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

TestMetricsCollectionService()

Method Summary

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