co.cask.cdap.data2.metrics

Class LevelDBDatasetMetricsReporter

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

co.cask.cdap.data2.metrics.LevelDBDatasetMetricsReporter

All Implemented Interfaces:

DatasetMetricsReporter, com.google.common.util.concurrent.Service

public class LevelDBDatasetMetricsReporter
extends com.google.common.util.concurrent.AbstractScheduledService
implements DatasetMetricsReporter

Collects LevelDB-based dataset's metrics from levelDB.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.util.concurrent.AbstractScheduledService

com.google.common.util.concurrent.AbstractScheduledService.CustomScheduler, com.google.common.util.concurrent.AbstractScheduledService.Scheduler

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
LevelDBDatasetMetricsReporter(MetricsCollectionService metricsService, LevelDBTableService ldbService, DatasetFramework dsFramework, CConfiguration conf)

Method Summary

Methods

Modifier and Type	Method and Description
protected ScheduledExecutorService	executor()
protected void	runOneIteration()
protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler	scheduler()
protected void	shutDown()

Methods inherited from class com.google.common.util.concurrent.AbstractScheduledService

addListener, isRunning, start, startAndWait, startUp, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, isRunning, start, startAndWait, state, stop, stopAndWait

Constructor Detail

LevelDBDatasetMetricsReporter

@Inject
public LevelDBDatasetMetricsReporter(MetricsCollectionService metricsService,
                                    LevelDBTableService ldbService,
                                    DatasetFramework dsFramework,
                                    CConfiguration conf)

Method Detail

shutDown

protected void shutDown()
                 throws Exception

Overrides:

shutDown in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception

runOneIteration

protected void runOneIteration()
                        throws Exception

Specified by:

runOneIteration in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception

scheduler

protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler scheduler()

Specified by:

scheduler in class com.google.common.util.concurrent.AbstractScheduledService

executor

protected final ScheduledExecutorService executor()

Overrides:

executor in class com.google.common.util.concurrent.AbstractScheduledService