-
- Downloads
[SPARK-11663][STREAMING] Add Java API for trackStateByKey
TODO - [x] Add Java API - [x] Add API tests - [x] Add a function test Author: Shixiong Zhu <shixiong@databricks.com> Closes #9636 from zsxwing/java-track.
Showing
- core/src/main/java/org/apache/spark/api/java/function/Function4.java 27 additions, 0 deletions...in/java/org/apache/spark/api/java/function/Function4.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaStatefulNetworkWordCount.java 21 additions, 24 deletions...park/examples/streaming/JavaStatefulNetworkWordCount.java
- examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala 1 addition, 1 deletion...e/spark/examples/streaming/StatefulNetworkWordCount.scala
- extras/java8-tests/src/test/java/org/apache/spark/streaming/Java8APISuite.java 43 additions, 0 deletions...c/test/java/org/apache/spark/streaming/Java8APISuite.java
- streaming/src/main/scala/org/apache/spark/streaming/State.scala 23 additions, 2 deletions...ing/src/main/scala/org/apache/spark/streaming/State.scala
- streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala 62 additions, 22 deletions...src/main/scala/org/apache/spark/streaming/StateSpec.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala 45 additions, 1 deletion...org/apache/spark/streaming/api/java/JavaPairDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaTrackStateDStream.scala 44 additions, 0 deletions...ache/spark/streaming/api/java/JavaTrackStateDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/TrackStateDStream.scala 1 addition, 0 deletions...rg/apache/spark/streaming/dstream/TrackStateDStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/rdd/TrackStateRDD.scala 3 additions, 1 deletion.../scala/org/apache/spark/streaming/rdd/TrackStateRDD.scala
- streaming/src/main/scala/org/apache/spark/streaming/util/StateMap.scala 5 additions, 1 deletion...main/scala/org/apache/spark/streaming/util/StateMap.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaTrackStateByKeySuite.java 210 additions, 0 deletions.../org/apache/spark/streaming/JavaTrackStateByKeySuite.java
Loading
Please register or sign in to comment