OrderedDistribution¶

OrderedDistribution is a Distribution for ordered data distribution requirement (of SortExec physical operator with global sort).

Creating Instance¶

OrderedDistribution takes the following to be created:

• SortOrder expressions (for ordering)

OrderedDistribution is created when:

• SortExec physical operator is requested for the requiredChildDistribution (with global sort)

Required Number of Partitions¶

requiredNumPartitions: Option[Int]

requiredNumPartitions is undefined (None).

requiredNumPartitions is part of the Distribution abstraction.

Creating Partitioning¶

createPartitioning(
  numPartitions: Int): Partitioning

createPartitioning creates a RangePartitioning expression.

createPartitioning is part of the Distribution abstraction.