Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static NodeAllocationPlan |
NodeAllocationPlan.create(String jobMasterNodeId,
ResourceAllocation masterResources,
List<NodeAllocationPlan.AssignmentPlan> assignments,
ResourceAllocation partitionResources,
NodeInformationMapping nodeMapping)
Creates a new node allocation.
|
NodeAllocationPlan |
DistributedExecutorService.ensureInitialNodeAllocation()
Returns the original node allocation (that which was allocated before any nodes failed).
|
NodeAllocationPlan |
DistributedCallableContextBatch.ensureInitialNodeAllocation()
Returns the initial node allocation of the job.
|
NodeAllocationPlan |
DistributedCallableContext.ensureInitialNodeAllocation()
Returns the initial node allocation of the job.
|
NodeAllocationPlan |
StorageManager.getNodeAllocationPlan()
Returns the node allocation plan associated with this storage manager
|
NodeAllocationPlan |
StorageBucket.getNodeAllocationPlan() |
NodeAllocationPlan |
NodeAllocationPlan.subPlan(int maxParallelism)
Returns the effective NodeAllocationPlan, given the specified value of max parallelism.
|
Modifier and Type | Method and Description |
---|---|
static NodeAllocationState |
NodeAllocationState.initial(NodeAllocationPlan plan)
Creates the initial NodeAllocationState based on the plan.
|
Modifier and Type | Method and Description |
---|---|
NodeAllocationPlan |
AbstractDRClusterExecutor.ensureInitialNodeAllocation() |
NodeAllocationPlan |
NodeAllocationProvider.ensureInitialNodeAllocation(FileClient client,
JobSpecifier jobSpec) |
NodeAllocationPlan |
EagerNodeAllocationProvider.ensureInitialNodeAllocation(FileClient client,
JobSpecifier jobSpec) |
Constructor and Description |
---|
DRFSStorageManager(NodeAllocationPlan nodeAllocationPlan,
Path masterStorageLocation,
List<Path> workerStorageLocations) |
EagerNodeAllocationProvider(NodeAllocationPlan plan) |
Modifier and Type | Method and Description |
---|---|
NodeAllocationPlan |
DataRushCluster.allocateWorkers(GUID jobGUID) |
NodeAllocationPlan |
ClusterManagerImpl.allocateWorkers(GUID jobGUID) |
NodeAllocationPlan |
ClusterManager.allocateWorkers(GUID jobGUID)
Allocates the worker nodes for the given job
|
Modifier and Type | Method and Description |
---|---|
static List<NodeAllocationPlan.AssignmentPlan> |
HBasePartitioningFunction.localizeAssignments(NodeAllocationPlan nodeAlloc,
List<String> serverNames,
boolean balance) |
Modifier and Type | Method and Description |
---|---|
NodeAllocationPlan |
ExecutionContext.getNodeAllocation()
Returns the initial node allocation for the graph to which this operator belongs.
|
NodeAllocationPlan |
DeferredCompositionContext.getNodeAllocation()
Returns the node allocation for the graph to which this operator belongs.
|
Modifier and Type | Method and Description |
---|---|
NodeAllocationPlan |
PartitioningFunctionContext.getNodeAllocation()
Returns the node allocation.
|
Copyright © 2015 Actian Corporation. All Rights Reserved.