-
- Downloads
[SPARK-12429][STREAMING][DOC] Add Accumulator and Broadcast example for Streaming
This PR adds Scala, Java and Python examples to show how to use Accumulator and Broadcast in Spark Streaming to support checkpointing. Author: Shixiong Zhu <shixiong@databricks.com> Closes #10385 from zsxwing/accumulator-broadcast-example.
Showing
- docs/programming-guide.md 3 additions, 3 deletionsdocs/programming-guide.md
- docs/streaming-programming-guide.md 165 additions, 0 deletionsdocs/streaming-programming-guide.md
- examples/src/main/java/org/apache/spark/examples/streaming/JavaRecoverableNetworkWordCount.java 67 additions, 4 deletions...k/examples/streaming/JavaRecoverableNetworkWordCount.java
- examples/src/main/python/streaming/recoverable_network_wordcount.py 29 additions, 1 deletion...rc/main/python/streaming/recoverable_network_wordcount.py
- examples/src/main/scala/org/apache/spark/examples/streaming/RecoverableNetworkWordCount.scala 61 additions, 5 deletions...park/examples/streaming/RecoverableNetworkWordCount.scala
Loading
Please register or sign in to comment