Module datarush.commons

Package com.pervasive.datarush.cal

Interface DistributedCallableBatch<R>

Type Parameters:

R - the type of result.

All Superinterfaces:

ResultMerger<R>, Serializable

All Known Implementing Classes:

DistributedCommandBatch

public interface DistributedCallableBatch<R>
extends ResultMerger<R>

A distributed equivalent of a Callable. A DistributedCallableBatch will be invoked once per physicalNodeID. (This is different from DistributedCallable's which are invoked once per VirtualNodeID). In the case of pseudo-distributed execution, this will be invoked once. DistributedCallableBatch's are generally used to enable sharing of, say, large memory structures within the JVM, etc.

Method Summary

Modifier and Type	Method	Description
MonitoredCallable<R>	init(DistributedCallableContextBatch ctx)	Invoked once per physicalNodeID.

Methods inherited from interface com.pervasive.datarush.cal.ResultMerger

merge

Method Details

init

MonitoredCallable<R> init(DistributedCallableContextBatch ctx)

Invoked once per physicalNodeID. This method will be called on the remote side.

Parameters:

ctx - a remote context containing all of the contexts for this physicalNodeID.

Returns:

the actual callable to invoke.