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.monitoring
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	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	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	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	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	Description
DistributedExecutorService	Distributed equivalent of the ExecutorService concept.
JobExecutorService	Client-side API for submitting units of work to the job master.

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

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

Class	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	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	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	Description
NodeAllocationPlan	Represents the initial node allocation.