Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr |
Modifier and Type | Method and Description |
---|---|
protected <R> MonitoredFuture<R> |
YarnClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
Modifier and Type | Field and Description |
---|---|
static ExecutionOptions |
ExecutionOptions.MASTER
Execution options to run in the master.
|
static ExecutionOptions |
ExecutionOptions.WORKER
Default execution options: parallel/distributed, retry disabled
|
Modifier and Type | Method and Description |
---|---|
ExecutionOptions |
ExecutionOptions.maxParallelism(int maxParallelism)
Creates a new ExecutionOptions, with the maximum parallelism set to the specified
value
|
ExecutionOptions |
ExecutionOptions.maxRetries(int maxRetries)
Creates a new ExecutionOptions, with the maximum retries set to the specified
value
|
Modifier and Type | Method and Description |
---|---|
<T> T |
DistributedExecutorService.execute(DistributedCallable<T> command,
ExecutionOptions options)
Synchronously invokes the given callable.
|
<T> T |
DistributedExecutorService.execute(DistributedCallableBatch<T> command,
ExecutionOptions options)
Synchronously invokes the given callable.
|
<T> MonitoredFuture<T> |
DistributedExecutorService.submit(DistributedCallable<T> callable,
ExecutionOptions options)
Asynchronously invokes the given callable.
|
<T> MonitoredFuture<T> |
DistributedExecutorService.submit(DistributedCallableBatch<T> callable,
ExecutionOptions options)
Asynchronously invokes the given callable.
|
Modifier and Type | Method and Description |
---|---|
protected <R> MonitoredFuture<R> |
PseudoDistributedClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
protected <R> MonitoredFuture<R> |
DRClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
protected abstract <R> MonitoredFuture<R> |
AbstractDRClusterExecutor.createFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
ExecutionOptions options) |
<T> T |
AbstractDRClusterExecutor.execute(DistributedCallable<T> command,
ExecutionOptions options) |
<T> T |
AbstractDRClusterExecutor.execute(DistributedCallableBatch<T> command,
ExecutionOptions options) |
<R> MonitoredFuture<R> |
AbstractDRClusterExecutor.submit(DistributedCallable<R> command,
ExecutionOptions options) |
<R> MonitoredFuture<R> |
AbstractDRClusterExecutor.submit(DistributedCallableBatch<R> command,
ExecutionOptions options) |
Constructor and Description |
---|
FaultTolerantFuture(DistributedCallableBatch<R> batch,
List<CommandHandleInfo> handles,
DRClusterExecutor executor,
ExecutionOptions options) |
Copyright © 2016 Actian Corporation. All Rights Reserved.