This is an automated email from the ASF dual-hosted git repository.
dongjoon 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 32b2827b964b [SPARK-47834][SQL][CONNECT] Mark deprecated functions
with `@deprecated` in `SQLImplicits`
32b2827b964b is described below
commit 32b2827b964bd4a4accb60b47ddd6929f41d4a89
Author: YangJie <yangji...@baidu.com>
AuthorDate: Thu May 9 20:47:34 2024 -0700
[SPARK-47834][SQL][CONNECT] Mark deprecated functions with `@deprecated` in
`SQLImplicits`
### What changes were proposed in this pull request?
In the `sql` module, some functions in `SQLImplicits` have already been
marked as `deprecated` in the function comments after SPARK-19089.
This pr adds `deprecated` type annotation marks to them. Since SPARK-19089
occurred in Spark 2.2.0, the `since` field of `deprecated` is filled in as
`2.2.0`.
At the same time, these `deprecated` marks have also been synchronized to
the corresponding functions in `SQLImplicits` in the `connect` module.
### Why are the changes needed?
Mark deprecated functions with `deprecated` in `SQLImplicits`
### 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 #46029 from LuciferYang/deprecated-SQLImplicits.
Lead-authored-by: YangJie <yangji...@baidu.com>
Co-authored-by: yangjie01 <yangji...@baidu.com>
Signed-off-by: Dongjoon Hyun <dh...@apple.com>
---
.../jvm/src/main/scala/org/apache/spark/sql/SQLImplicits.scala | 9 +++++++++
sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala | 9 +++++++++
2 files changed, 18 insertions(+)
diff --git
a/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
b/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
index 6c626fd716d5..7799d395d5c6 100644
---
a/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
+++
b/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
@@ -149,6 +149,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newIntSeqEncoder: Encoder[Seq[Int]] = newSeqEncoder(PrimitiveIntEncoder)
/**
@@ -156,6 +157,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newLongSeqEncoder: Encoder[Seq[Long]] =
newSeqEncoder(PrimitiveLongEncoder)
/**
@@ -163,6 +165,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newDoubleSeqEncoder: Encoder[Seq[Double]] =
newSeqEncoder(PrimitiveDoubleEncoder)
/**
@@ -170,6 +173,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newFloatSeqEncoder: Encoder[Seq[Float]] =
newSeqEncoder(PrimitiveFloatEncoder)
/**
@@ -177,6 +181,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newByteSeqEncoder: Encoder[Seq[Byte]] =
newSeqEncoder(PrimitiveByteEncoder)
/**
@@ -184,6 +189,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newShortSeqEncoder: Encoder[Seq[Short]] =
newSeqEncoder(PrimitiveShortEncoder)
/**
@@ -191,6 +197,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newBooleanSeqEncoder: Encoder[Seq[Boolean]] =
newSeqEncoder(PrimitiveBooleanEncoder)
/**
@@ -198,6 +205,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newStringSeqEncoder: Encoder[Seq[String]] = newSeqEncoder(StringEncoder)
/**
@@ -205,6 +213,7 @@ abstract class SQLImplicits private[sql] (session:
SparkSession) extends LowPrio
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newProductSeqEncoder[A <: Product: TypeTag]: Encoder[Seq[A]] =
newSeqEncoder(ScalaReflection.encoderFor[A])
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
b/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
index d257a6b771b9..56f13994277d 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
@@ -130,54 +130,63 @@ abstract class SQLImplicits extends
LowPrioritySQLImplicits {
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newIntSeqEncoder: Encoder[Seq[Int]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newLongSeqEncoder: Encoder[Seq[Long]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newDoubleSeqEncoder: Encoder[Seq[Double]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newFloatSeqEncoder: Encoder[Seq[Float]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newByteSeqEncoder: Encoder[Seq[Byte]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newShortSeqEncoder: Encoder[Seq[Short]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newBooleanSeqEncoder: Encoder[Seq[Boolean]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newStringSeqEncoder: Encoder[Seq[String]] = ExpressionEncoder()
/**
* @since 1.6.1
* @deprecated use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
def newProductSeqEncoder[A <: Product : TypeTag]: Encoder[Seq[A]] =
ExpressionEncoder()
/** @since 2.2.0 */
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
