spark git commit: SPARK-2548 [STREAMING] JavaRecoverableWordCount is missing

2014-11-10 Thread tdas
Repository: spark Updated Branches: refs/heads/master ed8bf1eac -> 3a02d416c 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

spark git commit: SPARK-2548 [STREAMING] JavaRecoverableWordCount is missing

2014-11-10 Thread tdas
Repository: spark Updated Branches: refs/heads/branch-1.2 69dd2997f -> ca3fe8c12 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/formatt

spark git commit: SPARK-2548 [STREAMING] JavaRecoverableWordCount is missing

2014-11-10 Thread tdas
Repository: spark Updated Branches: refs/heads/branch-1.1 dc38defd2 -> cdcf5467a 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/formatt