Uses of Class
com.pervasive.datarush.cal.NodeAllocationState.AssignmentState
-
Packages that use NodeAllocationState.AssignmentState 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. -
-
Uses of NodeAllocationState.AssignmentState in com.pervasive.datarush.cal
Fields in com.pervasive.datarush.cal declared as NodeAllocationState.AssignmentState Modifier and Type Field Description static NodeAllocationState.AssignmentState
NodeAllocationState.AssignmentState. MASTER
The master assignment.Methods in com.pervasive.datarush.cal that return NodeAllocationState.AssignmentState Modifier and Type Method Description NodeAllocationState.AssignmentState
NodeAllocationState.AssignmentState. assign(VirtualNodeID newID)
Create a new assignment, re-assigned to the new nodeNodeAllocationState.AssignmentState
PartitionInstanceInfo. getAssignment()
Returns the assignmentNodeAllocationState.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 assignmentMethods in com.pervasive.datarush.cal that return types with arguments of type NodeAllocationState.AssignmentState Modifier and Type Method 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 idConstructors in com.pervasive.datarush.cal with parameters of type NodeAllocationState.AssignmentState Constructor Description PartitionInstanceInfo(NodeAllocationState.AssignmentState assignment, int partitionCount)
Construct with given count and ID. -
Uses of NodeAllocationState.AssignmentState in com.pervasive.datarush.graphs
Methods in com.pervasive.datarush.graphs with parameters of type NodeAllocationState.AssignmentState Modifier and Type Method Description LogicalStatistic.Builder
LogicalStatistic.Builder. assignment(NodeAllocationState.AssignmentState assignment)
Sets the value forLogicalStatistic.originalNodeID()
andLogicalStatistic.nodeID()
based on the specified assignment.StatisticsRegistry
StatisticsRegistry. forAssignment(NodeAllocationState.AssignmentState assignment)
Returns a statistics registry, re-scoped for the given assignment -
Uses of NodeAllocationState.AssignmentState in com.pervasive.datarush.operators
Methods in com.pervasive.datarush.operators that return types with arguments of type NodeAllocationState.AssignmentState Modifier and Type Method Description List<NodeAllocationState.AssignmentState>
StagedSourceOptions. getAssignments()
Returns the assignment that contains partition information, host information, etcConstructors in com.pervasive.datarush.operators with parameters of type NodeAllocationState.AssignmentState Constructor Description StagedSourceOptions(NodeAllocationState.AssignmentState assignment)
Specifies the partition information that controls which partition of the staged data is returned by theStagedSource
StagedSourceOptions(NodeAllocationState.AssignmentState assignment, LogicalPortOptions options)
Specifies the partition information that controls which partition of the staged data is returned by theStagedSource
and specifies tuning settings.Constructor parameters in com.pervasive.datarush.operators with type arguments of type NodeAllocationState.AssignmentState Constructor Description StagedSourceOptions(List<NodeAllocationState.AssignmentState> assignments)
Specifies the partition information that controls which partition of the staged data is returned by theStagedSource
StagedSourceOptions(List<NodeAllocationState.AssignmentState> assignments, LogicalPortOptions options)
Specifies the partition information that controls which partition of the staged data is returned by theStagedSource
and specifies tuning settings.
-