diff --git a/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SparkSession.scala b/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SparkSession.scala index 231c604b98bb5..b74d0c2ff2243 100644 --- a/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SparkSession.scala +++ b/connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SparkSession.scala @@ -210,7 +210,6 @@ class SparkSession private[sql] ( throw ConnectClientUnsupportedErrors.executeCommand() /** @inheritdoc */ - @Experimental def sql(sqlText: String, args: Array[_]): DataFrame = { val sqlCommand = proto.SqlCommand .newBuilder() @@ -221,13 +220,11 @@ class SparkSession private[sql] ( } /** @inheritdoc */ - @Experimental def sql(sqlText: String, args: Map[String, Any]): DataFrame = { sql(sqlText, args.asJava) } /** @inheritdoc */ - @Experimental override def sql(sqlText: String, args: java.util.Map[String, Any]): DataFrame = { val sqlCommand = proto.SqlCommand .newBuilder() diff --git a/sql/api/src/main/scala/org/apache/spark/sql/api/SparkSession.scala b/sql/api/src/main/scala/org/apache/spark/sql/api/SparkSession.scala index 64b0a87c573d3..35f74497b96f4 100644 --- a/sql/api/src/main/scala/org/apache/spark/sql/api/SparkSession.scala +++ b/sql/api/src/main/scala/org/apache/spark/sql/api/SparkSession.scala @@ -470,7 +470,6 @@ abstract class SparkSession extends Serializable with Closeable { * is. * @since 3.5.0 */ - @Experimental def sql(sqlText: String, args: Array[_]): Dataset[Row] /** @@ -488,7 +487,6 @@ abstract class SparkSession extends Serializable with Closeable { * `array()`, `struct()`, in that case it is taken as is. * @since 3.4.0 */ - @Experimental def sql(sqlText: String, args: Map[String, Any]): Dataset[Row] /** @@ -506,7 +504,6 @@ abstract class SparkSession extends Serializable with Closeable { * `array()`, `struct()`, in that case it is taken as is. * @since 3.4.0 */ - @Experimental def sql(sqlText: String, args: util.Map[String, Any]): Dataset[Row] = { sql(sqlText, args.asScala.toMap) } diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala b/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala index a7f85db12b214..8cf30fb39f310 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala @@ -460,7 +460,6 @@ class SparkSession private( } /** @inheritdoc */ - @Experimental def sql(sqlText: String, args: Array[_]): DataFrame = { sql(sqlText, args, new QueryPlanningTracker) } @@ -498,13 +497,11 @@ class SparkSession private( } /** @inheritdoc */ - @Experimental def sql(sqlText: String, args: Map[String, Any]): DataFrame = { sql(sqlText, args, new QueryPlanningTracker) } /** @inheritdoc */ - @Experimental override def sql(sqlText: String, args: java.util.Map[String, Any]): DataFrame = { sql(sqlText, args.asScala.toMap) }