-
- Downloads
Fixed bug in Java transformWith, added more Java testcases for transform and...
Fixed bug in Java transformWith, added more Java testcases for transform and transformWith, added missing variations of Java join and cogroup, updated various Scala and Java API docs.
Showing
- core/src/main/scala/org/apache/spark/api/java/function/Function3.java 1 addition, 1 deletion...n/scala/org/apache/spark/api/java/function/Function3.java
- core/src/main/scala/org/apache/spark/api/java/function/WrappedFunction3.scala 2 additions, 2 deletions...org/apache/spark/api/java/function/WrappedFunction3.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStream.scala 8 additions, 8 deletions...g/src/main/scala/org/apache/spark/streaming/DStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/PairDStreamFunctions.scala 67 additions, 31 deletions...ala/org/apache/spark/streaming/PairDStreamFunctions.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala 33 additions, 31 deletions...org/apache/spark/streaming/api/java/JavaDStreamLike.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala 109 additions, 33 deletions...org/apache/spark/streaming/api/java/JavaPairDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/CoGroupedDStream.scala 0 additions, 58 deletions...org/apache/spark/streaming/dstream/CoGroupedDStream.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java 204 additions, 15 deletions...rc/test/java/org/apache/spark/streaming/JavaAPISuite.java
Loading
Please register or sign in to comment