Name | Description | Type | Package | Framework |
AbstractKeyRangeMasterTestCase | Abstract base class for test suites for the AbstractMasterTask and friends using IPartitionMetadata locators. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractMasterStats | Abstract base class providing statistics for the AbstractMasterTask and a factory for the statistics for the subtasks. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractMasterTask | Abstract base class for a master task which consumes chunks of elements written onto a BlockingBuffer and distributes those chunks to | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractMasterTestCase | Abstract base class for test suites for the AbstractMasterTask and Note: There are a bunch of inner classes which have the same names as the | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractPendingSetMasterStats | and the sinks and to report the maximum pending set size for the sinks. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractPendingSetMasterTask | The clients notify the AbstractPendingSetSubtask as each operation completes. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractPendingSetSubtask | IAsynchronousClientTask, to track the set of outstanding asynchronous operations for a specific client task (the "pending set"), and | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractRunnableMasterStats | Statistics for the consumer, including several moving averages based onVersion:$Id$Author:Bryan Thompson | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractScaleOutClientIndexView | Abstract base class for the IScaleOutClientIndex implementation(s). | Class | com.bigdata.service.ndx | BlazeGraph |
|
AbstractScaleOutClientIndexView2 | Abstract class encapsulating MOST of the logic for executing tasks corresponding to client index operations. | Class | com.bigdata.service.ndx | BlazeGraph |
|
AbstractSplitter | Basic implementation - you only need to provide resolution for theVersion:$Id$Author:Bryan Thompson | Class | com.bigdata.service.ndx | BlazeGraph |
|
AbstractSubtask | Abstract implementation of a subtask for the AbstractMasterTask handles the protocol for startup and termination of the subtask. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
AbstractSubtaskStats | | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
ClientException | Exposes a linked list of retry exceptions leading to the failure of an AbstractDataServiceProcedureTask. | Class | com.bigdata.service.ndx | BlazeGraph |
|
ClientIndexView | A client-side view of a scale-out index as of some timestamp. | Class | com.bigdata.service.ndx | BlazeGraph |
|
ClientIndexViewRefactor | A client-side view of a scale-out index as of some timestamp. | Class | com.bigdata.service.ndx | BlazeGraph |
|
DataServiceTupleIterator | Class supports range query across against an unpartitioned index on anVersion:$Id$Author:Bryan Thompson | Class | com.bigdata.service.ndx | BlazeGraph |
|
DefaultDuplicateRemover | unsigned byte[] key and the same byte[] value. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IAsynchronousWriteBufferFactory | Interface for asynchronous writes on scale-out indices. | Interface | com.bigdata.service.ndx | BlazeGraph |
|
IClientIndex | IBigdataClient-side IIndex interface. | Interface | com.bigdata.service.ndx | BlazeGraph |
|
IdentityHandler | Hands back the object visited for a single index partition. | Class | com.bigdata.service.ndx | BlazeGraph |
|
IdleTimeoutException | An 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 a | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IDuplicateRemover | Interface allowing application specific elimination of duplicates. | Interface | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IMasterTask | Interface for task consuming data written on an application on an asynchronous write buffer. | Interface | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IndexAsyncWriteStats | Statistics for asynchronous index writes. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IndexPartitionWriteStats | Statistics reported for each index partition. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IndexPartitionWriteTask | Class drains a BlockingBuffer writing on a specific indexVersion:$Id$Author:Bryan Thompson | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IndexSyncRPCCounters | Counters used for sync RPC on scale-out indices. | Class | com.bigdata.service.ndx | BlazeGraph |
|
IndexWriteTask | Task drains a BlockingBuffer containing KVO[] chunks, splits the chunks based on the separator keys for the scale-out index, and then | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IndexWriteTask .M | Concrete master hides most of the generic types leaving you with only those that are meaningfully parameterize for applications using the | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
IScaleOutClientIndex | A client-side view of a scale-out index. | Interface | com.bigdata.service.ndx | BlazeGraph |
|
ISplitter | Interface for finding the Splits for an ordered set of unsigned byte[] keys. | Interface | com.bigdata.service.ndx | BlazeGraph |
|
KVOC | Note: IDuplicateRemovers MUST create a list from the identified duplicates so that the KVOLatch of each duplicate as well as the | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
KVOLatch | A synchronization aid that allows one or more threads to await asynchronous writes on one or more scale-out indices. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
KVOList | doubly-linked list. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
KVOList .Op | An operation which can be mapped over the duplicate list. | Interface | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
MasterExhaustedException | An instance of this exception is thrown when a sink closes it's input queue due to the master being exhausted. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
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 | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
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 | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
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 | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
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 | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
NopAggregator | NOP aggregator does nothing and returns null. | Class | com.bigdata.service.ndx | BlazeGraph |
|
NOPDuplicateRemover | | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
PartitionedTupleIterator | Class supports range query across one or more index partitions. | Class | com.bigdata.service.ndx | BlazeGraph |
|
RawDataServiceTupleIterator | Class supports range query across against an unpartitioned index on an IDataService but DOES NOT handle index partition splits, moves or | Class | com.bigdata.service.ndx | BlazeGraph |
|
ScaleOutIndexCounters | Counters pertaining to a scale-out index. | Class | com.bigdata.service.ndx | BlazeGraph |
|
SubtaskOp | An operation which can be mapped across subtasks. | Interface | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestAll | Aggregates test suites in increasing dependency order. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestAll | Aggregates test suites in increasing dependency order. | Class | com.bigdata.service.ndx | BlazeGraph |
|
TestDefaultDuplicateRemover | Test suite for DefaultDuplicateRemover. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestFileSystemScanner | | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestMasterTask | Unit tests for the control logic used by AbstractMasterTask andVersion:$Id$Author:Bryan Thompson | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestMasterTaskIdleTimeout | Unit tests of the idle timeout behavior for AbstractMasterTask andVersion:$Id$Author:Bryan Thompson | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestMasterTaskWithErrors | Unit tests for error handling in the control logic used by AbstractMasterTask and friends. | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestMasterTaskWithRedirect | Test ability to handle a redirect (subtask learns that the target service no longer accepts data for some locator and instead must send the data somewhere | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestMasterTaskWithSplits | Stress test using key-range partitioned index (IMetadataIndex), which allows us to test the AbstractMasterTask under split, move, join and | Class | com.bigdata.service.ndx.pipeline | BlazeGraph |
|
TestSplitter | Unit tests for ISplitter. | Class | com.bigdata.service.ndx | BlazeGraph |