Repository: spark Updated Branches: refs/heads/master 965245d08 -> e29656f8e
[MINOR] Correct comments in JavaDirectKafkaWordCount Author: Rohan Bhanderi <[email protected]> Closes #9781 from RohanBhanderi/patch-3. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e29656f8 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e29656f8 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e29656f8 Branch: refs/heads/master Commit: e29656f8e7fa19686b448292e20d8bbf07ab9f11 Parents: 965245d Author: Rohan Bhanderi <[email protected]> Authored: Tue Nov 17 15:45:39 2015 -0800 Committer: Andrew Or <[email protected]> Committed: Tue Nov 17 15:45:46 2015 -0800 ---------------------------------------------------------------------- .../spark/examples/streaming/JavaDirectKafkaWordCount.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/e29656f8/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java ---------------------------------------------------------------------- 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 bab9f24..f9a5e7f 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)); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
