-
- Downloads
[SPARK-11899][SQL] API audit for GroupedDataset.
1. Renamed map to mapGroup, flatMap to flatMapGroup. 2. Renamed asKey -> keyAs. 3. Added more documentation. 4. Changed type parameter T to V on GroupedDataset. 5. Added since versions for all functions. Author: Reynold Xin <rxin@databricks.com> Closes #9880 from rxin/SPARK-11899.
Showing
- core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java 1 addition, 1 deletion.../org/apache/spark/api/java/function/MapGroupFunction.java
- sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala 4 additions, 0 deletions...atalyst/src/main/scala/org/apache/spark/sql/Encoder.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/JavaTypeInference.scala 1 addition, 2 deletions...ala/org/apache/spark/sql/catalyst/JavaTypeInference.scala
- sql/core/src/main/scala/org/apache/spark/sql/Column.scala 2 additions, 0 deletionssql/core/src/main/scala/org/apache/spark/sql/Column.scala
- sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala 0 additions, 1 deletionsql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
- sql/core/src/main/scala/org/apache/spark/sql/GroupedDataset.scala 106 additions, 26 deletions.../src/main/scala/org/apache/spark/sql/GroupedDataset.scala
- sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java 4 additions, 4 deletions...test/java/test/org/apache/spark/sql/JavaDatasetSuite.java
- sql/core/src/test/scala/org/apache/spark/sql/DatasetPrimitiveSuite.scala 2 additions, 2 deletions...st/scala/org/apache/spark/sql/DatasetPrimitiveSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala 11 additions, 9 deletions...re/src/test/scala/org/apache/spark/sql/DatasetSuite.scala
Loading
Please register or sign in to comment