-
- Downloads
[SPARK-5605][SQL][DF] Allow using String to specify colum name in DSL aggregate functions
Author: Reynold Xin <rxin@databricks.com> Closes #4376 from rxin/SPARK-5605 and squashes the following commits: c55f5fa [Reynold Xin] Added a Python test. f4b8dbb [Reynold Xin] [SPARK-5605][SQL][DF] Allow using String to specify colum name in DSL aggregate functions.
Showing
- python/pyspark/sql.py 8 additions, 5 deletionspython/pyspark/sql.py
- sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala 4 additions, 4 deletionssql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameImpl.scala 4 additions, 4 deletions...e/src/main/scala/org/apache/spark/sql/DataFrameImpl.scala
- sql/core/src/main/scala/org/apache/spark/sql/Dsl.scala 37 additions, 0 deletionssql/core/src/main/scala/org/apache/spark/sql/Dsl.scala
- sql/core/src/main/scala/org/apache/spark/sql/GroupedData.scala 1 addition, 1 deletion...ore/src/main/scala/org/apache/spark/sql/GroupedData.scala
- sql/core/src/main/scala/org/apache/spark/sql/IncomputableColumn.scala 2 additions, 2 deletions.../main/scala/org/apache/spark/sql/IncomputableColumn.scala
Loading
Please register or sign in to comment