@Evolving public class KeyGroupedPartitioning extends Object implements Partitioning
Note: Data source implementations should make sure for a single partition, all of its rows
must be evaluated to the same partition value after being applied by
keys expressions. Different partitions can share the same
partition value: Spark will group these into a single logical partition during planning phase.
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns the partition transform expressions for this partitioning.
Returns the number of partitions that the data is split across.
public KeyGroupedPartitioning(Expression keys, int numPartitions)
public Expression keys()