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	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	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	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

Modifier	Constructor	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 that implement DistributedExecutorService

Modifier and Type	Class	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	Description
DistributedExecutorService	IterativeExecutionContext.getExecutorService()	Public only as a matter of implementation; iterative operators should not invoke this method.