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

Packages that use AbstractMasterTask

Package	Description
com.bigdata.service.ndx.pipeline

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

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

Modifier and Type	Class and Description
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 AbstractMasterTask in com.bigdata.service.ndx.pipeline

Modifier and Type	Class and Description
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	IndexWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,S extends IndexPartitionWriteTask,L extends PartitionLocator,HS extends IndexPartitionWriteStats,T extends IKeyArrayIndexProcedure,R,A> Task drains a BlockingBuffer containing KVO[] chunks, splits the chunks based on the separator keys for the scale-out index, and then assigns each chunk to per-index partition BlockingBuffer which is in turned drained by an IndexPartitionWriteTask that writes onto a specific index partition.
static class	IndexWriteTask.M<T extends IKeyArrayIndexProcedure,O,R,A> Concrete master hides most of the generic types leaving you with only those that are meaningfully parameterize for applications using the streaming write API.
class	MockMaster<H extends MockMasterStats<L,HS>,O,E extends KVO<O>,S extends MockSubtask,L,HS extends 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 AbstractMasterTask

Modifier and Type	Field and Description
protected M	AbstractSubtask.master The master.

Fields in com.bigdata.service.ndx.pipeline with type parameters of type AbstractMasterTask

Modifier and Type	Field and Description
protected ConcurrentWeakValueCache<Integer,AbstractMasterTask>	AbstractMasterStats.masters Weak value hash map of the active masters.