This is an automated email from the ASF dual-hosted git repository.
yangjie01 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 261b281e6e5 [SPARK-45659][SQL][SS] Add `since` field to Java API
marked as `@Deprecated`
261b281e6e5 is described below
commit 261b281e6e57be32eb28bf4e50bea24ed22a9f21
Author: yangjie01 <[email protected]>
AuthorDate: Thu Oct 26 21:35:39 2023 +0800
[SPARK-45659][SQL][SS] Add `since` field to Java API marked as `@Deprecated`
### What changes were proposed in this pull request?
This PR supplements the `since` field for the following Java APIs that have
been marked as Deprecated:
**Spark 3.0.0**
[SPARK-26861](https://issues.apache.org/jira/browse/SPARK-26861)
- `org.apache.spark.sql.expressions.javalang.typed`
[SPARK-27606](https://issues.apache.org/jira/browse/SPARK-27606)
-
`org.apache.spark.sql.catalyst.expressions.ExpressionDescription#extended`
-
`org.apache.spark.sql.catalyst.expressions.ExpressionInfo#ExpressionInfo(String,
String, String, String, String)`
**Spark 3.2.0**
[SPARK-33717](https://issues.apache.org/jira/browse/SPARK-33717)
-
`org.apache.spark.launcher.SparkLauncher#DEPRECATED_CHILD_CONNECTION_TIMEOUT`
[SPARK-33779](https://issues.apache.org/jira/browse/SPARK-33779)
- `org.apache.spark.sql.connector.write.WriteBuilder#buildForBatch`
- `org.apache.spark.sql.connector.write.WriteBuilder#buildForStreaming`
**Spark 3.4.0**
[SPARK-39805](https://issues.apache.org/jira/browse/SPARK-39805)
- `org.apache.spark.sql.streaming.Trigger`
[SPARK-42398](https://issues.apache.org/jira/browse/SPARK-42398)
-
`org.apache.spark.sql.connector.catalog.TableCatalog#createTable(Identifier,
StructType, Transform[], Map<String,String>) `
-
`org.apache.spark.sql.connector.catalog.StagingTableCatalog#stageCreate(Identifier,
StructType, Transform[], Map<String,String>)`
- `org.apache.spark.sql.connector.catalog.Table#schema`
### Why are the changes needed?
This facilitates tracing from which version the API started to be
deprecated.
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
Pass GitHub Actions
### Was this patch authored or co-authored using generative AI tooling?
No
Closes #43522 from LuciferYang/SPARK-45659.
Authored-by: yangjie01 <[email protected]>
Signed-off-by: yangjie01 <[email protected]>
---
launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java | 2 +-
sql/api/src/main/java/org/apache/spark/sql/streaming/Trigger.java | 2 +-
.../apache/spark/sql/catalyst/expressions/ExpressionDescription.java | 2 +-
.../org/apache/spark/sql/catalyst/expressions/ExpressionInfo.java | 2 +-
.../org/apache/spark/sql/connector/catalog/StagingTableCatalog.java | 4 ++--
.../src/main/java/org/apache/spark/sql/connector/catalog/Table.java | 4 ++--
.../java/org/apache/spark/sql/connector/catalog/TableCatalog.java | 4 ++--
.../main/java/org/apache/spark/sql/connector/write/WriteBuilder.java | 4 ++--
.../main/java/org/apache/spark/sql/expressions/javalang/typed.java | 2 +-
9 files changed, 13 insertions(+), 13 deletions(-)
diff --git
a/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java
b/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java
index bcff454b99a..5d36ef56d2c 100644
--- a/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java
+++ b/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java
@@ -99,7 +99,7 @@ public class SparkLauncher extends
AbstractLauncher<SparkLauncher> {
* @deprecated use `CHILD_CONNECTION_TIMEOUT`
* @since 1.6.0
*/
- @Deprecated
+ @Deprecated(since = "3.2.0")
public static final String DEPRECATED_CHILD_CONNECTION_TIMEOUT =
"spark.launcher.childConectionTimeout";
diff --git a/sql/api/src/main/java/org/apache/spark/sql/streaming/Trigger.java
b/sql/api/src/main/java/org/apache/spark/sql/streaming/Trigger.java
index 328c5290e77..6e3a93ba945 100644
--- a/sql/api/src/main/java/org/apache/spark/sql/streaming/Trigger.java
+++ b/sql/api/src/main/java/org/apache/spark/sql/streaming/Trigger.java
@@ -98,7 +98,7 @@ public class Trigger {
* processing of watermark advancement including no-data batch.
* See the NOTES in {@link #AvailableNow()} for details.
*/
- @Deprecated
+ @Deprecated(since = "3.4.0")
public static Trigger Once() {
return OneTimeTrigger$.MODULE$;
}
diff --git
a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionDescription.java
b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionDescription.java
index e9ccf2b56f8..833d68bdf89 100644
---
a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionDescription.java
+++
b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionDescription.java
@@ -102,7 +102,7 @@ public @interface ExpressionDescription {
* {@link #examples}, {@link #note}, {@link #since} and {@link
#deprecated} instead
* to document the extended usage.
*/
- @Deprecated
+ @Deprecated(since = "3.0.0")
String extended() default "";
String arguments() default "";
String examples() default "";
diff --git
a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionInfo.java
b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionInfo.java
index 84ee30440b7..e7af5a68b46 100644
---
a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionInfo.java
+++
b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionInfo.java
@@ -192,7 +192,7 @@ public class ExpressionInfo {
* @deprecated This constructor is deprecated as of Spark 3.0. Use other
constructors to fully
* specify each argument for extended usage.
*/
- @Deprecated
+ @Deprecated(since = "3.0.0")
public ExpressionInfo(String className, String db, String name, String
usage, String extended) {
// `arguments` and `examples` are concatenated for the extended
description. So, here
// simply pass the `extended` as `arguments` and an empty string for
`examples`.
diff --git
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/StagingTableCatalog.java
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/StagingTableCatalog.java
index 4337a7c6152..e69fc3324c6 100644
---
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/StagingTableCatalog.java
+++
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/StagingTableCatalog.java
@@ -57,10 +57,10 @@ public interface StagingTableCatalog extends TableCatalog {
/**
* Stage the creation of a table, preparing it to be committed into the
metastore.
* <p>
- * This is deprecated. Please override
+ * @deprecated This is deprecated. Please override
* {@link #stageCreate(Identifier, Column[], Transform[], Map)} instead.
*/
- @Deprecated
+ @Deprecated(since = "3.4.0")
StagedTable stageCreate(
Identifier ident,
StructType schema,
diff --git
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Table.java
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Table.java
index b9753a08aba..d5eb03dcf94 100644
---
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Table.java
+++
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Table.java
@@ -52,9 +52,9 @@ public interface Table {
* Returns the schema of this table. If the table is not readable and
doesn't have a schema, an
* empty schema can be returned here.
* <p>
- * This is deprecated. Please override {@link #columns} instead.
+ * @deprecated This is deprecated. Please override {@link #columns} instead.
*/
- @Deprecated
+ @Deprecated(since = "3.4.0")
StructType schema();
/**
diff --git
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableCatalog.java
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableCatalog.java
index d99e7e14b01..6642adc3354 100644
---
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableCatalog.java
+++
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableCatalog.java
@@ -170,10 +170,10 @@ public interface TableCatalog extends CatalogPlugin {
/**
* Create a table in the catalog.
* <p>
- * This is deprecated. Please override
+ * @deprecated This is deprecated. Please override
* {@link #createTable(Identifier, Column[], Transform[], Map)} instead.
*/
- @Deprecated
+ @Deprecated(since = "3.4.0")
Table createTable(
Identifier ident,
StructType schema,
diff --git
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/WriteBuilder.java
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/WriteBuilder.java
index 51ca167a4c0..c8b20ec7e92 100644
---
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/WriteBuilder.java
+++
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/WriteBuilder.java
@@ -56,7 +56,7 @@ public interface WriteBuilder {
*
* @deprecated use {@link #build()} instead.
*/
- @Deprecated
+ @Deprecated(since = "3.2.0")
default BatchWrite buildForBatch() {
throw new UnsupportedOperationException(getClass().getName() +
" does not support batch write");
@@ -67,7 +67,7 @@ public interface WriteBuilder {
*
* @deprecated use {@link #build()} instead.
*/
- @Deprecated
+ @Deprecated(since = "3.2.0")
default StreamingWrite buildForStreaming() {
throw new UnsupportedOperationException(getClass().getName() +
" does not support streaming write");
diff --git
a/sql/core/src/main/java/org/apache/spark/sql/expressions/javalang/typed.java
b/sql/core/src/main/java/org/apache/spark/sql/expressions/javalang/typed.java
index 259328d319c..e1e4ba4c8e0 100644
---
a/sql/core/src/main/java/org/apache/spark/sql/expressions/javalang/typed.java
+++
b/sql/core/src/main/java/org/apache/spark/sql/expressions/javalang/typed.java
@@ -32,7 +32,7 @@ import org.apache.spark.sql.execution.aggregate.TypedSumLong;
* @since 2.0.0
* @deprecated As of release 3.0.0, please use the untyped builtin aggregate
functions.
*/
-@Deprecated
+@Deprecated(since = "3.0.0")
public class typed {
// Note: make sure to keep in sync with typed.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
