-
- Downloads
[SPARK-11564][SQL][FOLLOW-UP] improve java api for GroupedDataset
created `MapGroupFunction`, `FlatMapGroupFunction`, `CoGroupFunction` Author: Wenchen Fan <wenchen@databricks.com> Closes #9564 from cloud-fan/map.
Showing
- core/src/main/java/org/apache/spark/api/java/function/CoGroupFunction.java 29 additions, 0 deletions...a/org/apache/spark/api/java/function/CoGroupFunction.java
- core/src/main/java/org/apache/spark/api/java/function/FlatMapFunction.java 1 addition, 1 deletion...a/org/apache/spark/api/java/function/FlatMapFunction.java
- core/src/main/java/org/apache/spark/api/java/function/FlatMapFunction2.java 1 addition, 1 deletion.../org/apache/spark/api/java/function/FlatMapFunction2.java
- core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupFunction.java 28 additions, 0 deletions.../apache/spark/api/java/function/FlatMapGroupFunction.java
- core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java 28 additions, 0 deletions.../org/apache/spark/api/java/function/MapGroupFunction.java
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala 2 additions, 2 deletions...che/spark/sql/catalyst/plans/logical/basicOperators.scala
- sql/core/src/main/scala/org/apache/spark/sql/GroupedDataset.scala 4 additions, 8 deletions.../src/main/scala/org/apache/spark/sql/GroupedDataset.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/basicOperators.scala 1 addition, 1 deletion...scala/org/apache/spark/sql/execution/basicOperators.scala
- sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java 24 additions, 12 deletions...test/java/test/org/apache/spark/sql/JavaDatasetSuite.java
Loading
Please register or sign in to comment