Skip to content

[SPARK-54622][SQL] Promote RequiresDistributionAndOrdering and its required interfaces to Evolving #53361

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
dongjoon-hyun wants to merge 1 commit into from
Closed

[SPARK-54622][SQL] Promote RequiresDistributionAndOrdering and its required interfaces to Evolving #53361

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions ...yst/src/main/java/org/apache/spark/sql/connector/distributions/ClusteredDistribution.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;

/**
Expand All @@ -26,7 +26,7 @@
*
* @since 3.2.0
*/
@Experimental
@Evolving
public interface ClusteredDistribution extends Distribution {
/**
* Returns clustering expressions.
Expand Down
4 changes: 2 additions & 2 deletions sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distribution.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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 {}
4 changes: 2 additions & 2 deletions sql/catalyst/src/main/java/org/apache/spark/sql/connector/distributions/Distributions.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand All @@ -26,7 +26,7 @@
*
* @since 3.2.0
*/
@Experimental
@Evolving
public class Distributions {
private Distributions() {
}
Expand Down
4 changes: 2 additions & 2 deletions ...alyst/src/main/java/org/apache/spark/sql/connector/distributions/OrderedDistribution.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;

/**
Expand All @@ -26,7 +26,7 @@
*
* @since 3.2.0
*/
@Experimental
@Evolving
public interface OrderedDistribution extends Distribution {
/**
* Returns ordering expressions.
Expand Down
4 changes: 2 additions & 2 deletions ...t/src/main/java/org/apache/spark/sql/connector/distributions/UnspecifiedDistribution.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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 {}
4 changes: 2 additions & 2 deletions sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/NullOrdering.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
4 changes: 2 additions & 2 deletions sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortDirection.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -30,7 +30,7 @@
*
* @since 3.2.0
*/
@Experimental
@Evolving
public enum SortDirection {
ASCENDING(NULLS_FIRST), DESCENDING(NULLS_LAST);

Expand Down
4 changes: 2 additions & 2 deletions sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/SortOrder.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
4 changes: 2 additions & 2 deletions ...t/src/main/java/org/apache/spark/sql/connector/write/RequiresDistributionAndOrdering.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -27,7 +27,7 @@
*
* @since 3.2.0
*/
@Experimental
@Evolving
public interface RequiresDistributionAndOrdering extends Write {
/**
* Returns the distribution required by this write.
Expand Down