Module datarush.library

Package com.pervasive.datarush.ports.physical

Class InputSnapshot

java.lang.Object

com.pervasive.datarush.ports.physical.PortSnapshot

com.pervasive.datarush.ports.physical.InputSnapshot

All Implemented Interfaces:

InputStatistics, PortStatistics, Serializable

public class InputSnapshot
extends PortSnapshot
implements InputStatistics

A snapshot of run-time statistics for an input port.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
InputSnapshot(InputStatistics stats)	Creates a snapshot of input statistics.

Method Summary

Modifier and Type	Method	Description
long	getIndirectWaitCount()	Gets the number of times the port entered a wait state because the writer was blocked by a different reader.
long	getIndirectWaitDuration()	Gets the total amount of time the port has spent in a wait state because the writer was blocked by a different reader.
InputSnapshot	getSnapshot()	Gets a snapshot of the current statistics.

Methods inherited from class com.pervasive.datarush.ports.physical.PortSnapshot

asSnapshots, getBatchCount, getDataDuration, getEODInstant, getFirstBatchInstant, getName, getState, getTokenCount, getType, getWaitCount, getWaitDuration

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.pervasive.datarush.ports.physical.PortStatistics

getBatchCount, getDataDuration, getEODInstant, getFirstBatchInstant, getName, getState, getTokenCount, getType, getWaitCount, getWaitDuration

Constructor Details

InputSnapshot

public InputSnapshot(InputStatistics stats)

Creates a snapshot of input statistics.

Parameters:

stats - the live statistics to capture

Method Details

getIndirectWaitCount

public long getIndirectWaitCount()

Gets the number of times the port entered a wait state because the writer was blocked by a different reader. This is only applicable to input ports.

Specified by:

getIndirectWaitCount in interface InputStatistics

Returns:

the accumulated number of waits due to another reader

getIndirectWaitDuration

public long getIndirectWaitDuration()

Gets the total amount of time the port has spent in a wait state because the writer was blocked by a different reader. This is only applicable to input ports.

Specified by:

getIndirectWaitDuration in interface InputStatistics

Returns:

milliseconds spent in an indirect wait state

getSnapshot

public InputSnapshot getSnapshot()

Description copied from interface: PortStatistics

Gets a snapshot of the current statistics.

Specified by:

getSnapshot in interface InputStatistics

Specified by:

getSnapshot in interface PortStatistics

Returns:

an immutable copy of the statistics