This is an automated email from the ASF dual-hosted git repository. gurwls223 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 957b0bc79d2 [SPARK-41183][SQL][FOLLOWUP] Change the name from injectPlanNormalizationRules to injectPlanNormalizationRule 957b0bc79d2 is described below commit 957b0bc79d26f6859e4456d58854bd9b4a2fa0e9 Author: Wenchen Fan <wenc...@databricks.com> AuthorDate: Thu Nov 24 10:37:31 2022 +0900 [SPARK-41183][SQL][FOLLOWUP] Change the name from injectPlanNormalizationRules to injectPlanNormalizationRule ### What changes were proposed in this pull request? Followup of https://github.com/apache/spark/pull/38692. To follow other APIs in `SparkSessionExtensions`, the name should be `inject...Rule` and `build...Rules`. ### Why are the changes needed? typo fix ### Does this PR introduce _any_ user-facing change? not a released API ### How was this patch tested? n/a Closes #38767 from cloud-fan/small. Authored-by: Wenchen Fan <wenc...@databricks.com> Signed-off-by: Hyukjin Kwon <gurwls...@apache.org> --- .../src/main/scala/org/apache/spark/sql/SparkSessionExtensions.scala | 2 +- .../test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SparkSessionExtensions.scala b/sql/core/src/main/scala/org/apache/spark/sql/SparkSessionExtensions.scala index 6b3744fe02d..dc3dfaae4ff 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/SparkSessionExtensions.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/SparkSessionExtensions.scala @@ -230,7 +230,7 @@ class SparkSessionExtensions { * cache hit rate by normalizing different plans to the same form. These rules should never modify * the result of the LogicalPlan. */ - def injectPlanNormalizationRules(builder: RuleBuilder): Unit = { + def injectPlanNormalizationRule(builder: RuleBuilder): Unit = { planNormalizationRules += builder } diff --git a/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala index f5f04eabec0..66507756e89 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala @@ -194,7 +194,7 @@ class SparkSessionExtensionSuite extends SparkFunSuite with SQLHelper { test("inject plan normalization rules") { val extensions = create { extensions => - extensions.injectPlanNormalizationRules { session => + extensions.injectPlanNormalizationRule { session => org.apache.spark.sql.catalyst.optimizer.PushDownPredicates } } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org