public interface DistributedExecutorService
ExecutorService
concept. To obtain a handle to
an executor service, use JobExecutorServiceFactory
.Modifier and Type | Method and Description |
---|---|
NodeAllocationPlan |
ensureInitialNodeAllocation()
Returns the original node allocation (that which was allocated before any nodes failed).
|
<T> T |
execute(DistributedCallable<T> command,
ExecutionOptions options)
Synchronously invokes the given callable.
|
<T> T |
execute(DistributedCallableBatch<T> command,
ExecutionOptions options)
Synchronously invokes the given callable.
|
DistributedCallableContext |
getMasterContext()
Returns the job master context.
|
<T> MonitoredFuture<T> |
submit(DistributedCallable<T> callable,
ExecutionOptions options)
Asynchronously invokes the given callable.
|
<T> MonitoredFuture<T> |
submit(DistributedCallableBatch<T> callable,
ExecutionOptions options)
Asynchronously invokes the given callable.
|
<T> MonitoredFuture<T> |
submitMaster(MonitoredCallable<T> callable)
Asynchronous, local, and non-parallel submission of the given callable.
|
NodeAllocationPlan ensureInitialNodeAllocation()
DistributedCallableContext getMasterContext()
ExecutionOptions.MASTER
.<T> MonitoredFuture<T> submitMaster(MonitoredCallable<T> callable)
T
- the result typecallable
- the callable to run<T> MonitoredFuture<T> submit(DistributedCallable<T> callable, ExecutionOptions options)
VirtualNodeID
and
results/status/exceptions merged together.
NOTE: Implementations are advised to implement this in terms of DistributedCallableBatch. This has the
advantage of minimizing communication overhead. It also has the advantage of deserializing
the command once-per-JVM which provides command implementations a convenient way of sharing (larger) objects
within the same JVM. (DR relies on the assumption for certain performance optimizations).T
- the type of results/statuscallable
- the callable to executeoptions
- miscellaneous execution options<T> MonitoredFuture<T> submit(DistributedCallableBatch<T> callable, ExecutionOptions options)
physicalNodeID
and
results/status/exceptions merged together.
T
- the type of results/statuscallable
- the callable to executeoptions
- miscellaneous execution options<T> T execute(DistributedCallable<T> command, ExecutionOptions options) throws DistributedExecutionException, InterruptedException
VirtualNodeID
and
results/status/exceptions merged together.
NOTE: Implementations are advised to implement this in terms of DistributedCallableBatch. This has the
advantage of minimizing communication overhead. It also has the advantage of deserializing
the command once-per-JVM which provides command implementations a convenient way of sharing (larger) objects
within the same JVM. (DR relies on the assumption for certain performance optimizations).T
- the type of results/statuscommand
- the command to executeoptions
- miscellaneous execution optionsDistributedExecutionException
- if an exception occurs during executionInterruptedException
- if interrupted while waiting for results<T> T execute(DistributedCallableBatch<T> command, ExecutionOptions options) throws DistributedExecutionException, InterruptedException
physicalNodeID
and
results/status/exceptions merged together.
T
- the type of results/statuscommand
- the command to executeoptions
- miscellaneous execution optionsDistributedExecutionException
- if an exception occurs during executionInterruptedException
- if interrupted while waiting for resultsCopyright © 2021 Actian Corporation. All rights reserved.