Uses of Class
com.pervasive.datarush.cal.NodeAllocationPlan

Packages that use NodeAllocationPlan

Package	Description
com.pervasive.datarush.cal	Provides interfaces the define the "cluster abstraction layer".
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.

Uses of NodeAllocationPlan in com.pervasive.datarush.cal

Methods in com.pervasive.datarush.cal that return NodeAllocationPlan

Modifier and Type	Method	Description
static NodeAllocationPlan	NodeAllocationPlan.create(String jobMasterNodeId, ResourceAllocation masterResources, List<NodeAllocationPlan.AssignmentPlan> assignments, ResourceAllocation partitionResources, NodeInformationMapping nodeMapping)	Creates a new node allocation.
NodeAllocationPlan	DistributedCallableContext.ensureInitialNodeAllocation()	Returns the initial node allocation of the job.
NodeAllocationPlan	DistributedCallableContextBatch.ensureInitialNodeAllocation()	Returns the initial node allocation of the job.
NodeAllocationPlan	DistributedExecutorService.ensureInitialNodeAllocation()	Returns the original node allocation (that which was allocated before any nodes failed).
NodeAllocationPlan	StorageBucket.getNodeAllocationPlan()
NodeAllocationPlan	StorageManager.getNodeAllocationPlan()	Returns the node allocation plan associated with this storage manager
NodeAllocationPlan	NodeAllocationPlan.subPlan(int maxParallelism)	Returns the effective NodeAllocationPlan, given the specified value of max parallelism.

Methods in com.pervasive.datarush.cal with parameters of type NodeAllocationPlan

Modifier and Type	Method	Description
static NodeAllocationState	NodeAllocationState.initial(NodeAllocationPlan plan)	Creates the initial NodeAllocationState based on the plan.

Uses of NodeAllocationPlan in com.pervasive.datarush.hbase

Methods in com.pervasive.datarush.hbase with parameters of type NodeAllocationPlan

Modifier and Type	Method	Description
static List<NodeAllocationPlan.AssignmentPlan>	HBasePartitioningFunction.localizeAssignments(NodeAllocationPlan nodeAlloc, List<String> serverNames, boolean balance)

Uses of NodeAllocationPlan in com.pervasive.datarush.operators

Methods in com.pervasive.datarush.operators that return NodeAllocationPlan

Modifier and Type	Method	Description
NodeAllocationPlan	DeferredCompositionContext.getNodeAllocation()	Returns the node allocation for the graph to which this operator belongs.
NodeAllocationPlan	ExecutionContext.getNodeAllocation()	Returns the initial node allocation for the graph to which this operator belongs.

Uses of NodeAllocationPlan in com.pervasive.datarush.ports.record

Methods in com.pervasive.datarush.ports.record that return NodeAllocationPlan

Modifier and Type	Method	Description
NodeAllocationPlan	PartitioningFunctionContext.getNodeAllocation()	Returns the node allocation.