Minor fix

Signed-off-by: Heng Qian <[email protected]>
opensearch-project · Nov 4, 2024 · 83cd46c · 83cd46c
1 parent aee8971
commit 83cd46c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ala/org/opensearch/flint/spark/ppl/PPLLogicalPlanLambdaFunctionsTranslatorTestSuite.scala b/...ala/org/opensearch/flint/spark/ppl/PPLLogicalPlanLambdaFunctionsTranslatorTestSuite.scala
@@ -181,7 +181,7 @@ class PPLLogicalPlanLambdaFunctionsTranslatorTestSuite
       planTransformer.visit(
         plan(
           pplParser,
-          """source=t | eval a = json_array(1, 2, 3), b = transform(a, 0, (x, y) -> x + y, x -> x * 10)""".stripMargin),
+          """source=t | eval a = json_array(1, 2, 3), b = reduce(a, 0, (x, y) -> x + y, x -> x * 10)""".stripMargin),
         context)
     val table = UnresolvedRelation(Seq("t"))
     val jsonFunc =
@@ -199,7 +199,7 @@ class PPLLogicalPlanLambdaFunctionsTranslatorTestSuite
     val aliasB =
       Alias(
         UnresolvedFunction(
-          "transform",
+          "reduce",
           Seq(UnresolvedAttribute("a"), Literal(0), mergeLambda, finishLambda),
           false),
         "b")()