/spark mirrored from git://git.apache.org/spark.git

Switch branches/tags
Nothing to show
Find file History
spark/examples/src/main/scala/org/apache/spark/examples/streaming/
Latest commit a0eec8e Jun 2, 2016 @lw-lin lw-lin committed with srowen [SPARK-15208][WIP][CORE][STREAMING][DOCS] Update Spark examples with … 
…AccumulatorV2

## What changes were proposed in this pull request?

The patch updates the codes & docs in the example module as well as the related doc module:

- [ ] [docs] `streaming-programming-guide.md`
  - [x] scala code part
  - [ ] java code part
  - [ ] python code part
- [x] [examples] `RecoverableNetworkWordCount.scala`
- [ ] [examples] `JavaRecoverableNetworkWordCount.java`
- [ ] [examples] `recoverable_network_wordcount.py`

## How was this patch tested?

Ran the examples and verified results manually.

Author: Liwei Lin <lwlin7@gmail.com>

Closes #12981 from lw-lin/accumulatorV2-examples.
Permalink
..
Failed to load latest commit information.
clickstream [MINOR][DOCS] Use multi-line JavaDoc comments in Scala code. Apr 3, 2016
CustomReceiver.scala [SPARK-15645][STREAMING] Fix some typos of Streaming module May 30, 2016
DirectKafkaWordCount.scala [SPARK-7977] [BUILD] Disallowing println Jul 10, 2015
FlumeEventCount.scala [SPARK-14073][STREAMING][TEST-MAVEN] Move flume back to Spark Mar 26, 2016
FlumePollingEventCount.scala [SPARK-14073][STREAMING][TEST-MAVEN] Move flume back to Spark Mar 26, 2016
HdfsWordCount.scala [SPARK-7977] [BUILD] Disallowing println Jul 10, 2015
KafkaWordCount.scala [SPARK-3873][EXAMPLES] Import ordering fixes. Jan 5, 2016
NetworkWordCount.scala [SPARK-3873][EXAMPLES] Import ordering fixes. Jan 5, 2016
QueueStream.scala [SPARK-15645][STREAMING] Fix some typos of Streaming module May 30, 2016
RawNetworkGrep.scala [SPARK-7977] [BUILD] Disallowing println Jul 10, 2015
RecoverableNetworkWordCount.scala [SPARK-15208][WIP][CORE][STREAMING][DOCS] Update Spark examples with … Jun 2, 2016
SqlNetworkWordCount.scala [SPARK-15171][SQL] Remove the references to deprecated method dataset… May 18, 2016
StatefulNetworkWordCount.scala [SPARK-13583][CORE][STREAMING] Remove unused imports and add checksty… Mar 3, 2016
StreamingExamples.scala [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.int… Mar 17, 2016