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

Packages that use AbstractSubtask

Package	Description
com.bigdata.service.ndx.pipeline

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

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

Modifier and Type	Class and Description
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	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.
interface	SubtaskOp<S extends AbstractSubtask> An operation which can be mapped across subtasks.

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

Modifier and Type	Class and Description
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	IndexPartitionWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,L extends PartitionLocator,S extends IndexPartitionWriteTask,HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,T extends IKeyArrayIndexProcedure,R,A> Class drains a BlockingBuffer writing on a specific index partition.
class	MockSubtask<H extends MockMasterStats<L,HS>,O,E extends KVO<O>,L,S extends MockSubtask,HS extends MockSubtaskStats,M extends MockMaster<H,O,E,S,L,HS>> 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.

Methods in com.bigdata.service.ndx.pipeline with parameters of type AbstractSubtask

Modifier and Type	Method and Description
protected void	AbstractMasterTask.moveSinkToFinishedQueueAtomically(L locator, AbstractSubtask sink) Transfer a sink from AbstractMasterTask.sinks to AbstractMasterTask.finishedSubtaskQueue.
protected void	AbstractMasterTask.notifySubtaskDone(AbstractSubtask subtask) Notify the master that a subtask is done.