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)