Package org.apache.storm.metric
Class ClusterMetricsConsumerExecutor
java.lang.Object
org.apache.storm.metric.ClusterMetricsConsumerExecutor
-
Field Summary
-
Constructor Summary
ConstructorDescriptionClusterMetricsConsumerExecutor
(String consumerClassName, Object registrationArgument) -
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
void
handleDataPoints
(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints) void
handleDataPoints
(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints) void
prepare()
-
Field Details
-
LOG
public static final org.slf4j.Logger LOG
-
-
Constructor Details
-
ClusterMetricsConsumerExecutor
-
-
Method Details
-
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()
-