in src/main/java/com/aliyun/emr/example/storm/benchmark/TridentWordCount.java [89:102]
public static void main(String[] args) throws Exception {
TridentWordCount wordCount = new TridentWordCount();
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.TridentWordCount benchmark.properties --property k1=v1,k2=v2");
System.exit(1);
}
wordCount.init(args[0], args[2]);
} else {
wordCount.init(args[0]);
}
wordCount.run(true);
}