Uses of Interface
com.pervasive.datarush.cal.DistributedCallableBatch
Packages that use DistributedCallableBatch
Package
Description
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 DistributedCallableBatchModifier and TypeMethodDescriptionprotected <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 DistributedCallableBatchModifier and TypeClassDescriptionclassConvenient base class forDistributedCallableBatch's that do not support monitoring/partial results.Methods in com.pervasive.datarush.cal with parameters of type DistributedCallableBatchModifier and TypeMethodDescription<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.