Package org.apache.iceberg.spark
Class SparkDistributionAndOrderingUtil
- java.lang.Object
-
- org.apache.iceberg.spark.SparkDistributionAndOrderingUtil
-
public class SparkDistributionAndOrderingUtil extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static org.apache.spark.sql.connector.distributions.Distribution
buildCopyOnWriteDistribution(Table table, RowLevelOperation.Command command, DistributionMode distributionMode)
static org.apache.spark.sql.connector.expressions.SortOrder[]
buildCopyOnWriteOrdering(Table table, RowLevelOperation.Command command, org.apache.spark.sql.connector.distributions.Distribution distribution)
static org.apache.spark.sql.connector.distributions.Distribution
buildPositionDeltaDistribution(Table table, RowLevelOperation.Command command, DistributionMode distributionMode)
static org.apache.spark.sql.connector.expressions.SortOrder[]
buildPositionDeltaOrdering(Table table, RowLevelOperation.Command command, org.apache.spark.sql.connector.distributions.Distribution distribution)
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)
-
-
-
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, RowLevelOperation.Command command, DistributionMode distributionMode)
-
buildCopyOnWriteOrdering
public static org.apache.spark.sql.connector.expressions.SortOrder[] buildCopyOnWriteOrdering(Table table, RowLevelOperation.Command command, org.apache.spark.sql.connector.distributions.Distribution distribution)
-
buildPositionDeltaDistribution
public static org.apache.spark.sql.connector.distributions.Distribution buildPositionDeltaDistribution(Table table, RowLevelOperation.Command command, DistributionMode distributionMode)
-
buildPositionDeltaOrdering
public static org.apache.spark.sql.connector.expressions.SortOrder[] buildPositionDeltaOrdering(Table table, RowLevelOperation.Command command, org.apache.spark.sql.connector.distributions.Distribution distribution)
-
convert
public static org.apache.spark.sql.connector.expressions.SortOrder[] convert(SortOrder sortOrder)
-
-