Uses of Interface
com.pervasive.datarush.cal.DistributedCallableBatch
-
Packages that use DistributedCallableBatch Package Description com.actian.dataflow.cal.yarn.server com.pervasive.datarush.cal Provides interfaces the define the "cluster abstraction layer". -
-
Uses of DistributedCallableBatch in com.actian.dataflow.cal.yarn.server
Methods in com.actian.dataflow.cal.yarn.server with parameters of type DistributedCallableBatch Modifier and Type Method Description protected <R> MonitoredFuture<R>
YarnClusterExecutor. createFuture(DistributedCallableBatch<R> batch, List<com.pervasive.datarush.cal.dr.CommandHandleInfo> handles, ExecutionOptions options)
protected <R> List<com.pervasive.datarush.cal.dr.CommandHandleInfo>
YarnClusterExecutor. submit(DistributedCallableBatch<R> command, List<com.pervasive.datarush.cal.dr.AbstractDRClusterExecutor.CommandServiceHelper> services)
-
Uses of DistributedCallableBatch in com.pervasive.datarush.cal
Classes in com.pervasive.datarush.cal that implement DistributedCallableBatch Modifier and Type Class Description class
DistributedCommandBatch<T>
Convenient base class forDistributedCallableBatch
's that do not support monitoring/partial results.Methods in com.pervasive.datarush.cal with parameters of type DistributedCallableBatch Modifier and Type Method Description <T> T
DistributedExecutorService. execute(DistributedCallableBatch<T> command, ExecutionOptions options)
Synchronously invokes the given callable.<T> MonitoredFuture<T>
DistributedExecutorService. submit(DistributedCallableBatch<T> callable, ExecutionOptions options)
Asynchronously invokes the given callable.
-