co.cask.cdap.test.internal

Class TestMetricsCollectionService

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

co.cask.cdap.metrics.collect.AggregatedMetricsCollectionService

co.cask.cdap.test.internal.TestMetricsCollectionService

All Implemented Interfaces:

co.cask.cdap.common.metrics.MetricsCollectionService, com.google.common.util.concurrent.Service

public final class TestMetricsCollectionService
extends AggregatedMetricsCollectionService

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
TestMetricsCollectionService()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	publish(co.cask.cdap.common.metrics.MetricsScope scope, Iterator<MetricsRecord> metrics)

Methods inherited from class co.cask.cdap.metrics.collect.AggregatedMetricsCollectionService

executor, getCollector, runOneIteration, scheduler, 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

TestMetricsCollectionService

public TestMetricsCollectionService()

Method Detail

publish

protected void publish(co.cask.cdap.common.metrics.MetricsScope scope,
           Iterator<MetricsRecord> metrics)
                throws Exception

Specified by:

publish in class AggregatedMetricsCollectionService

Throws:

Exception