-
- Downloads
[SPARK-9242] [SQL] Audit UDAF interface.
A few minor changes: 1. Improved documentation 2. Rename apply(distinct....) to distinct. 3. Changed MutableAggregationBuffer from a trait to an abstract class. 4. Renamed returnDataType to dataType to be more consistent with other expressions. And unrelated to UDAFs: 1. Renamed file names in expressions to use suffix "Expressions" to be more consistent. 2. Moved regexp related expressions out to its own file. 3. Renamed StringComparison => StringPredicate. Author: Reynold Xin <rxin@databricks.com> Closes #8321 from rxin/SPARK-9242.
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/bitwiseExpressions.scala 0 additions, 0 deletions...e/spark/sql/catalyst/expressions/bitwiseExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/conditionalExpressions.scala 0 additions, 0 deletions...ark/sql/catalyst/expressions/conditionalExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala 0 additions, 0 deletions.../spark/sql/catalyst/expressions/datetimeExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/decimalExpressions.scala 0 additions, 0 deletions...e/spark/sql/catalyst/expressions/decimalExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/jsonExpressions.scala 0 additions, 0 deletions...ache/spark/sql/catalyst/expressions/jsonExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/mathExpressions.scala 0 additions, 0 deletions...ache/spark/sql/catalyst/expressions/mathExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/nullExpressions.scala 0 additions, 0 deletions...ache/spark/sql/catalyst/expressions/nullExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/randomExpressions.scala 0 additions, 0 deletions...he/spark/sql/catalyst/expressions/randomExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/regexpExpressions.scala 346 additions, 0 deletions...he/spark/sql/catalyst/expressions/regexpExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/stringExpressions.scala 4 additions, 328 deletions...he/spark/sql/catalyst/expressions/stringExpressions.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala 1 addition, 1 deletion...a/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/StringExpressionsSuite.scala 1 addition, 1 deletion...ark/sql/catalyst/expressions/StringExpressionsSuite.scala
- sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala 1 addition, 0 deletions...src/main/scala/org/apache/spark/sql/UDFRegistration.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/udaf.scala 1 addition, 1 deletion...scala/org/apache/spark/sql/execution/aggregate/udaf.scala
- sql/core/src/main/scala/org/apache/spark/sql/expressions/udaf.scala 29 additions, 15 deletions...rc/main/scala/org/apache/spark/sql/expressions/udaf.scala
- sql/hive/src/test/java/test/org/apache/spark/sql/hive/JavaDataFrameSuite.java 1 addition, 1 deletion...va/test/org/apache/spark/sql/hive/JavaDataFrameSuite.java
- sql/hive/src/test/java/test/org/apache/spark/sql/hive/aggregate/MyDoubleAvg.java 1 addition, 1 deletion...test/org/apache/spark/sql/hive/aggregate/MyDoubleAvg.java
- sql/hive/src/test/java/test/org/apache/spark/sql/hive/aggregate/MyDoubleSum.java 1 addition, 1 deletion...test/org/apache/spark/sql/hive/aggregate/MyDoubleSum.java
Loading
Please register or sign in to comment