Uses of Class
com.bigdata.service.ndx.pipeline.AbstractSubtaskStats

Packages that use AbstractSubtaskStats

Package	Description
com.bigdata.service.ndx.pipeline

Uses of AbstractSubtaskStats in com.bigdata.service.ndx.pipeline

Classes in com.bigdata.service.ndx.pipeline with type parameters of type AbstractSubtaskStats

Modifier and Type	Class and Description
class	AbstractMasterStats<L,HS extends AbstractSubtaskStats> Abstract base class providing statistics for the AbstractMasterTask and a factory for the statistics for the subtasks.
class	AbstractMasterTask<H extends AbstractMasterStats<L,? extends AbstractSubtaskStats>,E,S extends AbstractSubtask,L> Abstract base class for a master task which consumes chunks of elements written onto a BlockingBuffer and distributes those chunks to subtasks according to some abstraction which is not defined by this class.
class	AbstractPendingSetMasterStats<L,HS extends AbstractSubtaskStats> 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.
class	AbstractPendingSetMasterTask<H extends AbstractPendingSetMasterStats<L,? extends AbstractSubtaskStats>,E,S extends AbstractPendingSetSubtask,L> Extends the master task to track outstanding asynchronous operations on work items.
class	AbstractPendingSetSubtask<HS extends AbstractSubtaskStats,M extends AbstractPendingSetMasterTask<? extends AbstractPendingSetMasterStats<L,HS>,E,? extends AbstractPendingSetSubtask,L>,E,L> Extended to assign chunks of work items to a remote IAsynchronousClientTask, to track the set of outstanding asynchronous operations for a specific client task (the "pending set"), and to close the client task when the sink not assign any more work to that client.
class	AbstractRunnableMasterStats<L,HS extends AbstractSubtaskStats> Statistics for the consumer, including several moving averages based on sampled data.
class	AbstractSubtask<HS extends AbstractSubtaskStats,M extends AbstractMasterTask<? extends AbstractMasterStats<L,HS>,E,? extends AbstractSubtask,L>,E,L> Abstract implementation of a subtask for the AbstractMasterTask handles the protocol for startup and termination of the subtask.

Subclasses of AbstractSubtaskStats in com.bigdata.service.ndx.pipeline

Modifier and Type	Class and Description
class	IndexPartitionWriteStats Statistics reported for each index partition.
class	MockSubtaskStats Class exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statistics objects.

Fields in com.bigdata.service.ndx.pipeline declared as AbstractSubtaskStats

Modifier and Type	Field and Description
protected HS	AbstractSubtask.stats The statistics used by this task.

Method parameters in com.bigdata.service.ndx.pipeline with type arguments of type AbstractSubtaskStats

Modifier and Type	Method and Description
protected void	IndexWriteTask.submitSubtask(FutureTask<? extends AbstractSubtaskStats> subtask)
protected abstract void	AbstractMasterTask.submitSubtask(FutureTask<? extends AbstractSubtaskStats> subtask) Submit the subtask to an Executor.