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 Detail

      • clustering

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