[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 <yangjie01@baidu.com>
Co-authored-by: yangjie01 <yangjie01@baidu.com>
Signed-off-by: Dongjoon Hyun <dhyun@apple.com>
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 6c626fd..7799d39 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 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newIntSeqEncoder: Encoder[Seq[Int]] = newSeqEncoder(PrimitiveIntEncoder)
/**
@@ -156,6 +157,7 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newLongSeqEncoder: Encoder[Seq[Long]] = newSeqEncoder(PrimitiveLongEncoder)
/**
@@ -163,6 +165,7 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newDoubleSeqEncoder: Encoder[Seq[Double]] = newSeqEncoder(PrimitiveDoubleEncoder)
/**
@@ -170,6 +173,7 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newFloatSeqEncoder: Encoder[Seq[Float]] = newSeqEncoder(PrimitiveFloatEncoder)
/**
@@ -177,6 +181,7 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newByteSeqEncoder: Encoder[Seq[Byte]] = newSeqEncoder(PrimitiveByteEncoder)
/**
@@ -184,6 +189,7 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newShortSeqEncoder: Encoder[Seq[Short]] = newSeqEncoder(PrimitiveShortEncoder)
/**
@@ -191,6 +197,7 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newBooleanSeqEncoder: Encoder[Seq[Boolean]] = newSeqEncoder(PrimitiveBooleanEncoder)
/**
@@ -198,6 +205,7 @@
* @deprecated
* use [[newSequenceEncoder]]
*/
+ @deprecated("Use newSequenceEncoder instead", "2.2.0")
val newStringSeqEncoder: Encoder[Seq[String]] = newSeqEncoder(StringEncoder)
/**
@@ -205,6 +213,7 @@
* @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 d257a6b..56f1399 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 @@
* @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 */
