Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.graphs |
Provides classes and interfaces for the construction of executable
dataflow graphs.
|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
Modifier and Type | Field and Description |
---|---|
static NodeAllocationState.AssignmentState |
NodeAllocationState.AssignmentState.MASTER
The master assignment.
|
Modifier and Type | Method and Description |
---|---|
NodeAllocationState.AssignmentState |
NodeAllocationState.AssignmentState.assign(VirtualNodeID newID)
Create a new assignment, re-assigned to the new node
|
NodeAllocationState.AssignmentState |
PartitionInstanceInfo.getAssignment()
Returns the assignment
|
NodeAllocationState.AssignmentState |
DistributedCallableContext.getAssignmentState()
Returns the assignment state for this callable.
|
static NodeAllocationState.AssignmentState |
NodeAllocationState.AssignmentState.initial(NodeAllocationPlan.AssignmentPlan originalAssignment)
Creates an initial assignment state for the given assignment
|
Modifier and Type | Method and Description |
---|---|
List<NodeAllocationState.AssignmentState> |
NodeAllocationState.getAssignments()
Returns a list of assignments in this node allocation.
|
Map<String,List<NodeAllocationState.AssignmentState>> |
NodeAllocationState.getGroupedAssignments()
returns assignments, grouped by current physical node id
|
Constructor and Description |
---|
PartitionInstanceInfo(NodeAllocationState.AssignmentState assignment,
int partitionCount)
Construct with given count and ID.
|
Modifier and Type | Method and Description |
---|---|
LogicalStatistic.Builder |
LogicalStatistic.Builder.assignment(NodeAllocationState.AssignmentState assignment)
Sets the value for
LogicalStatistic.originalNodeID() and LogicalStatistic.nodeID()
based on the specified assignment. |
StatisticsRegistry |
StatisticsRegistry.forAssignment(NodeAllocationState.AssignmentState assignment)
Returns a statistics registry, re-scoped for the given assignment
|
Modifier and Type | Method and Description |
---|---|
List<NodeAllocationState.AssignmentState> |
StagedSourceOptions.getAssignments()
Returns the assignment that contains partition information, host information, etc
|
Constructor and Description |
---|
StagedSourceOptions(NodeAllocationState.AssignmentState assignment)
Specifies the partition information that controls which partition of the staged data is returned
by the
StagedSource |
StagedSourceOptions(NodeAllocationState.AssignmentState assignment,
LogicalPortOptions options)
Specifies the partition information that controls which partition of the staged data is returned
by the
StagedSource and specifies tuning settings. |
Constructor and Description |
---|
StagedSourceOptions(List<NodeAllocationState.AssignmentState> assignments)
Specifies the partition information that controls which partition of the staged data is returned
by the
StagedSource |
StagedSourceOptions(List<NodeAllocationState.AssignmentState> assignments,
LogicalPortOptions options)
Specifies the partition information that controls which partition of the staged data is returned
by the
StagedSource and specifies tuning settings. |
Copyright © 2020 Actian Corporation. All rights reserved.