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 classDistributedCommandBatch<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> TDistributedExecutorService. 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.
-