Uses of Class
com.pervasive.datarush.cal.ExecutionOptions

Packages that use ExecutionOptions

Package	Description
com.actian.dataflow.cal.yarn.server
com.pervasive.datarush.cal	Provides interfaces the define the "cluster abstraction layer".

Uses of ExecutionOptions in com.actian.dataflow.cal.yarn.server

Methods in com.actian.dataflow.cal.yarn.server with parameters of type ExecutionOptions

Modifier and Type	Method	Description
protected <R> MonitoredFuture<R>	YarnClusterExecutor.createFuture(DistributedCallableBatch<R> batch, List<com.pervasive.datarush.cal.dr.CommandHandleInfo> handles, ExecutionOptions options)

Uses of ExecutionOptions in com.pervasive.datarush.cal

Fields in com.pervasive.datarush.cal declared as ExecutionOptions

Modifier and Type	Field	Description
static final ExecutionOptions	ExecutionOptions.MASTER	Execution options to run in the master.
static final ExecutionOptions	ExecutionOptions.WORKER	Default execution options: parallel/distributed, retry disabled

Methods in com.pervasive.datarush.cal that return ExecutionOptions

Modifier and Type	Method	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

Methods in com.pervasive.datarush.cal with parameters of type ExecutionOptions

Modifier and Type	Method	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.