diff options
| author | Sean Owen <sowen@cloudera.com> | 2014-11-10 11:47:27 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-11-10 11:47:27 -0800 |
| commit | 3a02d416cd82a7a942fd6ff4a0e05ff070eb218a (patch) | |
| tree | 7fd5e50588b6033c3f599808c3f27bf34dcfaf0b /sbt | |
| parent | ed8bf1eac548577c4bbad7ce3f7f301a2f52ef17 (diff) | |
| download | spark-3a02d416cd82a7a942fd6ff4a0e05ff070eb218a.tar.gz spark-3a02d416cd82a7a942fd6ff4a0e05ff070eb218a.tar.bz2 spark-3a02d416cd82a7a942fd6ff4a0e05ff070eb218a.zip | |
SPARK-2548 [STREAMING] JavaRecoverableWordCount is missing
Here's my attempt to re-port `RecoverableNetworkWordCount` to Java, following the example of its Scala and Java siblings. I fixed a few minor doc/formatting issues along the way I believe.
Author: Sean Owen <sowen@cloudera.com>
Closes #2564 from srowen/SPARK-2548 and squashes the following commits:
0d0bf29 [Sean Owen] Update checkpoint call as in https://github.com/apache/spark/pull/2735
35f23e3 [Sean Owen] Remove old comment about running in standalone mode
179b3c2 [Sean Owen] Re-port RecoverableNetworkWordCount to Java example, and touch up doc / formatting in related examples
Diffstat (limited to 'sbt')
0 files changed, 0 insertions, 0 deletions