Package org.apache.iceberg.spark

Class 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, 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)