-
- Downloads
Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird
Conflicts: project/SparkBuild.scala
No related branches found
No related tags found
Showing
- core/src/main/scala/spark/rdd/CheckpointRDD.scala 2 additions, 2 deletionscore/src/main/scala/spark/rdd/CheckpointRDD.scala
- core/src/test/scala/spark/CheckpointSuite.scala 10 additions, 0 deletionscore/src/test/scala/spark/CheckpointSuite.scala
- docs/plugin-custom-receiver.md 101 additions, 0 deletionsdocs/plugin-custom-receiver.md
- docs/python-programming-guide.md 1 addition, 1 deletiondocs/python-programming-guide.md
- docs/streaming-programming-guide.md 196 additions, 54 deletionsdocs/streaming-programming-guide.md
- examples/src/main/java/spark/streaming/examples/JavaFlumeEventCount.java 0 additions, 0 deletions...in/java/spark/streaming/examples/JavaFlumeEventCount.java
- examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java 1 addition, 1 deletion...n/java/spark/streaming/examples/JavaNetworkWordCount.java
- examples/src/main/java/spark/streaming/examples/JavaQueueStream.java 0 additions, 0 deletions...c/main/java/spark/streaming/examples/JavaQueueStream.java
- examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala 158 additions, 0 deletions.../main/scala/spark/streaming/examples/ActorWordCount.scala
- examples/src/main/scala/spark/streaming/examples/KafkaWordCount.scala 20 additions, 8 deletions.../main/scala/spark/streaming/examples/KafkaWordCount.scala
- examples/src/main/scala/spark/streaming/examples/NetworkWordCount.scala 1 addition, 1 deletion...ain/scala/spark/streaming/examples/NetworkWordCount.scala
- examples/src/main/scala/spark/streaming/examples/TwitterPopularTags.scala 13 additions, 20 deletions...n/scala/spark/streaming/examples/TwitterPopularTags.scala
- examples/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala 6 additions, 7 deletions...spark/streaming/examples/clickstream/PageViewStream.scala
- examples/src/main/scala/spark/streaming/examples/twitter/StreamingHLL.scala 1 addition, 0 deletions...scala/spark/streaming/examples/twitter/StreamingHLL.scala
- project/SparkBuild.scala 3 additions, 5 deletionsproject/SparkBuild.scala
- run 3 additions, 0 deletionsrun
- streaming/src/main/scala/spark/streaming/Checkpoint.scala 46 additions, 24 deletionsstreaming/src/main/scala/spark/streaming/Checkpoint.scala
- streaming/src/main/scala/spark/streaming/DStream.scala 121 additions, 100 deletionsstreaming/src/main/scala/spark/streaming/DStream.scala
- streaming/src/main/scala/spark/streaming/DStreamCheckpointData.scala 93 additions, 0 deletions...rc/main/scala/spark/streaming/DStreamCheckpointData.scala
- streaming/src/main/scala/spark/streaming/DStreamGraph.scala 37 additions, 21 deletionsstreaming/src/main/scala/spark/streaming/DStreamGraph.scala
Loading
Please register or sign in to comment