Interface PartitioningFunction.Evaluator

Enclosing interface:
PartitioningFunction

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

    Modifier and Type
    Method
    Description
    int
    Returns the partition id to which we should assign the current value
  • Method Details

    • getAssignment

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