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 and 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 and Description
class	DistributedCommandBatch<T> Convenient base class for DistributedCallableBatch's that do not support monitoring/partial results.

Methods in com.pervasive.datarush.cal with parameters of type DistributedCallableBatch

Modifier and Type	Method and 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.