public class MetricsManager extends Object implements AutoCloseable
| 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) |
| 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() |
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)
public void init()
public void start()
public void stop()
public void close()
close in interface AutoCloseablepublic void reportFinalMetrics()
public MetricsCollectingExecutionListener getExecutionListener()
Copyright © 2017–2021 DataStax. All rights reserved.