Class ScheduledStormReporter
java.lang.Object
org.apache.storm.metrics2.reporters.ScheduledStormReporter
- All Implemented Interfaces:
com.codahale.metrics.Reporter,Closeable,AutoCloseable,StormReporter
- Direct Known Subclasses:
ConsoleStormReporter,CsvStormReporter,GraphiteStormReporter
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected com.codahale.metrics.ScheduledReporterprotected longprotected TimeUnitFields inherited from interface org.apache.storm.metrics2.reporters.StormReporter
REPORT_DIMENSIONS_ENABLED, REPORT_PERIOD, REPORT_PERIOD_UNITS -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()static StormMetricsFiltergetMetricsFilter(Map<String, Object> reporterConf) static longgetReportPeriod(Map<String, Object> reporterConf) static TimeUnitgetReportPeriodUnit(Map<String, Object> reporterConf) static booleanisReportDimensionsEnabled(Map<String, Object> reporterConf) voidstart()voidstop()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.metrics2.reporters.StormReporter
prepare, prepare
-
Field Details
-
reporter
protected com.codahale.metrics.ScheduledReporter reporter -
reportingPeriod
protected long reportingPeriod -
reportingPeriodUnit
-
-
Constructor Details
-
ScheduledStormReporter
public ScheduledStormReporter()
-
-
Method Details
-
getReportPeriodUnit
-
getReportPeriod
-
isReportDimensionsEnabled
-
getMetricsFilter
-
start
public void start()- Specified by:
startin interfaceStormReporter
-
stop
public void stop()- Specified by:
stopin interfaceStormReporter
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-