You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/05/14 17:40:02 UTC
[3/8] git commit: Update PrintSampleStream.java
Update PrintSampleStream.java
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/8785f491
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/8785f491
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/8785f491
Branch: refs/heads/master
Commit: 8785f491bab0c3a43d472e1e5250415aee6e287b
Parents: aa06472
Author: Prabeesh K <pr...@gmail.com>
Authored: Thu May 8 10:00:40 2014 +0530
Committer: Prabeesh K <pr...@gmail.com>
Committed: Thu May 8 10:00:40 2014 +0530
----------------------------------------------------------------------
.../src/jvm/storm/starter/PrintSampleStream.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/8785f491/examples/storm-starter/src/jvm/storm/starter/PrintSampleStream.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/src/jvm/storm/starter/PrintSampleStream.java b/examples/storm-starter/src/jvm/storm/starter/PrintSampleStream.java
index de70850..81c1dee 100644
--- a/examples/storm-starter/src/jvm/storm/starter/PrintSampleStream.java
+++ b/examples/storm-starter/src/jvm/storm/starter/PrintSampleStream.java
@@ -21,13 +21,15 @@
package storm.starter;
-import storm.starter.spout.TwitterSampleSpout;
+import java.util.Arrays;
+
import backtype.storm.Config;
import backtype.storm.LocalCluster;
import backtype.storm.topology.TopologyBuilder;
import backtype.storm.utils.Utils;
-import storm.starter.bolt.PrinterBolt;
+import storm.starter.bolt.PrinterBolt;
+import storm.starter.spout.TwitterSampleSpout;
public class PrintSampleStream {
public static void main(String[] args) {
@@ -35,6 +37,7 @@ public class PrintSampleStream {
String consumerSecret = args[1];
String accessToken = args[2];
String accessTokenSecret = args[3];
+ String[] arguments = args.clone();
String[] keyWords = Arrays.copyOfRange(arguments, 4, arguments.length);
TopologyBuilder builder = new TopologyBuilder();