in src/main/java/com/aliyun/emr/example/storm/benchmark/WindowedWordCount.java [81:94]
public static void main(String[] args) throws Exception {
WindowedWordCount wordCount = new WindowedWordCount();
if (args.length > 1) {
if (!"--property".equals(args[1])) {
System.out.println("unknow option: " + args[1]);
System.out.println("usage storm jar examples-1.1-shaded.jar com.aliyun.emr.example.storm.benchmark.WindowedWordCount benchmark.properties --property k1=v1,k2=v2");
System.exit(1);
}
wordCount.init(args[0], args[2]);
} else {
wordCount.init(args[0]);
}
wordCount.run(true);
}