Interface PartitioningFunctionContext


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

      • 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.