Uses of Class
com.pervasive.datarush.cal.ExecutionOptions
Packages that use ExecutionOptions
Package
Description
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 ExecutionOptionsModifier and TypeMethodDescriptionprotected <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 ExecutionOptionsModifier and TypeFieldDescriptionstatic final ExecutionOptionsExecutionOptions.MASTERExecution options to run in the master.static final ExecutionOptionsExecutionOptions.WORKERDefault execution options: parallel/distributed, retry disabledMethods in com.pervasive.datarush.cal that return ExecutionOptionsModifier and TypeMethodDescriptionExecutionOptions.maxParallelism(int maxParallelism) Creates a new ExecutionOptions, with the maximum parallelism set to the specified valueExecutionOptions.maxRetries(int maxRetries) Creates a new ExecutionOptions, with the maximum retries set to the specified valueMethods in com.pervasive.datarush.cal with parameters of type ExecutionOptionsModifier and TypeMethodDescription<T> TDistributedExecutorService.execute(DistributedCallable<T> command, ExecutionOptions options) Synchronously invokes the given callable.<T> TDistributedExecutorService.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.