Module datarush.library
Package com.pervasive.datarush.ports.record

Interface PartitioningFunctionContext

public interface PartitioningFunctionContext
Contextual information for PartitioningFunction's. Clients should not implement this interface.

  • Method Details

    • 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 call NodeAllocationPlan.subPlan(int), passing in getTargetPartitionCount()
      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.