Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Com.bigdata.service.ndx.pipeline Classes and Interfaces - 38 results found.
NameDescriptionTypePackageFramework
AbstractKeyRangeMasterTestCaseAbstract base class for test suites for the AbstractMasterTask and friends using IPartitionMetadata locators.Classcom.bigdata.service.ndx.pipelineBlazeGraph
AbstractMasterStatsAbstract base class providing statistics for the AbstractMasterTask and a factory for the statistics for the subtasks.Classcom.bigdata.service.ndx.pipelineBlazeGraph
AbstractMasterTaskAbstract base class for a master task which consumes chunks of elements written onto a BlockingBuffer and distributes those chunks toClasscom.bigdata.service.ndx.pipelineBlazeGraph
AbstractMasterTestCaseAbstract base class for test suites for the AbstractMasterTask and Note: There are a bunch of inner classes which have the same names as theClasscom.bigdata.service.ndx.pipelineBlazeGraph
AbstractPendingSetMasterStats and the sinks and to report the maximum pending set size for the sinks.Classcom.bigdata.service.ndx.pipelineBlazeGraph
AbstractPendingSetMasterTask The clients notify the AbstractPendingSetSubtask as each operation completes.Classcom.bigdata.service.ndx.pipelineBlazeGraph
AbstractPendingSetSubtask IAsynchronousClientTask, to track the set of outstanding asynchronous operations for a specific client task (the "pending set"), andClasscom.bigdata.service.ndx.pipelineBlazeGraph
AbstractRunnableMasterStatsStatistics for the consumer, including several moving averages based onVersion:$Id$Author:Bryan ThompsonClasscom.bigdata.service.ndx.pipelineBlazeGraph
AbstractSubtaskAbstract implementation of a subtask for the AbstractMasterTask handles the protocol for startup and termination of the subtask.Classcom.bigdata.service.ndx.pipelineBlazeGraph
AbstractSubtaskStatsClasscom.bigdata.service.ndx.pipelineBlazeGraph
DefaultDuplicateRemover unsigned byte[] key and the same byte[] value.Classcom.bigdata.service.ndx.pipelineBlazeGraph
IdleTimeoutExceptionAn instance of this exception is thrown when a sink closes it's input queue due to an idle timeout (nothing has been written on its input queue for aClasscom.bigdata.service.ndx.pipelineBlazeGraph
IDuplicateRemoverInterface allowing application specific elimination of duplicates.Interfacecom.bigdata.service.ndx.pipelineBlazeGraph
IMasterTaskInterface for task consuming data written on an application on an asynchronous write buffer.Interfacecom.bigdata.service.ndx.pipelineBlazeGraph
IndexAsyncWriteStatsStatistics for asynchronous index writes.Classcom.bigdata.service.ndx.pipelineBlazeGraph
IndexPartitionWriteStatsStatistics reported for each index partition.Classcom.bigdata.service.ndx.pipelineBlazeGraph
IndexPartitionWriteTaskClass drains a BlockingBuffer writing on a specific indexVersion:$Id$Author:Bryan ThompsonClasscom.bigdata.service.ndx.pipelineBlazeGraph
IndexWriteTaskTask drains a BlockingBuffer containing KVO[] chunks, splits the chunks based on the separator keys for the scale-out index, and thenClasscom.bigdata.service.ndx.pipelineBlazeGraph
IndexWriteTask .MConcrete master hides most of the generic types leaving you with only those that are meaningfully parameterize for applications using theClasscom.bigdata.service.ndx.pipelineBlazeGraph
KVOC Note: IDuplicateRemovers MUST create a list from the identified duplicates so that the KVOLatch of each duplicate as well as theClasscom.bigdata.service.ndx.pipelineBlazeGraph
KVOLatchA synchronization aid that allows one or more threads to await asynchronous writes on one or more scale-out indices.Classcom.bigdata.service.ndx.pipelineBlazeGraph
KVOList doubly-linked list.Classcom.bigdata.service.ndx.pipelineBlazeGraph
KVOList .OpAn operation which can be mapped over the duplicate list.Interfacecom.bigdata.service.ndx.pipelineBlazeGraph
MasterExhaustedExceptionAn instance of this exception is thrown when a sink closes it's input queue due to the master being exhausted.Classcom.bigdata.service.ndx.pipelineBlazeGraph
MockMasterClass exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statisticsClasscom.bigdata.service.ndx.pipelineBlazeGraph
MockMasterStatsClass exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statisticsClasscom.bigdata.service.ndx.pipelineBlazeGraph
MockSubtaskClass exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statisticsClasscom.bigdata.service.ndx.pipelineBlazeGraph
MockSubtaskStatsClass exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statisticsClasscom.bigdata.service.ndx.pipelineBlazeGraph
NOPDuplicateRemoverClasscom.bigdata.service.ndx.pipelineBlazeGraph
SubtaskOpAn operation which can be mapped across subtasks.Interfacecom.bigdata.service.ndx.pipelineBlazeGraph
TestAllAggregates test suites in increasing dependency order.Classcom.bigdata.service.ndx.pipelineBlazeGraph
TestDefaultDuplicateRemoverTest suite for DefaultDuplicateRemover.Classcom.bigdata.service.ndx.pipelineBlazeGraph
TestFileSystemScannerClasscom.bigdata.service.ndx.pipelineBlazeGraph
TestMasterTaskUnit tests for the control logic used by AbstractMasterTask andVersion:$Id$Author:Bryan ThompsonClasscom.bigdata.service.ndx.pipelineBlazeGraph
TestMasterTaskIdleTimeoutUnit tests of the idle timeout behavior for AbstractMasterTask andVersion:$Id$Author:Bryan ThompsonClasscom.bigdata.service.ndx.pipelineBlazeGraph
TestMasterTaskWithErrorsUnit tests for error handling in the control logic used by AbstractMasterTask and friends.Classcom.bigdata.service.ndx.pipelineBlazeGraph
TestMasterTaskWithRedirectTest ability to handle a redirect (subtask learns that the target service no longer accepts data for some locator and instead must send the data somewhereClasscom.bigdata.service.ndx.pipelineBlazeGraph
TestMasterTaskWithSplitsStress test using key-range partitioned index (IMetadataIndex), which allows us to test the AbstractMasterTask under split, move, join andClasscom.bigdata.service.ndx.pipelineBlazeGraph