Uses of Package
com.pervasive.datarush.cal

Packages that use com.pervasive.datarush.cal

Package	Description
com.actian.dataflow.cal.yarn.client
com.actian.dataflow.cal.yarn.server
com.actian.dataflow.cal.yarn.shared
com.pervasive.datarush.cal	Provides interfaces the define the "cluster abstraction layer".
com.pervasive.datarush.cal.dr
com.pervasive.datarush.cal.internal
com.pervasive.datarush.cal.monitoring
com.pervasive.datarush.cluster	Provides classes and interfaces related to the management of clustered dataflow engines.
com.pervasive.datarush.graphs	Provides classes and interfaces for the construction of executable dataflow graphs.
com.pervasive.datarush.hbase
com.pervasive.datarush.operators	Provides classes and interfaces for developing dataflow operators.
com.pervasive.datarush.ports.record	Provides implementations of port objects related to the flow of record sets between operators.

Classes in com.pervasive.datarush.cal used by com.actian.dataflow.cal.yarn.client

Class and Description
ClusterProvider Extension point to register cluster providers for new schemes.
ClusterSpecifier A "URL-like" entity that identifies a cluster.
JobExecutorService Client-side API for submitting units of work to the job master.
JobHistoryService
JobSpecifier Rollup of all parameters needed to launch a job
StorageManager A manager of intermediate storage.

Classes in com.pervasive.datarush.cal used by com.actian.dataflow.cal.yarn.server

Class and Description
DistributedCallableBatch A distributed equivalent of a Callable.
DistributedExecutorService Distributed equivalent of the ExecutorService concept.
ExecutionOptions Miscellaneous execution options.
JobServerInformation
JobSpecifier Rollup of all parameters needed to launch a job
MonitoredFuture Extension of Future that allows the client to query for the partial status.
ResourceAllocation Describes the resource allocation for a job server process.

Classes in com.pervasive.datarush.cal used by com.actian.dataflow.cal.yarn.shared

Class and Description
ClasspathSpecifier The classpath specifies for a job.
JobSpecifier Rollup of all parameters needed to launch a job

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.cal

Class and Description
AttributeScope A session qualifier to provide uniqueness of session attributes.
CacheScopeSpecifier Enumeration of possible caches for Element's.
ClasspathSpecifier The classpath specifies for a job.
ClasspathSpecifier.Element An element of a classpath.
ClusterProvider Extension point to register cluster providers for new schemes.
ClusterProviderManager Facade to lookup providers from META-INF/services.
ClusterSpecifier A "URL-like" entity that identifies a cluster.
DistributedCallable A distributed equivalent of a Callable.
DistributedCallableBatch A distributed equivalent of a Callable.
DistributedCallableContext Distributed context passed to DistributedCallable.init(DistributedCallableContext).
DistributedCallableContextBatch Distributed context passed to DistributedCallableBatch.init(DistributedCallableContextBatch).
DistributedExecutionException An ExecutionException in a distributed context.
DistributedExecutorService Distributed equivalent of the ExecutorService concept.
ExecutionOptions Miscellaneous execution options.
JobCallable
JobContext Context available to job.
JobExecutorService Client-side API for submitting units of work to the job master.
JobHistoryService
JobInformation Basic job information that contains the job name, id, and the user that submitted the job.
JobLogInfo.LogInfo
JobSpecifier Rollup of all parameters needed to launch a job
JobStatus
MonitoredCallable Extension of Callable that provides a way to get its current status prior to execution completion.
MonitoredFuture Extension of Future that allows the client to query for the partial status.
NodeAllocationPlan Represents the initial node allocation.
NodeAllocationPlan.AssignmentPlan Assignment details for a particular node ID.
NodeAllocationState Reflects the current state of node allocation, which takes into account failed nodes.
NodeAllocationState.AssignmentState Assignment details for a particular node ID.
NodeInformation Contains node and host information
NodeInformationMapping Contains host information associated with the nodes in the cluster that the current job is running on.
OSGIOptions Extra options for an OSGI classpath element
PartitionInstanceInfo Information pertaining to an instance of a partitioning operation.
ResourceAllocation Describes the resource allocation for a job server process.
ResourceSpecifier Resource specifier for the resources needed by a job.
ResultMerger
SessionAttribute Provides a key for a session attribute and, optionally, an initial value
StorageBucket Convenient pairing of StorageBucketId and it's associated StorageManager.
StorageBucketId A storage bucket represents one unit of work to be exchanged by nodes in the cluster.
StorageManager A manager of intermediate storage.
StorageManagerSpecifier Rollup of the various parameters needed to create a StorageManager.
StoragePlanner An allocator of StorageBucketId's.
VirtualNodeID Identifies a "virtual node" in a cluster.
VirtualNodeType Enumeration of non-parallel locations
WorkerRole

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.cal.dr

