Package io.deephaven.extensions.barrage

Class BarragePerformanceLog.SnapshotMetricsHelper

java.lang.Object

io.deephaven.extensions.barrage.BarragePerformanceLog.SnapshotMetricsHelper

All Implemented Interfaces:

BarrageMessageWriter.WriteMetricsConsumer

Enclosing class:

BarragePerformanceLog

public static class BarragePerformanceLog.SnapshotMetricsHelper
extends Object
implements BarrageMessageWriter.WriteMetricsConsumer

Field Summary

Fields

Modifier and Type	Field	Description
long	queueNanos
final Instant	requestTm
long	snapshotNanos
String	tableId
String	tableKey

Fields inherited from interface io.deephaven.extensions.barrage.BarrageMessageWriter.WriteMetricsConsumer

NO_OP

Constructor Summary

Constructors

Constructor	Description
SnapshotMetricsHelper()

Method Summary

Modifier and Type	Method	Description
void	onWrite(long bytesWritten, long writeNanos)	Called once the whole message has been written, with its size and how long it took to write.

Methods inherited from class java.lang.Object

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

Field Details

requestTm

public final Instant requestTm

tableId

public String tableId

tableKey

public String tableKey

queueNanos

public long queueNanos

snapshotNanos

public long snapshotNanos

Constructor Details

SnapshotMetricsHelper

public SnapshotMetricsHelper()

Method Details

onWrite

public void onWrite(long bytesWritten,
 long writeNanos)

Description copied from interface: BarrageMessageWriter.WriteMetricsConsumer

Called once the whole message has been written, with its size and how long it took to write. A view that several subscribers share is written once, so this is called once for all of them.

Specified by:

onWrite in interface BarrageMessageWriter.WriteMetricsConsumer

Parameters:

bytesWritten - the number of bytes in the message, every batch it was written as counted, dictionary batches included

writeNanos - the elapsed nanoseconds, not CPU time, from starting to encode the message until the visitor returned from its last batch; this includes the visitor's own time, such as delivering each batch