-
- Downloads
Removed countByKeyAndWindow on paired DStreams, and added...
Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWindow for all DStreams. Updated both scala and java API and testsuites.
Showing
- examples/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala 5 additions, 6 deletions...spark/streaming/examples/clickstream/PageViewStream.scala
- streaming/src/main/scala/spark/streaming/DStream.scala 72 additions, 16 deletionsstreaming/src/main/scala/spark/streaming/DStream.scala
- streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala 5 additions, 38 deletions...src/main/scala/spark/streaming/PairDStreamFunctions.scala
- streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala 10 additions, 17 deletions...src/main/scala/spark/streaming/api/java/JavaDStream.scala
- streaming/src/main/scala/spark/streaming/api/java/JavaDStreamLike.scala 85 additions, 2 deletions...main/scala/spark/streaming/api/java/JavaDStreamLike.scala
- streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala 1 addition, 55 deletions...main/scala/spark/streaming/api/java/JavaPairDStream.scala
- streaming/src/test/java/spark/streaming/JavaAPISuite.java 30 additions, 49 deletionsstreaming/src/test/java/spark/streaming/JavaAPISuite.java
- streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala 19 additions, 2 deletions...src/test/scala/spark/streaming/BasicOperationsSuite.scala
- streaming/src/test/scala/spark/streaming/WindowOperationsSuite.scala 4 additions, 4 deletions...rc/test/scala/spark/streaming/WindowOperationsSuite.scala
Loading
Please register or sign in to comment