org.apache.spark.sql.sources.v2.reader.partitioning

Class ClusteredDistribution

Object

org.apache.spark.sql.sources.v2.reader.partitioning.ClusteredDistribution

All Implemented Interfaces:

Distribution

@InterfaceStability.Evolving
public class ClusteredDistribution
extends Object
implements Distribution

A concrete implementation of Distribution. Represents a distribution where records that share the same values for the clusteredColumns will be produced by the same InputPartitionReader.

Field Summary

Fields

Modifier and Type	Field and Description
String[]	clusteredColumns The names of the clustered columns.

Constructor Summary

Constructors

Constructor and Description
ClusteredDistribution(String[] clusteredColumns)

Method Summary

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

clusteredColumns

public final String[] clusteredColumns

The names of the clustered columns. Note that they are order insensitive.

Constructor Detail

ClusteredDistribution

public ClusteredDistribution(String[] clusteredColumns)