Uses of Class
com.bigdata.btree.proc.AbstractKeyArrayIndexProcedureConstructor

Packages that use AbstractKeyArrayIndexProcedureConstructor

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.mdi	This package provides a metadata index and range partitioned indices managed by that metadata index.
com.bigdata.rdf.lexicon
com.bigdata.rdf.magic	This package includes an abstraction layer for declaring containers of relations, relations, the relationships between the relations (foreign keys), and the indices for a relation, including what goes into the key and the value for the index.
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.jini.master
com.bigdata.service.ndx
com.bigdata.service.ndx.pipeline

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.btree

Methods in com.bigdata.btree with parameters of type AbstractKeyArrayIndexProcedureConstructor

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) Overriden 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)
void	ReadCommittedView.submit(int fromIndex, int toIndex, byte[][] keys, byte[][] vals, AbstractKeyArrayIndexProcedureConstructor ctor, IResultHandler resultHandler)
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.

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.btree.proc

Subclasses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.btree.proc

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	BatchRemove.BatchRemoveConstructor Factory for BatchRemove procedures.

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.btree.view

Methods in com.bigdata.btree.view with parameters of type AbstractKeyArrayIndexProcedureConstructor

void	FusedView.submit(int fromIndex, int toIndex, byte[][] keys, byte[][] vals, AbstractKeyArrayIndexProcedureConstructor ctor, IResultHandler aggregator)

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.mdi

Methods in com.bigdata.mdi with parameters of type AbstractKeyArrayIndexProcedureConstructor

void	ReadOnlyMetadataIndexView.submit(int fromIndex, int toIndex, byte[][] keys, byte[][] vals, AbstractKeyArrayIndexProcedureConstructor ctor, IResultHandler aggregator) Overriden to ensure that procedure is applied against read-only view and not the DelegateIndex.

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.rdf.lexicon

Subclasses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.rdf.lexicon

static class	Id2TermWriteProc.Id2TermWriteProcConstructor
static class	Term2IdWriteProc.Term2IdWriteProcConstructor

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.rdf.magic

Subclasses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.rdf.magic

static class

MagicIndexWriteProc.IndexWriteProcConstructor

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.rdf.spo

Subclasses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.rdf.spo

static class	JustIndexWriteProc.WriteJustificationsProcConstructor
static class	SPOIndexWriteProc.IndexWriteProcConstructor

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.search

Subclasses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.search

static class

TextIndexWriteProc.IndexWriteProcConstructor

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.service.jini.master

Methods in com.bigdata.service.jini.master with parameters of type AbstractKeyArrayIndexProcedureConstructor

<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>

AggregatorTask.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor) Note: This ignores its arguments (it uses those specified to the ctor instead) and returns the proxy for the pre-existing write buffer.

Constructors in com.bigdata.service.jini.master with parameters of type AbstractKeyArrayIndexProcedureConstructor

AggregatorTask(String name, long timestamp, IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor)

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.service.ndx

Methods in com.bigdata.service.ndx with parameters of type AbstractKeyArrayIndexProcedureConstructor

<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>	IAsynchronousWriteBufferFactory.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor) Asynchronous write API (streaming writes).
<T extends IKeyArrayIndexProcedure,O,R,A> BlockingBuffer<KVO<O>[]>	AbstractScaleOutClientIndexView.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor)
<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>	ClientIndexView.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor)
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.
void	DataServiceIndex.submit(int fromIndex, int toIndex, byte[][] keys, byte[][] vals, AbstractKeyArrayIndexProcedureConstructor ctor, IResultHandler aggregator)
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.

Uses of AbstractKeyArrayIndexProcedureConstructor in com.bigdata.service.ndx.pipeline

Fields in com.bigdata.service.ndx.pipeline declared as AbstractKeyArrayIndexProcedureConstructor

protected AbstractKeyArrayIndexProcedureConstructor<T>

IndexWriteTask.ctor

Constructors in com.bigdata.service.ndx.pipeline with parameters of type AbstractKeyArrayIndexProcedureConstructor

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)