We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8ab0b79 commit 4e84a6fCopy full SHA for 4e84a6f
sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala
@@ -894,6 +894,17 @@ object SparkSession extends Logging {
894
*
895
* @since 2.2.0
896
*/
897
+ def withExtensions(f: SparkSessionExtensions => Unit): Builder = synchronized {
898
+ f(extensions)
899
+ this
900
+ }
901
+
902
+ /**
903
+ * Inject extensions into the [[SparkSession]]. This allows a user to add Analyzer rules,
904
+ * Optimizer rules, Planning Strategies or a customized parser.
905
+ *
906
+ * @since 3.2.0
907
+ */
908
def withExtensions(f: SparkSessionExtensionsProvider): Builder = synchronized {
909
f(extensions)
910
this
0 commit comments