Package | Description |
---|---|
com.bigdata.btree |
The
BTree is a scalable B+-Tree with copy-on-write
semantics mapping variable length unsigned byte[] keys to variable
length byte[] values (null values are allowed). |
com.bigdata.btree.proc | |
com.bigdata.btree.view | |
com.bigdata.rdf.lexicon | |
com.bigdata.rdf.spo |
This package defines a statement model using long term identifiers rather than
RDF Value objects.
|
com.bigdata.search |
This package provides full text indexing and search.
|
com.bigdata.service.ndx | |
com.bigdata.service.ndx.pipeline |
Modifier and Type | Method and Description |
---|---|
void |
DelegateIndex.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler handler) |
void |
IIndex.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler resultHandler)
Runs a procedure against an index.
|
void |
ReadCommittedView.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler resultHandler) |
void |
UnisolatedReadWriteIndex.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator) |
void |
ReadOnlyIndex.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator)
Overridden to ensure that procedure is applied against read-only view and
not the
DelegateIndex . |
void |
AbstractBTree.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator) |
Modifier and Type | Class and Description |
---|---|
static class |
BatchContains.BatchContainsConstructor
Factory for
BatchContains procedures. |
static class |
BatchInsert.BatchInsertConstructor
Factory for
BatchInsert procedures. |
static class |
BatchLookup.BatchLookupConstructor
Factory for
BatchLookup procedures. |
static class |
BatchPutIfAbsent.BatchPutIfAbsentConstructor
Factory for
BatchPutIfAbsent procedures. |
static class |
BatchRemove.BatchRemoveConstructor
Factory for
BatchRemove procedures. |
Modifier and Type | Method and Description |
---|---|
void |
FusedView.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator) |
Modifier and Type | Class and Description |
---|---|
static class |
BlobsWriteProc.BlobsWriteProcConstructor |
static class |
Id2TermWriteProc.Id2TermWriteProcConstructor |
static class |
Term2IdWriteProc.Term2IdWriteProcConstructor |
Modifier and Type | Class and Description |
---|---|
static class |
JustIndexWriteProc.WriteJustificationsProcConstructor |
static class |
SPOIndexWriteProc.IndexWriteProcConstructor |
Modifier and Type | Class and Description |
---|---|
static class |
TextIndexWriteProc.IndexWriteProcConstructor |
Modifier and Type | Method and Description |
---|---|
<T extends IKeyArrayIndexProcedure,O,R,A> |
AbstractScaleOutClientIndexView.newWriteBuffer(IResultHandler<R,A> resultHandler,
IDuplicateRemover<O> duplicateRemover,
AbstractKeyArrayIndexProcedureConstructor<T> ctor) |
<T extends IKeyArrayIndexProcedure,O,R,A> |
ClientIndexView.newWriteBuffer(IResultHandler<R,A> resultHandler,
IDuplicateRemover<O> duplicateRemover,
AbstractKeyArrayIndexProcedureConstructor<T> ctor) |
<T extends IKeyArrayIndexProcedure,O,R,A> |
IAsynchronousWriteBufferFactory.newWriteBuffer(IResultHandler<R,A> resultHandler,
IDuplicateRemover<O> duplicateRemover,
AbstractKeyArrayIndexProcedureConstructor<T> ctor)
Asynchronous write API (streaming writes).
|
void |
AbstractScaleOutClientIndexView.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator)
The procedure will be transparently broken down and executed against each
index partitions spanned by its keys.
|
void |
ClientIndexView.submit(int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator)
The procedure will be transparently broken down and executed against each
index partitions spanned by its keys.
|
protected void |
AbstractScaleOutClientIndexView2.submit(long ts,
int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator)
Variant uses the caller's timestamp.
|
protected abstract void |
AbstractScaleOutClientIndexView.submit(long ts,
int fromIndex,
int toIndex,
byte[][] keys,
byte[][] vals,
AbstractKeyArrayIndexProcedureConstructor ctor,
IResultHandler aggregator)
Variant uses the caller's timestamp.
|
Modifier and Type | Field and Description |
---|---|
protected AbstractKeyArrayIndexProcedureConstructor<T> |
IndexWriteTask.ctor |
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.