public class ReadsReportingExecutionListener extends AbstractMetricsReportingExecutionListener implements ExecutionListener
ExecutionListener that reports useful metrics about ongoing bulk read operations. It
relies on a delegate MetricsCollectingExecutionListener as its source of metrics.BYTES_PER_KB, BYTES_PER_MB| Constructor and Description |
|---|
ReadsReportingExecutionListener()
Creates a default instance of
ReadsReportingExecutionListener. |
ReadsReportingExecutionListener(MetricsCollectingExecutionListener delegate)
Creates an instance of
ReadsReportingExecutionListener using the given delegate. |
| Modifier and Type | Method and Description |
|---|---|
static AbstractMetricsReportingExecutionListenerBuilder<ReadsReportingExecutionListener> |
builder()
Creates a new builder for this class.
|
void |
report(SortedMap<String,com.codahale.metrics.Gauge> gauges,
SortedMap<String,com.codahale.metrics.Counter> counters,
SortedMap<String,com.codahale.metrics.Histogram> histograms,
SortedMap<String,com.codahale.metrics.Meter> meters,
SortedMap<String,com.codahale.metrics.Timer> timers) |
onExecutionFailed, onExecutionStarted, onExecutionSuccessful, onReadRequestFailed, onReadRequestStarted, onReadRequestSuccessful, onRowReceived, onWriteRequestFailed, onWriteRequestStarted, onWriteRequestSuccessfulclose, convertDuration, convertRate, getDisabledMetricAttributes, getDurationUnit, getRateUnit, isShutdownExecutorOnStop, report, start, start, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonExecutionFailed, onExecutionStarted, onExecutionSuccessful, onReadRequestFailed, onReadRequestStarted, onReadRequestSuccessful, onRowReceived, onWriteRequestFailed, onWriteRequestStarted, onWriteRequestSuccessfulpublic ReadsReportingExecutionListener()
ReadsReportingExecutionListener.
The instance will express rates in operations per second, and durations in milliseconds.
public ReadsReportingExecutionListener(MetricsCollectingExecutionListener delegate)
ReadsReportingExecutionListener using the given delegate.
The instance will express rates in operations per second, and durations in milliseconds.
delegate - the ReadsReportingExecutionListener to use as metrics source.public static AbstractMetricsReportingExecutionListenerBuilder<ReadsReportingExecutionListener> builder()
public void report(SortedMap<String,com.codahale.metrics.Gauge> gauges, SortedMap<String,com.codahale.metrics.Counter> counters, SortedMap<String,com.codahale.metrics.Histogram> histograms, SortedMap<String,com.codahale.metrics.Meter> meters, SortedMap<String,com.codahale.metrics.Timer> timers)
report in class com.codahale.metrics.ScheduledReporterCopyright © 2017–2021 DataStax. All rights reserved.