Class ConsoleStormReporter
- java.lang.Object
-
- org.apache.storm.metrics2.reporters.ScheduledStormReporter
-
- org.apache.storm.metrics2.reporters.ConsoleStormReporter
-
- All Implemented Interfaces:
com.codahale.metrics.Reporter,Closeable,AutoCloseable,DimensionalReporter.DimensionHandler,StormReporter
public class ConsoleStormReporter extends ScheduledStormReporter implements DimensionalReporter.DimensionHandler
-
-
Field Summary
-
Fields inherited from class org.apache.storm.metrics2.reporters.ScheduledStormReporter
reporter, reportingPeriod, reportingPeriodUnit
-
Fields inherited from interface org.apache.storm.metrics2.reporters.StormReporter
REPORT_DIMENSIONS_ENABLED, REPORT_PERIOD, REPORT_PERIOD_UNITS
-
-
Constructor Summary
Constructors Constructor Description ConsoleStormReporter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidprepare(com.codahale.metrics.MetricRegistry registry, Map<String,Object> topoConf, Map<String,Object> reporterConf)voidprepare(MetricRegistryProvider metricRegistryProvider, Map<String,Object> topoConf, Map<String,Object> reporterConf)voidsetDimensions(Map<String,String> dimensions)Sets dimensions to be used for reporting on the next batch of metrics.-
Methods inherited from class org.apache.storm.metrics2.reporters.ScheduledStormReporter
getMetricsFilter, getReportPeriod, getReportPeriodUnit, isReportDimensionsEnabled, start, stop
-
-
-
-
Method Detail
-
prepare
public void prepare(com.codahale.metrics.MetricRegistry registry, Map<String,Object> topoConf, Map<String,Object> reporterConf)- Specified by:
preparein interfaceStormReporter
-
prepare
public void prepare(MetricRegistryProvider metricRegistryProvider, Map<String,Object> topoConf, Map<String,Object> reporterConf)
- Specified by:
preparein interfaceStormReporter
-
setDimensions
public void setDimensions(Map<String,String> dimensions)
Description copied from interface:DimensionalReporter.DimensionHandlerSets dimensions to be used for reporting on the next batch of metrics.- Specified by:
setDimensionsin interfaceDimensionalReporter.DimensionHandler- Parameters:
dimensions- dimensions valid for use in the next scheduled report.
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classScheduledStormReporter- Throws:
IOException
-
-