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
public abstract class ScheduledStormReporter extends Object implements StormReporter
-
-
Field Summary
Fields Modifier and Type Field Description protected com.codahale.metrics.ScheduledReporterreporterprotected longreportingPeriodprotected TimeUnitreportingPeriodUnit-
Fields inherited from interface org.apache.storm.metrics2.reporters.StormReporter
REPORT_DIMENSIONS_ENABLED, REPORT_PERIOD, REPORT_PERIOD_UNITS
-
-
Constructor Summary
Constructors Constructor Description ScheduledStormReporter()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()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, wait
-
Methods inherited from interface org.apache.storm.metrics2.reporters.StormReporter
prepare, prepare
-
-
-
-
Field Detail
-
reporter
protected com.codahale.metrics.ScheduledReporter reporter
-
reportingPeriod
protected long reportingPeriod
-
reportingPeriodUnit
protected TimeUnit reportingPeriodUnit
-
-
Method Detail
-
isReportDimensionsEnabled
public static boolean isReportDimensionsEnabled(Map<String,Object> reporterConf)
-
getMetricsFilter
public static StormMetricsFilter getMetricsFilter(Map<String,Object> reporterConf)
-
start
public void start()
- Specified by:
startin interfaceStormReporter
-
stop
public void stop()
- Specified by:
stopin interfaceStormReporter
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-
-