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.
|
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.
|
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.
|
Class and Description |
---|
ClasspathSpecifier
The classpath specifies for a job.
|
JobSpecifier
Rollup of all parameters needed to launch a job
|
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 |
Class and Description |
---|
DistributedExecutorService
Distributed equivalent of the
ExecutorService concept. |
JobExecutorService
Client-side API for submitting units of work to the job master.
|
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 |
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.
|
Class and Description |
---|
NodeAllocationPlan
Represents the initial node allocation.
|
NodeAllocationPlan.AssignmentPlan
Assignment details for a particular node ID.
|
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.
|
Class and Description |
---|
NodeAllocationPlan
Represents the initial node allocation.
|
Copyright © 2021 Actian Corporation. All rights reserved.