Package org.apache.storm.metric
Class ClusterMetricsConsumerExecutor
java.lang.Object
org.apache.storm.metric.ClusterMetricsConsumerExecutor
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionClusterMetricsConsumerExecutor(String consumerClassName, Object registrationArgument) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()voidhandleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints) voidhandleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints) voidprepare()
- 
Field Details- 
LOGpublic static final org.slf4j.Logger LOG
 
- 
- 
Constructor Details- 
ClusterMetricsConsumerExecutor
 
- 
- 
Method Details- 
preparepublic void prepare()
- 
handleDataPointspublic void handleDataPoints(IClusterMetricsConsumer.ClusterInfo clusterInfo, Collection<DataPoint> dataPoints) 
- 
handleDataPointspublic void handleDataPoints(IClusterMetricsConsumer.SupervisorInfo supervisorInfo, Collection<DataPoint> dataPoints) 
- 
cleanuppublic void cleanup()
 
-