From 11403e56a1170295b5df49dffc88110020039e21 Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Fri, 5 Dec 2025 17:23:55 -0800 Subject: [PATCH] [SPARK-54622][SQL] Promote `RequiresDistributionAndOrdering` and its required interfaces to `Evolving` --- .../sql/connector/distributions/ClusteredDistribution.java | 4 ++-- .../spark/sql/connector/distributions/Distribution.java | 4 ++-- .../spark/sql/connector/distributions/Distributions.java | 4 ++-- .../sql/connector/distributions/OrderedDistribution.java | 4 ++-- .../sql/connector/distributions/UnspecifiedDistribution.java | 4 ++-- .../apache/spark/sql/connector/expressions/NullOrdering.java | 4 ++-- .../apache/spark/sql/connector/expressions/SortDirection.java | 4 ++-- .../org/apache/spark/sql/connector/expressions/SortOrder.java | 4 ++-- .../sql/connector/write/RequiresDistributionAndOrdering.java | 4 ++-- 9 files changed, 18 insertions(+), 18 deletions(-) diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/ClusteredDistribution.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/ClusteredDistribution.java index dcc3d191461ce..0fa77d259e9d7 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/ClusteredDistribution.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/ClusteredDistribution.java @@ -17,7 +17,7 @@ package org.apache.spark.sql.connector.distributions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; import org.apache.spark.sql.connector.expressions.Expression; /** @@ -26,7 +26,7 @@ * * @since 3.2.0 */ -@Experimental +@Evolving public interface ClusteredDistribution extends Distribution { /** * Returns clustering expressions. diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distribution.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distribution.java index 95d68ea2d1abe..0a2f982fce079 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distribution.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distribution.java @@ -17,12 +17,12 @@ package org.apache.spark.sql.connector.distributions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; /** * An interface that defines how data is distributed across partitions. * * @since 3.2.0 */ -@Experimental +@Evolving public interface Distribution {} diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distributions.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distributions.java index da5d6f8c81a3f..6a346a25424f6 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distributions.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distributions.java @@ -17,7 +17,7 @@ package org.apache.spark.sql.connector.distributions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; import org.apache.spark.sql.connector.expressions.Expression; import org.apache.spark.sql.connector.expressions.SortOrder; @@ -26,7 +26,7 @@ * * @since 3.2.0 */ -@Experimental +@Evolving public class Distributions { private Distributions() { } diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/OrderedDistribution.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/OrderedDistribution.java index 3456178d8e64f..f959cc2e00ce8 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/OrderedDistribution.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/OrderedDistribution.java @@ -17,7 +17,7 @@ package org.apache.spark.sql.connector.distributions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; import org.apache.spark.sql.connector.expressions.SortOrder; /** @@ -26,7 +26,7 @@ * * @since 3.2.0 */ -@Experimental +@Evolving public interface OrderedDistribution extends Distribution { /** * Returns ordering expressions. diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/UnspecifiedDistribution.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/UnspecifiedDistribution.java index ea18d8906cfd0..4749701e348e7 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/UnspecifiedDistribution.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/UnspecifiedDistribution.java @@ -17,12 +17,12 @@ package org.apache.spark.sql.connector.distributions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; /** * A distribution where no promises are made about co-location of data. * * @since 3.2.0 */ -@Experimental +@Evolving public interface UnspecifiedDistribution extends Distribution {} diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/NullOrdering.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/NullOrdering.java index 4aca199c11c0f..7d457a62b3136 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/NullOrdering.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/NullOrdering.java @@ -17,14 +17,14 @@ package org.apache.spark.sql.connector.expressions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; /** * A null order used in sorting expressions. * * @since 3.2.0 */ -@Experimental +@Evolving public enum NullOrdering { NULLS_FIRST, NULLS_LAST; diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortDirection.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortDirection.java index 7e3a29945cc99..385154e0fd835 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortDirection.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortDirection.java @@ -17,7 +17,7 @@ package org.apache.spark.sql.connector.expressions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; import static org.apache.spark.sql.connector.expressions.NullOrdering.NULLS_FIRST; import static org.apache.spark.sql.connector.expressions.NullOrdering.NULLS_LAST; @@ -30,7 +30,7 @@ * * @since 3.2.0 */ -@Experimental +@Evolving public enum SortDirection { ASCENDING(NULLS_FIRST), DESCENDING(NULLS_LAST); diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortOrder.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortOrder.java index 51401786ca5d7..45f06e17de6d5 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortOrder.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortOrder.java @@ -17,14 +17,14 @@ package org.apache.spark.sql.connector.expressions; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; /** * Represents a sort order in the public expression API. * * @since 3.2.0 */ -@Experimental +@Evolving public interface SortOrder extends Expression { /** * Returns the sort expression. diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RequiresDistributionAndOrdering.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RequiresDistributionAndOrdering.java index 2adfe75f7d80c..dbef9dd6146a2 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RequiresDistributionAndOrdering.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RequiresDistributionAndOrdering.java @@ -17,7 +17,7 @@ package org.apache.spark.sql.connector.write; -import org.apache.spark.annotation.Experimental; +import org.apache.spark.annotation.Evolving; import org.apache.spark.sql.connector.distributions.Distribution; import org.apache.spark.sql.connector.distributions.UnspecifiedDistribution; import org.apache.spark.sql.connector.expressions.SortOrder; @@ -27,7 +27,7 @@ * * @since 3.2.0 */ -@Experimental +@Evolving public interface RequiresDistributionAndOrdering extends Write { /** * Returns the distribution required by this write.