Module datarush.library
Interface PartitioningFunctionContext
-
public interface PartitioningFunctionContext
Contextual information forPartitioningFunction
's. Clients should not implement this interface.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RecordValued
getInput()
Returns the data to be partitionedNodeAllocationPlan
getNodeAllocation()
Returns the node allocation.int
getTargetPartitionCount()
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.
-
-