org.apache.spark.sql.connector.iceberg.distributions

Interface ClusteredDistribution

All Superinterfaces:

Distribution

All Known Implementing Classes:

ClusterDistributionImpl

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
org.apache.spark.sql.connector.expressions.Expression[]	clustering() Returns clustering expressions.

Method Detail

clustering

org.apache.spark.sql.connector.expressions.Expression[] clustering()

Returns clustering expressions.