update scalastyle

Signed-off-by: YANGDB <[email protected]>
opensearch-project · Sep 20, 2023 · fa20a5a · fa20a5a
1 parent 3a33502
commit fa20a5a
Show file tree

Hide file tree

Showing 6 changed files with 384 additions and 236 deletions.
diff --git a/...spark-integration/src/main/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLParser.scala b/...spark-integration/src/main/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLParser.scala
@@ -38,7 +38,8 @@ import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
 import org.apache.spark.sql.types.{DataType, StructType}
 
 /**
- * Flint PPL parser that parse PPL Query Language into spark logical plan - if parse fails it will fall back to spark's parser.
+ * Flint PPL parser that parse PPL Query Language into spark logical plan - if parse fails it will
+ * fall back to spark's parser.
  *
  * @param sparkParser
  *   Spark SQL parser

diff --git a/...park-integration/src/test/scala/org/opensearch/flint/spark/ppl/LogicalPlanTestUtils.scala b/...park-integration/src/test/scala/org/opensearch/flint/spark/ppl/LogicalPlanTestUtils.scala
@@ -12,9 +12,10 @@ import org.apache.spark.sql.catalyst.plans.logical.{Aggregate, LogicalPlan, Proj
  * general utility functions for ppl to spark transformation test
  */
 trait LogicalPlanTestUtils {
+
   /**
-   * utility function to compare two logical plans while ignoring the auto-generated expressionId associated with the alias
-   * which is used for projection or aggregation 
+   * utility function to compare two logical plans while ignoring the auto-generated expressionId
+   * associated with the alias which is used for projection or aggregation
    * @param plan
    * @return
    */
@@ -23,18 +24,21 @@ trait LogicalPlanTestUtils {
     val rule: PartialFunction[LogicalPlan, LogicalPlan] = {
       case p: Project =>
         val newProjections = p.projectList.map {
-          case alias: Alias => Alias(alias.child, alias.name)(exprId = ExprId(0), qualifier = alias.qualifier)
+          case alias: Alias =>
+            Alias(alias.child, alias.name)(exprId = ExprId(0), qualifier = alias.qualifier)
           case other => other
         }
         p.copy(projectList = newProjections)
 
       case agg: Aggregate =>
         val newGrouping = agg.groupingExpressions.map {
-          case alias: Alias => Alias(alias.child, alias.name)(exprId = ExprId(0), qualifier = alias.qualifier)
+          case alias: Alias =>
+            Alias(alias.child, alias.name)(exprId = ExprId(0), qualifier = alias.qualifier)
           case other => other
         }
         val newAggregations = agg.aggregateExpressions.map {
-          case alias: Alias => Alias(alias.child, alias.name)(exprId = ExprId(0), qualifier = alias.qualifier)
+          case alias: Alias =>
+            Alias(alias.child, alias.name)(exprId = ExprId(0), qualifier = alias.qualifier)
           case other => other
         }
         agg.copy(groupingExpressions = newGrouping, aggregateExpressions = newAggregations)