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