com.bigdata.btree.proc

Interface IAsyncResultHandler<R,A,O,X extends KVO<O>>

All Superinterfaces:

IResultHandler<R,A>

public interface IAsyncResultHandler<R,A,O,X extends KVO<O>>
extends IResultHandler<R,A>

Interface for chunk-at-a-time result processing for asynchronous index writes.

Note: For backward compatibility both #aggregate(KVO[], Object, Split) and IResultHandler.aggregate(Object, Split) will be invoked by the IndexPartitionWriteTask. In general, one of those methods should be a NOP.

Author:

Bryan Thompson

See Also:

KVO, IAsynchronousWriteBufferFactory

Method Summary

Methods

Modifier and Type	Method and Description
void	aggregateAsync(X[] chunk, R result, Split split) Method is invoked for each result and is responsible for combining the results in whatever manner is meaningful for the procedure.

Methods inherited from interface com.bigdata.btree.proc.IResultHandler

aggregate, getResult

Method Detail

aggregateAsync

void aggregateAsync(X[] chunk,
                  R result,
                  Split split)

Method is invoked for each result and is responsible for combining the results in whatever manner is meaningful for the procedure. Implementations of this method MUST be thread-safe since the procedure MAY be applied in parallel when it spans more than one index partition.

Parameters:

chunk - The KVO[] chunk for which the result was obtained.

result - The result from applying the procedure to a single index partition.

split - The Split that generated that result.