Uses of Package
com.bigdata.service.ndx.pipeline

Packages that use com.bigdata.service.ndx.pipeline

Package	Description
com.bigdata.rdf.lexicon
com.bigdata.service.ndx
com.bigdata.service.ndx.pipeline

Classes in com.bigdata.service.ndx.pipeline used by com.bigdata.rdf.lexicon

Class and Description
KVOList.Op An operation which can be mapped over the duplicate list.

Classes in com.bigdata.service.ndx.pipeline used by com.bigdata.service.ndx

Class and Description
IDuplicateRemover Interface allowing application specific elimination of duplicates.
IndexAsyncWriteStats Statistics for asynchronous index writes.

Classes in com.bigdata.service.ndx.pipeline used by com.bigdata.service.ndx.pipeline

Class and Description
AbstractKeyRangeMasterTestCase Abstract base class for test suites for the AbstractMasterTask and friends using IPartitionMetadata locators.
AbstractMasterStats Abstract base class providing statistics for the AbstractMasterTask and a factory for the statistics for the subtasks.
AbstractMasterTask 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.
AbstractMasterTestCase Abstract base class for test suites for the AbstractMasterTask and friends.
AbstractPendingSetMasterStats 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.
AbstractPendingSetMasterStats.PendingSetStatisticsTask Extended to report the average #of operations in the pending set for the master and the sinks.
AbstractPendingSetMasterTask Extends the master task to track outstanding asynchronous operations on work items.
AbstractPendingSetSubtask 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.
AbstractRunnableMasterStats Statistics for the consumer, including several moving averages based on sampled data.
AbstractRunnableMasterStats.StatisticsTask Task samples various counters of interest and convert them into moving averages.
AbstractSubtask Abstract implementation of a subtask for the AbstractMasterTask handles the protocol for startup and termination of the subtask.
AbstractSubtaskStats
IDuplicateRemover Interface allowing application specific elimination of duplicates.
IMasterTask Interface for task consuming data written on an application on an asynchronous write buffer.
IndexAsyncWriteStats Statistics for asynchronous index writes.
IndexPartitionWriteStats Statistics reported for each index partition.
IndexPartitionWriteTask Class drains a BlockingBuffer writing on a specific index partition.
IndexWriteTask 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.
KVOLatch A synchronization aid that allows one or more threads to await asynchronous writes on one or more scale-out indices.
KVOList Extends KVO to allow duplicates to be gathered together in a doubly-linked list.
KVOList.Op An operation which can be mapped over the duplicate list.
MockMaster 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.
MockMasterStats 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.
MockSubtask 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.
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.
SubtaskOp An operation which can be mapped across subtasks.