Class and Description
ClusterProvider Extension point to register cluster providers for new schemes.
ClusterSpecifier A "URL-like" entity that identifies a cluster.
DistributedCallable A distributed equivalent of a Callable.
DistributedCallableBatch A distributed equivalent of a Callable.
DistributedCallableContext Distributed context passed to DistributedCallable.init(DistributedCallableContext).
DistributedCallableContextBatch Distributed context passed to DistributedCallableBatch.init(DistributedCallableContextBatch).
DistributedExecutionException An ExecutionException in a distributed context.
DistributedExecutorService Distributed equivalent of the ExecutorService concept.
ExecutionOptions Miscellaneous execution options.
JobCallable
JobExecutorService Client-side API for submitting units of work to the job master.
JobHistoryService
JobInformation Basic job information that contains the job name, id, and the user that submitted the job.
JobSpecifier Rollup of all parameters needed to launch a job
JobStatus
MonitoredCallable Extension of Callable that provides a way to get its current status prior to execution completion.
MonitoredFuture Extension of Future that allows the client to query for the partial status.
NodeAllocationPlan Represents the initial node allocation.
NodeAllocationState.AssignmentState Assignment details for a particular node ID.
PseudoDistributedExecutorService Subinterface of DistributedExecutorService for running in pseudo-distributed mode.
ResourceAllocation Describes the resource allocation for a job server process.
ResultMerger
StorageManager A manager of intermediate storage.
StorageManagerProvider Extension point to register a new StorageManager type.
StorageManagerSpecifier Rollup of the various parameters needed to create a StorageManager.

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.cal.internal

Class and Description
StorageManager A manager of intermediate storage.

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.cal.monitoring

Class and Description
JobInformation Basic job information that contains the job name, id, and the user that submitted the job.
JobServerInformation
JobStatus
ResourceAllocation Describes the resource allocation for a job server process.
WorkerRole

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.cluster

Class and Description
CacheScopeSpecifier Enumeration of possible caches for Element's.
ClasspathSpecifier The classpath specifies for a job.
ClasspathSpecifier.Element An element of a classpath.
ClusterSpecifier A "URL-like" entity that identifies a cluster.
DistributedCallableBatch A distributed equivalent of a Callable.
DistributedCallableContext Distributed context passed to DistributedCallable.init(DistributedCallableContext).
DistributedCallableContextBatch Distributed context passed to DistributedCallableBatch.init(DistributedCallableContextBatch).
JobCallable
JobHistoryService
JobInformation Basic job information that contains the job name, id, and the user that submitted the job.
JobLogInfo.LogInfo
JobServerInformation
JobSpecifier Rollup of all parameters needed to launch a job
JobStatus
NodeAllocationPlan Represents the initial node allocation.
NodeAllocationState.AssignmentState Assignment details for a particular node ID.
OSGIOptions Extra options for an OSGI classpath element
ResourceAllocation Describes the resource allocation for a job server process.
ResourceSpecifier Resource specifier for the resources needed by a job.
StorageManagerSpecifier Rollup of the various parameters needed to create a StorageManager.
WorkerRole

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.graphs

Class and Description
ClasspathSpecifier The classpath specifies for a job.
ClusterSpecifier A "URL-like" entity that identifies a cluster.
JobStatus
NodeAllocationState.AssignmentState Assignment details for a particular node ID.
VirtualNodeID Identifies a "virtual node" in a cluster.

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.hbase

Class and Description
NodeAllocationPlan Represents the initial node allocation.
NodeAllocationPlan.AssignmentPlan Assignment details for a particular node ID.

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.operators

Class and Description
DistributedCallableContext Distributed context passed to DistributedCallable.init(DistributedCallableContext).
DistributedExecutorService Distributed equivalent of the ExecutorService concept.
NodeAllocationPlan Represents the initial node allocation.
NodeAllocationState.AssignmentState Assignment details for a particular node ID.
PartitionInstanceInfo Information pertaining to an instance of a partitioning operation.

Classes in com.pervasive.datarush.cal used by com.pervasive.datarush.ports.record

Class and Description
NodeAllocationPlan Represents the initial node allocation.