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

Packages that use IResultHandler

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.service.jini.master
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

void	ReadOnlyIndex.submit(byte[] fromKey, byte[] toKey, IIndexProcedure proc, IResultHandler handler) Overriden to ensure that procedure is applied against read-only view and not the DelegateIndex.
void	AbstractBTree.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
void	UnisolatedReadWriteIndex.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
void	ReadCommittedView.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	DelegateIndex.submit(byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler handler)
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	UnisolatedReadWriteIndex.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	IIndex.submit(int fromIndex, int toIndex, byte[][] keys, byte[][] vals, AbstractKeyArrayIndexProcedureConstructor ctor, IResultHandler resultHandler) Runs a procedure against an index.
void	DelegateIndex.submit(int fromIndex, int toIndex, byte[][] keys, byte[][] vals, AbstractKeyArrayIndexProcedureConstructor ctor, IResultHandler handler)

Uses of IResultHandler in com.bigdata.btree.proc

Subinterfaces of IResultHandler in com.bigdata.btree.proc

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

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

Uses of IResultHandler in com.bigdata.btree.view

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

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.service.jini.master

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

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

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

Uses of IResultHandler in com.bigdata.service.ndx

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

class

IdentityHandler Hands back the object visited for a single index partition.

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

<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> BlockingBuffer<KVO<O>[]>	AbstractScaleOutClientIndexView.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	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(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(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	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.
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, byte[] fromKey, byte[] toKey, IKeyRangeIndexProcedure proc, IResultHandler resultHandler) 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.
protected void	AbstractScaleOutClientIndexView2.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

protected IResultHandler<R,A>

IndexWriteTask.resultHandler

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

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)