org.apache.iceberg.spark

Class SparkDistributionAndOrderingUtil

java.lang.Object

org.apache.iceberg.spark.SparkDistributionAndOrderingUtil

public class SparkDistributionAndOrderingUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.sql.connector.distributions.Distribution	buildCopyOnWriteDistribution(Table table, org.apache.spark.sql.connector.write.RowLevelOperation.Command command, DistributionMode distributionMode)
static org.apache.spark.sql.connector.expressions.SortOrder[]	buildCopyOnWriteOrdering(Table table, org.apache.spark.sql.connector.write.RowLevelOperation.Command command, org.apache.spark.sql.connector.distributions.Distribution distribution)
static org.apache.spark.sql.connector.distributions.Distribution	buildPositionDeltaDistribution(Table table, org.apache.spark.sql.connector.write.RowLevelOperation.Command command, DistributionMode distributionMode)
static org.apache.spark.sql.connector.expressions.SortOrder[]	buildPositionDeltaOrdering(Table table, org.apache.spark.sql.connector.write.RowLevelOperation.Command command)
static org.apache.spark.sql.connector.distributions.Distribution	buildRequiredDistribution(Table table, DistributionMode distributionMode)
static org.apache.spark.sql.connector.expressions.SortOrder[]	buildRequiredOrdering(Table table, org.apache.spark.sql.connector.distributions.Distribution distribution)
static org.apache.spark.sql.connector.expressions.SortOrder[]	convert(SortOrder sortOrder)

Methods inherited from class java.lang.Object

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

Method Detail

buildRequiredDistribution

public static org.apache.spark.sql.connector.distributions.Distribution buildRequiredDistribution(Table table,
                                                                                                  DistributionMode distributionMode)

buildRequiredOrdering

public static org.apache.spark.sql.connector.expressions.SortOrder[] buildRequiredOrdering(Table table,
                                                                                           org.apache.spark.sql.connector.distributions.Distribution distribution)

buildCopyOnWriteDistribution

public static org.apache.spark.sql.connector.distributions.Distribution buildCopyOnWriteDistribution(Table table,
                                                                                                     org.apache.spark.sql.connector.write.RowLevelOperation.Command command,
                                                                                                     DistributionMode distributionMode)

buildCopyOnWriteOrdering

public static org.apache.spark.sql.connector.expressions.SortOrder[] buildCopyOnWriteOrdering(Table table,
                                                                                              org.apache.spark.sql.connector.write.RowLevelOperation.Command command,
                                                                                              org.apache.spark.sql.connector.distributions.Distribution distribution)

buildPositionDeltaDistribution

public static org.apache.spark.sql.connector.distributions.Distribution buildPositionDeltaDistribution(Table table,
                                                                                                       org.apache.spark.sql.connector.write.RowLevelOperation.Command command,
                                                                                                       DistributionMode distributionMode)

buildPositionDeltaOrdering

public static org.apache.spark.sql.connector.expressions.SortOrder[] buildPositionDeltaOrdering(Table table,
                                                                                                org.apache.spark.sql.connector.write.RowLevelOperation.Command command)

convert

public static org.apache.spark.sql.connector.expressions.SortOrder[] convert(SortOrder sortOrder)