Uses of Interface
com.pervasive.datarush.cal.DistributedExecutorService

Packages that use DistributedExecutorService

Package	Description
com.actian.dataflow.cal.yarn.server
com.pervasive.datarush.cal	Provides interfaces the define the "cluster abstraction layer".
com.pervasive.datarush.cal.dr
com.pervasive.datarush.operators	Provides classes and interfaces for developing dataflow operators.

Uses of DistributedExecutorService in com.actian.dataflow.cal.yarn.server

Classes in com.actian.dataflow.cal.yarn.server that implement DistributedExecutorService

Modifier and Type	Class and Description
class	YarnClusterExecutor The executor responsible for starting Dataflow worker containers within YARN.

Uses of DistributedExecutorService in com.pervasive.datarush.cal

Subinterfaces of DistributedExecutorService in com.pervasive.datarush.cal

Modifier and Type	Interface and Description
interface	PseudoDistributedExecutorService Subinterface of DistributedExecutorService for running in pseudo-distributed mode.

Methods in com.pervasive.datarush.cal that return DistributedExecutorService

Modifier and Type	Method and Description
DistributedExecutorService	JobContext.getDistributedExecutor() Returns an executor service for performing work within the job.
DistributedExecutorService	StorageManagerSpecifier.getService() Returns the distributed executor service for the job.

Constructors in com.pervasive.datarush.cal with parameters of type DistributedExecutorService

Constructor and Description
StorageManagerSpecifier(JobSpecifier jobSpec, DistributedExecutorService service) Create a jobInfo

Uses of DistributedExecutorService in com.pervasive.datarush.cal.dr

Classes in com.pervasive.datarush.cal.dr with annotations of type with type parameters of type that implement declared as with annotations of type with type parameters of type with annotations of type with annotations of type with type parameters of type that return that return types with arguments of type with parameters of type with type arguments of type that throw with annotations of type with annotations of type with parameters of type with type arguments of type that throw DistributedExecutorService

Modifier and Type	Class and Description
class	com.pervasive.datarush.cal.dr.AbstractDRClusterExecutor

Uses of DistributedExecutorService in com.pervasive.datarush.operators

Methods in com.pervasive.datarush.operators that return DistributedExecutorService

Modifier and Type	Method and Description
DistributedExecutorService	IterativeExecutionContext.getExecutorService() Public only as a matter of implementation; iterative operators should not invoke this method.