File tree Expand file tree Collapse file tree 2 files changed +0
-20
lines changed
java/org/apache/spark/examples/streaming
scala/org/apache/spark/examples/streaming Expand file tree Collapse file tree 2 files changed +0
-20
lines changed Original file line number Diff line number Diff line change 6464 * checkpoint data exists in ~/checkpoint/, then it will create StreamingContext from
6565 * the checkpoint data.
6666 *
67- * To run this example in a local standalone cluster with automatic driver recovery,
68- *
69- * `$ bin/spark-class org.apache.spark.deploy.Client -s launch <cluster-url> \
70- * <path-to-examples-jar> \
71- * org.apache.spark.examples.streaming.JavaRecoverableNetworkWordCount <cluster-url> \
72- * localhost 9999 ~/checkpoint ~/out`
73- *
74- * <path-to-examples-jar> would typically be
75- * <spark-dir>/examples/target/scala-XX/spark-examples....jar
76- *
7767 * Refer to the online documentation for more details.
7868 */
7969public final class JavaRecoverableNetworkWordCount {
Original file line number Diff line number Diff line change @@ -52,16 +52,6 @@ import org.apache.spark.util.IntParam
5252 * checkpoint data exists in ~/checkpoint/, then it will create StreamingContext from
5353 * the checkpoint data.
5454 *
55- * To run this example in a local standalone cluster with automatic driver recovery,
56- *
57- * `$ bin/spark-class org.apache.spark.deploy.Client -s launch <cluster-url> \
58- * <path-to-examples-jar> \
59- * org.apache.spark.examples.streaming.RecoverableNetworkWordCount <cluster-url> \
60- * localhost 9999 ~/checkpoint ~/out`
61- *
62- * <path-to-examples-jar> would typically be
63- * <spark-dir>/examples/target/scala-XX/spark-examples....jar
64- *
6555 * Refer to the online documentation for more details.
6656 */
6757object RecoverableNetworkWordCount {
You can’t perform that action at this time.
0 commit comments