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