-
- Downloads
[SPARK-22569][SQL] Clean usage of addMutableState and splitExpressions
## What changes were proposed in this pull request? This PR is to clean the usage of addMutableState and splitExpressions 1. replace hardcoded type string to ctx.JAVA_BOOLEAN etc. 2. create a default value of the initCode for ctx.addMutableStats 3. Use named arguments when calling `splitExpressions ` ## How was this patch tested? The existing test cases Author: gatorsmile <gatorsmile@gmail.com> Closes #19790 from gatorsmile/codeClean.
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/MonotonicallyIncreasingID.scala 2 additions, 2 deletions.../sql/catalyst/expressions/MonotonicallyIncreasingID.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SparkPartitionID.scala 1 addition, 1 deletion...che/spark/sql/catalyst/expressions/SparkPartitionID.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/arithmetic.scala 4 additions, 4 deletions...rg/apache/spark/sql/catalyst/expressions/arithmetic.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala 17 additions, 5 deletions...park/sql/catalyst/expressions/codegen/CodeGenerator.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateMutableProjection.scala 1 addition, 1 deletion...alyst/expressions/codegen/GenerateMutableProjection.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeCreator.scala 1 addition, 1 deletion...e/spark/sql/catalyst/expressions/complexTypeCreator.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/hash.scala 3 additions, 3 deletions...cala/org/apache/spark/sql/catalyst/expressions/hash.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/nullExpressions.scala 6 additions, 4 deletions...ache/spark/sql/catalyst/expressions/nullExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala 13 additions, 13 deletions...ache/spark/sql/catalyst/expressions/objects/objects.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala 3 additions, 3 deletions...rg/apache/spark/sql/catalyst/expressions/predicates.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/randomExpressions.scala 2 additions, 2 deletions...he/spark/sql/catalyst/expressions/randomExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/stringExpressions.scala 26 additions, 19 deletions...he/spark/sql/catalyst/expressions/stringExpressions.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/ColumnarBatchScan.scala 2 additions, 2 deletions...la/org/apache/spark/sql/execution/ColumnarBatchScan.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SortExec.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/sql/execution/SortExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala 10 additions, 10 deletions...che/spark/sql/execution/aggregate/HashAggregateExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashMapGenerator.scala 2 additions, 2 deletions...ache/spark/sql/execution/aggregate/HashMapGenerator.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala 4 additions, 4 deletions...g/apache/spark/sql/execution/basicPhysicalOperators.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/GenerateColumnAccessor.scala 1 addition, 1 deletion...spark/sql/execution/columnar/GenerateColumnAccessor.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala 3 additions, 3 deletions.../apache/spark/sql/execution/joins/SortMergeJoinExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala 2 additions, 2 deletions...src/main/scala/org/apache/spark/sql/execution/limit.scala
Loading
Please register or sign in to comment