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