Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.hbase |
Modifier and Type | Field and Description |
---|---|
static NodeAllocationPlan.AssignmentPlan |
NodeAllocationPlan.AssignmentPlan.MASTER
The master assignment.
|
Modifier and Type | Method and Description |
---|---|
static NodeAllocationPlan.AssignmentPlan |
NodeAllocationPlan.AssignmentPlan.forWorker(int partitionID,
VirtualNodeID nodeID)
Creates an assignment for a worker node
|
NodeAllocationPlan.AssignmentPlan |
NodeAllocationState.AssignmentState.getOriginalAssignment()
Returns the original assignment associated with this assignment
|
Modifier and Type | Method and Description |
---|---|
List<NodeAllocationPlan.AssignmentPlan> |
NodeAllocationPlan.getAssignments()
Returns a list of assignments in this node allocation.
|
Modifier and Type | Method and Description |
---|---|
Path |
StorageBucket.getMyStorageLocation(NodeAllocationPlan.AssignmentPlan partitionInfo) |
Path |
StorageManager.getMyStorageLocation(StorageBucketId bucketId,
NodeAllocationPlan.AssignmentPlan assignment)
Returns "my" storage location
|
static NodeAllocationState.AssignmentState |
NodeAllocationState.AssignmentState.initial(NodeAllocationPlan.AssignmentPlan originalAssignment)
Creates an initial assignment state for the given assignment
|
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.
|
Modifier and Type | Method and Description |
---|---|
static List<NodeAllocationPlan.AssignmentPlan> |
HBasePartitioningFunction.localizeAssignments(NodeAllocationPlan nodeAlloc,
List<String> serverNames,
boolean balance) |
Copyright © 2020 Actian Corporation. All rights reserved.