com.bigdata.service.ndx.pipeline

Class AbstractPendingSetMasterStats<L,HS extends AbstractSubtaskStats>

java.lang.Object

com.bigdata.service.ndx.pipeline.AbstractMasterStats<L,HS>

com.bigdata.service.ndx.pipeline.AbstractRunnableMasterStats<L,HS>

com.bigdata.service.ndx.pipeline.AbstractPendingSetMasterStats<L,HS>

public abstract class AbstractPendingSetMasterStats<L,HS extends AbstractSubtaskStats>
extends AbstractRunnableMasterStats<L,HS>

Extended to report the moving average of the pending set size for the master and the sinks and to report the maximum pending set size for the sinks.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractPendingSetMasterStats.PendingSetStatisticsTask Extended to report the average #of operations in the pending set for the master and the sinks.

Nested classes/interfaces inherited from class com.bigdata.service.ndx.pipeline.AbstractRunnableMasterStats

AbstractRunnableMasterStats.StatisticsTask

Field Summary

Fields inherited from class com.bigdata.service.ndx.pipeline.AbstractRunnableMasterStats

duplicateCount, elapsedHandleChunkNanos, elapsedSplitChunkNanos, handledChunkCount, scalingFactor, statisticsTask

Fields inherited from class com.bigdata.service.ndx.pipeline.AbstractMasterStats

chunksIn, chunksOut, chunksTransferred, elapsedRedirectNanos, elapsedSinkChunkWaitingNanos, elapsedSinkChunkWritingNanos, elapsedSinkOfferNanos, elementsIn, elementsOnSinkQueues, elementsOut, elementsTransferred, masterCreateCount, masters, redirectCount, subtaskEndCount, subtaskIdleTimeoutCount, subtaskStartCount

Constructor Summary

Constructors

Constructor and Description
AbstractPendingSetMasterStats(AbstractFederation<?> fed)

Method Summary

Methods

Modifier and Type	Method and Description
CounterSet	getCounters()
protected AbstractPendingSetMasterStats.PendingSetStatisticsTask	newStatisticsTask() Return the AbstractRunnableMasterStats.StatisticsTask that will sample various counters of interest and convert them into moving averages.

Methods inherited from class com.bigdata.service.ndx.pipeline.AbstractRunnableMasterStats

getCounterSet, newSubtaskStats, toString

Methods inherited from class com.bigdata.service.ndx.pipeline.AbstractMasterStats

getActiveSinkCount, getMasterActiveCount, getMaximumPartitionCount, getSubtaskStats, getSubtaskStats

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPendingSetMasterStats

public AbstractPendingSetMasterStats(AbstractFederation<?> fed)

Parameters:

fed -

Method Detail

newStatisticsTask

protected AbstractPendingSetMasterStats.PendingSetStatisticsTask newStatisticsTask()

Description copied from class: AbstractRunnableMasterStats

Return the AbstractRunnableMasterStats.StatisticsTask that will sample various counters of interest and convert them into moving averages. This be overridden to extend the sampled counters. However, you MUST also override AbstractRunnableMasterStats.getCounterSet() to report any additional data.

Overrides:

newStatisticsTask in class AbstractRunnableMasterStats<L,HS extends AbstractSubtaskStats>

getCounters

public CounterSet getCounters()