Uses of Interface
com.bigdata.service.ndx.pipeline.IMasterTask

Packages that use IMasterTask

Package	Description
com.bigdata.service.ndx.pipeline

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

Classes in com.bigdata.service.ndx.pipeline that implement IMasterTask

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	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.