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

Class ClusterDistributionImpl

java.lang.Object

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

All Implemented Interfaces:

ClusteredDistribution, Distribution

public class ClusterDistributionImpl
extends java.lang.Object
implements ClusteredDistribution

Constructor Summary

Constructors

Constructor and Description
ClusterDistributionImpl(org.apache.spark.sql.connector.expressions.Expression[] clusterExprs)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.connector.expressions.Expression[]	clustering() Returns clustering expressions.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterDistributionImpl

public ClusterDistributionImpl(org.apache.spark.sql.connector.expressions.Expression[] clusterExprs)

Method Detail

clustering

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

Description copied from interface: ClusteredDistribution

Returns clustering expressions.

Specified by:

clustering in interface ClusteredDistribution