Skip to content

Distributions — Data Distribution Requirement

Distribution is an abstraction of data distribution requirements for EnsureRequirements physical optimization.

sealed abstract class

Distribution is a Scala sealed abstract class which means that all possible implementations (Distributions) are all in the same compilation unit (file).

Contract

Creating Partitioning

createPartitioning(
  numPartitions: Int): Partitioning

Creates the Partitioning with the given number of partitions

Used when EnsureRequirements physical optimization is executed

Required Number of Partitions

requiredNumPartitions: Option[Int]

Required number of partitions of the distribution

Used when EnsureRequirements physical optimization is executed

Implementations


Last update: 2020-08-24