@InterfaceStability.Evolving public class ClusteredDistribution extends Object implements Distribution
Distribution
. Represents a distribution where records that
share the same values for the clusteredColumns
will be produced by the same
InputPartitionReader
.Modifier and Type | Field and Description |
---|---|
String[] |
clusteredColumns
The names of the clustered columns.
|
Constructor and Description |
---|
ClusteredDistribution(String[] clusteredColumns) |