org.apache.spark.sql.connector.distributions

Interface ClusteredDistribution

All Superinterfaces:

Distribution

@Experimental
public interface ClusteredDistribution
extends Distribution

A distribution where tuples that share the same values for clustering expressions are co-located in the same partition.

Since:

3.2.0

Method Summary

Modifier and Type	Method and Description
Expression[]	clustering() Returns clustering expressions.

Method Detail

clustering

Expression[] clustering()

Returns clustering expressions.