com.datastax.oss.dsbulk.workflow.commons.metrics

Class MetricsManager

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

All Implemented Interfaces:

AutoCloseable

public class MetricsManager
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor and Description

MetricsManager(com.codahale.metrics.MetricRegistry driverRegistry, boolean monitorWrites, String executionId, ScheduledExecutorService scheduler, TimeUnit rateUnit, TimeUnit durationUnit, long expectedWrites, long expectedReads, boolean trackBytes, boolean jmx, boolean csv, boolean console, Path operationDirectory, LogSettings.Verbosity verbosity, Duration reportInterval, boolean batchingEnabled, ProtocolVersion protocolVersion, CodecRegistry codecRegistry, RowType rowType)

Method Summary

Modifier and Type	Method and Description
void	close()
MetricsCollectingExecutionListener	getExecutionListener()
void	init()
Function<Flux<Statement<?>>,Flux<Statement<?>>>	newBatcherMonitor()
<T> Function<Flux<T>,Flux<T>>	newFailedItemsMonitor()
<T> Function<Flux<T>,Flux<T>>	newTotalItemsMonitor()
void	reportFinalMetrics()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsManager

public MetricsManager(com.codahale.metrics.MetricRegistry driverRegistry,
                      boolean monitorWrites,
                      String executionId,
                      ScheduledExecutorService scheduler,
                      TimeUnit rateUnit,
                      TimeUnit durationUnit,
                      long expectedWrites,
                      long expectedReads,
                      boolean trackBytes,
                      boolean jmx,
                      boolean csv,
                      boolean console,
                      Path operationDirectory,
                      LogSettings.Verbosity verbosity,
                      Duration reportInterval,
                      boolean batchingEnabled,
                      ProtocolVersion protocolVersion,
                      CodecRegistry codecRegistry,
                      RowType rowType)

Method Detail

init

public void init()

start

public void start()

stop

public void stop()

close

public void close()

Specified by:

close in interface AutoCloseable

reportFinalMetrics

public void reportFinalMetrics()

newTotalItemsMonitor

public <T> Function<Flux<T>,Flux<T>> newTotalItemsMonitor()

newFailedItemsMonitor

public <T> Function<Flux<T>,Flux<T>> newFailedItemsMonitor()

newBatcherMonitor

public Function<Flux<Statement<?>>,Flux<Statement<?>>> newBatcherMonitor()

getExecutionListener

public MetricsCollectingExecutionListener getExecutionListener()