Class SparkDistributionAndOrderingUtil


  • public class SparkDistributionAndOrderingUtil
    extends java.lang.Object
    • 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)
      • buildCopyOnWriteOrdering

        public static org.apache.spark.sql.connector.expressions.SortOrder[] buildCopyOnWriteOrdering​(Table table,
                                                                                                      RowLevelOperation.Command command,
                                                                                                      org.apache.spark.sql.connector.distributions.Distribution distribution)
      • 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)