Interface PartitioningFunction.Evaluator

  • Enclosing interface:
    PartitioningFunction

    public static interface PartitioningFunction.Evaluator
    Computes partition assignments for each row if input
    • Method Detail

      • getAssignment

        int getAssignment()
        Returns the partition id to which we should assign the current value
        Returns:
        the partion id