Package org.apache.storm.metric

Class ClusterMetricsConsumerExecutor

java.lang.Object

org.apache.storm.metric.ClusterMetricsConsumerExecutor

public class ClusterMetricsConsumerExecutor
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
ClusterMetricsConsumerExecutor(String consumerClassName, Object registrationArgument)

Method Summary

Modifier and Type	Method	Description
void	cleanup()
void	handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints)
void	handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints)
void	prepare()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

ClusterMetricsConsumerExecutor

public ClusterMetricsConsumerExecutor(String consumerClassName,
                                      Object registrationArgument)

Method Detail

prepare

public void prepare()

handleDataPoints

public void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo,
                             Collection<DataPoint> dataPoints)

handleDataPoints

public void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo,
                             Collection<DataPoint> dataPoints)

cleanup

public void cleanup()