Uses of Interface
com.bigdata.btree.proc.IResultHandler

Packages that use IResultHandler

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

Uses of IResultHandler in com.bigdata.btree

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

Modifier and Type	Method and Description
void	DelegateIndex.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
void	IIndex.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler) The procedure will be transparently applied against each index partition spanned by the given key range.
void	ReadCommittedView.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
void	UnisolatedReadWriteIndex.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
void	AbstractBTree.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
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)

Uses of IResultHandler in com.bigdata.btree.proc

Subinterfaces of IResultHandler in com.bigdata.btree.proc

Modifier and Type	Interface and Description
interface	IAsyncResultHandler<R,A,O,X extends KVO<O>> Interface for chunk-at-a-time result processing for asynchronous index writes.

Classes in com.bigdata.btree.proc that implement IResultHandler

Modifier and Type	Class and Description
static class	AbstractKeyArrayIndexProcedure.ResultBitBufferCounter Counts the #of true bits in the AbstractKeyArrayIndexProcedure.ResultBitBuffer(s).
static class	AbstractKeyArrayIndexProcedure.ResultBitBufferHandler Knows how to aggregate AbstractKeyArrayIndexProcedure.ResultBitBuffer objects.
static class	AbstractKeyArrayIndexProcedure.ResultBufferHandler Knows how to aggregate AbstractKeyArrayIndexProcedure.ResultBuffer objects.
class	AbstractLocalSplitResultAggregator<R> Aggregator base class collects the individual results in an internal ordered map and assembles the final result when it is requested from the individual results.
class	BooleanORAggregator Combines together boolean values using a logical OR.
class	IntegerAggregator Aggregates the value of an Integer result, making the sum available as a Long integer (to help prevent overflow).
class	ListResultAggregator<R,A extends List<R>> Aggregates result into a list of results.
class	LongAggregator Aggregates the value of an Long result.

Methods in com.bigdata.btree.proc that return IResultHandler

Modifier and Type	Method and Description
protected IResultHandler<AbstractKeyArrayIndexProcedure.ResultBitBuffer,AbstractKeyArrayIndexProcedure.ResultBitBuffer>	BatchContains.newAggregator()
protected IResultHandler<AbstractKeyArrayIndexProcedure.ResultBuffer,AbstractKeyArrayIndexProcedure.ResultBuffer>	BatchInsert.newAggregator()
protected abstract IResultHandler<T,T>	AbstractKeyArrayIndexProcedure.newAggregator() Return an IResultHandler that will be used to combine the results if the index procedure is parallelized against a local index (including a scale-out shard).
protected IResultHandler<AbstractKeyArrayIndexProcedure.ResultBuffer,AbstractKeyArrayIndexProcedure.ResultBuffer>	BatchLookup.newAggregator()
protected IResultHandler<Object,Object>	BatchRemove.newAggregator() Returns an appropriate aggregator depending on BatchRemove.returnWhat.
protected IResultHandler<AbstractKeyArrayIndexProcedure.ResultBuffer,AbstractKeyArrayIndexProcedure.ResultBuffer>	BatchPutIfAbsent.newAggregator()

Uses of IResultHandler in com.bigdata.btree.view

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

Modifier and Type	Method and Description
void	FusedView.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
void	FusedView.submit(int fromIndex, int toIndex, byte[][] keys, byte[][] vals, AbstractKeyArrayIndexProcedureConstructor ctor, IResultHandler aggregator)

Uses of IResultHandler in com.bigdata.rdf.lexicon

Methods in com.bigdata.rdf.lexicon that return IResultHandler

Modifier and Type	Method and Description
protected IResultHandler<BlobsWriteProc.Result,BlobsWriteProc.Result>	BlobsWriteProc.newAggregator() Split-wise aggregation followed by combining the results across those splits in order to return an aggregated result whose counters[] is 1:1 with the original keys[][].
protected IResultHandler<Term2IdWriteProc.Result,Term2IdWriteProc.Result>	Term2IdWriteProc.newAggregator() Split-wise aggregation followed by combining the results across those splits in order to return an aggregated result whose iv[] is 1:1 with the original keys[][].
protected IResultHandler<Void,Void>	Id2TermWriteProc.newAggregator() Nothing is returned, so nothing to aggregate, but uses a NopAggregator to preserve striping against a local index.

Uses of IResultHandler in com.bigdata.rdf.spo

Methods in com.bigdata.rdf.spo that return IResultHandler

Modifier and Type	Method and Description
protected IResultHandler<Object,Object>	SPOIndexWriteProc.newAggregator()
protected IResultHandler<Long,Long>	JustIndexWriteProc.newAggregator() Uses LongAggregator to combine the mutation counts.

Uses of IResultHandler in com.bigdata.search

Methods in com.bigdata.search that return IResultHandler

Modifier and Type	Method and Description
protected IResultHandler<Long,Long>	TextIndexWriteProc.newAggregator() Uses LongAggregator to combine the mutation counts.

Uses of IResultHandler in com.bigdata.service.ndx

Classes in com.bigdata.service.ndx that implement IResultHandler

Modifier and Type	Class and Description
class	IdentityHandler<T> Hands back the object visited for a single index partition.
class	NopAggregator<R,A> NOP aggregator does nothing and returns null.

Fields in com.bigdata.service.ndx declared as IResultHandler

Modifier and Type	Field and Description
static IResultHandler	NopAggregator.INSTANCE

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

Modifier and Type	Method and Description
<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)
<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).
void	AbstractScaleOutClientIndexView.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler resultHandler) Maps an IIndexProcedure across a key range by breaking it down into one task per index partition spanned by that key range.
void	ClientIndexView.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler resultHandler) Maps an IIndexProcedure across a key range by breaking it down into one task per index partition spanned by that key range.
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, byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler resultHandler) Variant uses the caller's timestamp.
protected abstract void	AbstractScaleOutClientIndexView.submit(long ts, byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler resultHandler) Variant uses the caller's timestamp.
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 IResultHandler in com.bigdata.service.ndx.pipeline

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

Modifier and Type	Field and Description
protected IResultHandler<R,A>	IndexWriteTask.resultHandler

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

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)