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:57 -0800 |
commit | ca3fe8c127d1153fd575c44b950f7620e5db8737 (patch) | |
tree | 7fd5e50588b6033c3f599808c3f27bf34dcfaf0b /bagel | |
parent | 69dd2997fb84375fc57a597e3ac43e717b40011c (diff) | |
download | spark-ca3fe8c127d1153fd575c44b950f7620e5db8737.tar.gz spark-ca3fe8c127d1153fd575c44b950f7620e5db8737.tar.bz2 spark-ca3fe8c127d1153fd575c44b950f7620e5db8737.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
(cherry picked from commit 3a02d416cd82a7a942fd6ff4a0e05ff070eb218a)
Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
Diffstat (limited to 'bagel')
0 files changed, 0 insertions, 0 deletions