public static void main()

in src/main/java/com/aliyun/emr/example/storm/benchmark/KafkaHdfs.java [42:56]

• 14 lines of code
• 3 McCabe index (conditional complexity)

    public static void main(String[] args) throws Exception {
        KafkaHdfs topology = new KafkaHdfs();
        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.KafkaHdfs benchmark.properties --property k1=v1,k2=v2");
                System.exit(1);
            }
            topology.init(args[0], args[2]);
        } else {
            topology.init(args[0]);
        }

        topology.run(true);
    }