diff options
author | Rohan Bhanderi <rohan.bhanderi@sjsu.edu> | 2015-11-17 15:45:39 -0800 |
---|---|---|
committer | Andrew Or <andrew@databricks.com> | 2015-11-17 15:45:46 -0800 |
commit | e29656f8e7fa19686b448292e20d8bbf07ab9f11 (patch) | |
tree | f71b4bc365b235aa34a153ee6b578010d2446981 /examples | |
parent | 965245d087c18edc6c3d5baddeaf83163e32e330 (diff) | |
download | spark-e29656f8e7fa19686b448292e20d8bbf07ab9f11.tar.gz spark-e29656f8e7fa19686b448292e20d8bbf07ab9f11.tar.bz2 spark-e29656f8e7fa19686b448292e20d8bbf07ab9f11.zip |
[MINOR] Correct comments in JavaDirectKafkaWordCount
Author: Rohan Bhanderi <rohan.bhanderi@sjsu.edu>
Closes #9781 from RohanBhanderi/patch-3.
Diffstat (limited to 'examples')
-rw-r--r-- | examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java b/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java index bab9f2478e..f9a5e7f69f 100644 --- a/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java +++ b/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java @@ -35,12 +35,12 @@ import org.apache.spark.streaming.Durations; /** * Consumes messages from one or more topics in Kafka and does wordcount. - * Usage: DirectKafkaWordCount <brokers> <topics> + * Usage: JavaDirectKafkaWordCount <brokers> <topics> * <brokers> is a list of one or more Kafka brokers * <topics> is a list of one or more kafka topics to consume from * * Example: - * $ bin/run-example streaming.KafkaWordCount broker1-host:port,broker2-host:port topic1,topic2 + * $ bin/run-example streaming.JavaDirectKafkaWordCount broker1-host:port,broker2-host:port topic1,topic2 */ public final class JavaDirectKafkaWordCount { @@ -48,7 +48,7 @@ public final class JavaDirectKafkaWordCount { public static void main(String[] args) { if (args.length < 2) { - System.err.println("Usage: DirectKafkaWordCount <brokers> <topics>\n" + + System.err.println("Usage: JavaDirectKafkaWordCount <brokers> <topics>\n" + " <brokers> is a list of one or more Kafka brokers\n" + " <topics> is a list of one or more kafka topics to consume from\n\n"); System.exit(1); @@ -59,7 +59,7 @@ public final class JavaDirectKafkaWordCount { String brokers = args[0]; String topics = args[1]; - // Create context with 2 second batch interval + // Create context with a 2 seconds batch interval SparkConf sparkConf = new SparkConf().setAppName("JavaDirectKafkaWordCount"); JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, Durations.seconds(2)); |