Module datarush.library
Interface PartitioningFunctionContext
-
public interface PartitioningFunctionContextContextual information forPartitioningFunction's. Clients should not implement this interface.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RecordValuedgetInput()Returns the data to be partitionedNodeAllocationPlangetNodeAllocation()Returns the node allocation.intgetTargetPartitionCount()Returns the number of target partitions.
-
-
-
Method Detail
-
getNodeAllocation
NodeAllocationPlan getNodeAllocation()
Returns the node allocation. For use by partitioners that require host information when making partition assignment decisions. Note that this is the full node allocation. Partitioners may choose to callNodeAllocationPlan.subPlan(int), passing ingetTargetPartitionCount()- Returns:
- the node allocation
-
getInput
RecordValued getInput()
Returns the data to be partitioned- Returns:
- the data to be partitioned
-
getTargetPartitionCount
int getTargetPartitionCount()
Returns the number of target partitions.- Returns:
- the number of target partitions.
-
-