-
- Downloads
Added filter functionality to reduceByKeyAndWindow with inverse. Consolidated...
Added filter functionality to reduceByKeyAndWindow with inverse. Consolidated reduceByKeyAndWindow's many functions into smaller number of functions with optional parameters.
Showing
- streaming/src/main/scala/spark/streaming/DStream.scala 1 addition, 1 deletionstreaming/src/main/scala/spark/streaming/DStream.scala
- streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala 28 additions, 43 deletions...src/main/scala/spark/streaming/PairDStreamFunctions.scala
- streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala 20 additions, 8 deletions...main/scala/spark/streaming/api/java/JavaPairDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/ReducedWindowedDStream.scala 19 additions, 11 deletions...cala/spark/streaming/dstream/ReducedWindowedDStream.scala
- streaming/src/main/scala/spark/streaming/util/MasterFailureTest.scala 0 additions, 1 deletion...c/main/scala/spark/streaming/util/MasterFailureTest.scala
- streaming/src/test/resources/log4j.properties 1 addition, 1 deletionstreaming/src/test/resources/log4j.properties
- streaming/src/test/scala/spark/streaming/WindowOperationsSuite.scala 33 additions, 16 deletions...rc/test/scala/spark/streaming/WindowOperationsSuite.scala
Loading
Please register or sign in to comment