Skip to content

Commit

Permalink
[SPARK-50422][SQL] Make Parameterized SQL queries of `SparkSession.…
Browse files Browse the repository at this point in the history
…sql` API GA
  • Loading branch information
dongjoon-hyun committed Nov 26, 2024
1 parent afb5d6f commit 3e61574
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -460,7 +460,6 @@ class SparkSession private(
}

/** @inheritdoc */
@Experimental
def sql(sqlText: String, args: Array[_]): DataFrame = {
sql(sqlText, args, new QueryPlanningTracker)
}
Expand Down Expand Up @@ -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)
}
Expand Down

0 comments on commit 3e61574

Please sign in to comment.