From 03c9fc325e785b223650440e9b2d86a6a8134733 Mon Sep 17 00:00:00 2001 From: Hongze Zhang Date: Mon, 9 Dec 2024 15:42:09 +0800 Subject: [PATCH] fixup --- .../gluten/extension/columnar/validator/Validators.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/validator/Validators.scala b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/validator/Validators.scala index 24b1e681e49d..7e7f7b052d98 100644 --- a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/validator/Validators.scala +++ b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/validator/Validators.scala @@ -231,7 +231,7 @@ object Validators { import FallbackByNativeValidation._ private val offloadAttempt: LegacyOffload = LegacyOffload(offloadRules) override def validate(plan: SparkPlan): Validator.OutCome = { - applyAsSingleNode(plan) { + applyOnSingleNode(plan) { node => val offloadedNode = offloadAttempt.apply(node) val outcomes = offloadedNode.collect { @@ -265,7 +265,7 @@ object Validators { override def outputPartitioning: Partitioning = originalChild.outputPartitioning } - private def applyAsSingleNode[T](plan: SparkPlan)(body: SparkPlan => T): T = { + private def applyOnSingleNode[T](plan: SparkPlan)(body: SparkPlan => T): T = { val newChildren = plan.children.map(child => FakeLeaf(originalChild = child)) val newPlan = plan.withNewChildren(newChildren) val applied = body(newPlan)