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>

Direct Known Subclasses:

ResourceBufferStatistics

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: AbstractPendingSetMasterStats.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

TODO:

stdev? min?

Nested Class Summary

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

AbstractPendingSetMasterStats(AbstractFederation<?> fed)

Method Summary

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()