com.bigdata.service.ndx.pipeline

Class AbstractSubtaskStats

java.lang.Object

com.bigdata.service.ndx.pipeline.AbstractSubtaskStats

Direct Known Subclasses:

IndexPartitionWriteStats, MockSubtaskStats

public class AbstractSubtaskStats
extends Object

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
AtomicLong	chunksOut The #of chunks written onto the index partition using RMI.
long	elapsedChunkWaitingNanos Elapsed time waiting for another chunk to be ready so that it can be written onto the index partition.
long	elapsedChunkWritingNanos Elapsed nanoseconds writing chunks on an index partition (RMI request).
AtomicLong	elementsOut The #of elements in the output chunks (not including any eliminated duplicates).

Constructor Summary

Constructors

Constructor and Description
AbstractSubtaskStats()

Method Summary

Methods

Modifier and Type	Method and Description
double	getAverageElementsPerWrite() The average #of elements (tuples) per chunk written on the sink (this is an average of the totals to date, not a moving average).
double	getAverageNanosPerWait() The average #of nanoseconds for a chunk to become ready so that it can be written on the sink (this is an average of the totals to date, not a moving average).
double	getAverageNanosPerWrite() The average #of nanoseconds per chunk written on the sink (this is an average of the totals to date, not a moving average).
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

elementsOut

public final AtomicLong elementsOut

The #of elements in the output chunks (not including any eliminated duplicates).

Note: The AtomicLong provides an atomic update guarantee which some of the unit tests rely on.

chunksOut

public final AtomicLong chunksOut

The #of chunks written onto the index partition using RMI.

Note: The AtomicLong provides an atomic update guarantee which some of the unit tests rely on.

elapsedChunkWaitingNanos

public long elapsedChunkWaitingNanos

Elapsed time waiting for another chunk to be ready so that it can be written onto the index partition.

elapsedChunkWritingNanos

public long elapsedChunkWritingNanos

Elapsed nanoseconds writing chunks on an index partition (RMI request).

Constructor Detail

AbstractSubtaskStats

public AbstractSubtaskStats()

Method Detail

getAverageNanosPerWait

public double getAverageNanosPerWait()

The average #of nanoseconds for a chunk to become ready so that it can be written on the sink (this is an average of the totals to date, not a moving average).

getAverageNanosPerWrite

public double getAverageNanosPerWrite()

The average #of nanoseconds per chunk written on the sink (this is an average of the totals to date, not a moving average).

getAverageElementsPerWrite

public double getAverageElementsPerWrite()

The average #of elements (tuples) per chunk written on the sink (this is an average of the totals to date, not a moving average).

toString

public String toString()

Overrides:

toString in class Object