Module datarush.commons
Package com.pervasive.datarush.cal

Interface DistributedCallable<T>

Type Parameters:
T - the result type
All Superinterfaces:
Serializable
All Known Implementing Classes:
DistributedCommand
public interface DistributedCallable<T> extends Serializable
A distributed equivalent of a Callable. A DistributedCallable will be serialized to all nodes and will be be invoked once per VirtualNodeID. The callable will be run and its results will be merged together by calling merge(List).

  • Method Details

    • init

      MonitoredCallable<T> init(DistributedCallableContext ctx)
      Invoked once per VirtualNodeID. This method will be called on the remote side.
      Parameters:
      ctx - a remote context from which the callable can obtain its distributed identity, etc.
      Returns:
      the actual callable to invoke.

    • merge

      T merge(List<T> results)
      Invoked to perform a merge of results. Implementations should not make any assumptions about the order of the results (specifically, the order of the results will not necessarily be the same as partition ids). This also may be invoked multiple times to allow hierarchical merging.
      Parameters:
      results - the results
      Returns:
      the merged results.