Uses of Interface
com.pervasive.datarush.cal.MonitoredFuture

Packages that use MonitoredFuture

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

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

Methods in com.actian.dataflow.cal.yarn.server that return MonitoredFuture

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

Uses of MonitoredFuture in com.pervasive.datarush.cal

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

Modifier and Type	Method and Description
<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.
<T> MonitoredFuture<T>	JobExecutorService.submit(JobCallable<T> callable) Does the following: Starts the job master if not already started. Invokes the init method on the server side. Starts execution on the server side Returns a handle for monitoring execution
<T> MonitoredFuture<T>	DistributedExecutorService.submitMaster(MonitoredCallable<T> callable) Asynchronous, local, and non-parallel submission of the given callable.

Method parameters in com.pervasive.datarush.cal with type arguments of type MonitoredFuture

Modifier and Type	Method and Description
static <S> List<S>	ExecutionUtil.getStatus(List<? extends MonitoredFuture<S>> futures) Invokes getStatus() on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.