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.

Version:

$Id: IAsyncResultHandler.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

See Also:

KVO, IAsynchronousWriteBufferFactory

TODO:

This interface was hacked in after the fact to support asynchronous writes.

Method Summary

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.