Uses of Interface
com.pervasive.datarush.cal.MonitoredFuture
Packages that use MonitoredFuture
Package
Description
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 MonitoredFutureModifier and TypeMethodDescriptionprotected <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 MonitoredFutureModifier and TypeMethodDescription<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 MonitoredFutureModifier and TypeMethodDescriptionstatic <S> List<S>ExecutionUtil.getStatus(List<? extends MonitoredFuture<S>> futures) InvokesgetStatus()on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.