T
- the result typepublic interface DistributedCallable<T> extends Serializable
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)
.Modifier and Type | Method and Description |
---|---|
MonitoredCallable<T> |
init(DistributedCallableContext ctx)
Invoked once per
VirtualNodeID . |
T |
merge(List<T> results)
Invoked to perform a merge of results.
|
MonitoredCallable<T> init(DistributedCallableContext ctx)
VirtualNodeID
. This method will be called on the remote side.ctx
- a remote context from which the callable can obtain its distributed identity, etc.T merge(List<T> results)
results
- the resultsCopyright © 2021 Actian Corporation. All rights reserved.