org.apache.storm.metrics2.reporters

Class ScheduledStormReporter

java.lang.Object

org.apache.storm.metrics2.reporters.ScheduledStormReporter

All Implemented Interfaces:

com.codahale.metrics.Reporter, StormReporter

Direct Known Subclasses:

ConsoleStormReporter, CsvStormReporter, GraphiteStormReporter

public abstract class ScheduledStormReporter
extends Object
implements StormReporter

Field Summary

Fields

Modifier and Type	Field and Description
protected com.codahale.metrics.ScheduledReporter	reporter
protected long	reportingPeriod
protected TimeUnit	reportingPeriodUnit

Fields inherited from interface org.apache.storm.metrics2.reporters.StormReporter

REPORT_PERIOD, REPORT_PERIOD_UNITS

Constructor Summary

Constructors

Constructor and Description
ScheduledStormReporter()

Method Summary

Modifier and Type	Method and Description
static StormMetricsFilter	getMetricsFilter(Map reporterConf)
static long	getReportPeriod(Map reporterConf)
static TimeUnit	getReportPeriodUnit(Map<String,Object> reporterConf)
void	start()
void	stop()

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

Field Detail

reporter

protected com.codahale.metrics.ScheduledReporter reporter

reportingPeriod

protected long reportingPeriod

reportingPeriodUnit

protected TimeUnit reportingPeriodUnit

Constructor Detail

ScheduledStormReporter

public ScheduledStormReporter()

Method Detail

getReportPeriodUnit

public static TimeUnit getReportPeriodUnit(Map<String,Object> reporterConf)

getReportPeriod

public static long getReportPeriod(Map reporterConf)

getMetricsFilter

public static StormMetricsFilter getMetricsFilter(Map reporterConf)

start

public void start()

Specified by:

start in interface StormReporter

stop

public void stop()

Specified by:

stop in interface StormReporter