Package | Description |
---|---|
com.bigdata.service.ndx | |
com.bigdata.service.ndx.pipeline |
Modifier and Type | Class and Description |
---|---|
class |
AbstractScaleOutClientIndexView
Abstract base class for the
IScaleOutClientIndex implementation(s). |
class |
AbstractScaleOutClientIndexView2
Abstract class encapsulating MOST of the logic for executing tasks
corresponding to client index operations.
|
class |
ClientIndexView
A client-side view of a scale-out index as of some timestamp.
|
class |
ClientIndexViewRefactor
A client-side view of a scale-out index as of some timestamp.
|
Modifier and Type | Field and Description |
---|---|
protected IScaleOutClientIndex |
DataServiceTupleIterator.ndx
Used to submit delete requests to the scale-out index in a robust
manner.
|
Constructor and Description |
---|
DataServiceTupleIterator(IScaleOutClientIndex ndx,
IDataService dataService,
String name,
long timestamp,
byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter) |
PartitionedTupleIterator(IScaleOutClientIndex ndx,
long ts,
boolean isReadConsistentTx,
byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
Note: The
PartitionedTupleIterator uses a sequential scan (rather
than mapping across the index partitions in parallel) and always picks up
from the successor of the last key visited. |
Modifier and Type | Field and Description |
---|---|
protected IScaleOutClientIndex |
IndexWriteTask.ndx |
Constructor and Description |
---|
IndexWriteTask.M(IScaleOutClientIndex ndx,
long sinkIdleTimeoutNanos,
long sinkPollTimeoutNanos,
int sinkQueueCapacity,
int sinkChunkSize,
long sinkChunkTimeoutNanos,
IDuplicateRemover<O> duplicateRemover,
AbstractKeyArrayIndexProcedureConstructor<T> ctor,
IResultHandler<R,A> resultHandler,
IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats> stats,
BlockingBuffer<KVO<O>[]> buffer) |
IndexWriteTask(IScaleOutClientIndex ndx,
long sinkIdleTimeoutNanos,
long sinkPollTimeoutNanos,
int sinkQueueCapacity,
int sinkChunkSize,
long sinkChunkTimeoutNanos,
IDuplicateRemover<O> duplicateRemover,
AbstractKeyArrayIndexProcedureConstructor<T> ctor,
IResultHandler<R,A> resultHandler,
H stats,
BlockingBuffer<E[]> buffer) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.