static void parseCommandLineQuery()

in opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/CliQuery.java [42:119]
70 lines of code
28 McCabe index (conditional complexity)

    static void parseCommandLineQuery(final String[] args,
                                      final TSDB tsdb,
                                      final ArrayList<Query> queries) {
        long start_ts = DateTime.parseDateTimeString(args[0], null);
        if (start_ts >= 0) {
            start_ts /= 1000;
        }
        long end_ts = -1;
        if (args.length > 3) {
            // see if we can detect an end time
            try {
                if (args[1].charAt(0) != '+' && (args[1].indexOf(':') >= 0
                        || args[1].indexOf('/') >= 0 || args[1].indexOf('-') >= 0
                        || Long.parseLong(args[1]) > 0)) {
                    end_ts = DateTime.parseDateTimeString(args[1], null);
                }
            } catch (NumberFormatException ignore) {
                // ignore it as it means the third parameter is likely the aggregator
            }
        }
        // temp fixup to seconds from ms until the rest of TSDB supports ms
        // Note you can't append this to the DateTime.parseDateTimeString() call as
        // it clobbers -1 results
        if (end_ts >= 0) {
            end_ts /= 1000;
        }

        int i = end_ts < 0 ? 1 : 2;
        while (i < args.length && args[i].charAt(0) == '+') {
            i++;
        }

        while (i < args.length) {
            final Aggregator agg = Aggregators.get(args[i++]);
            final boolean rate = "rate".equals(args[i]);
            RateOptions rate_options = new RateOptions(false, Long.MAX_VALUE,
                    RateOptions.DEFAULT_RESET_VALUE);
            if (rate) {
                i++;

                long counterMax = Long.MAX_VALUE;
                long resetValue = RateOptions.DEFAULT_RESET_VALUE;
                if (args[i].startsWith("counter")) {
                    String[] parts = Tags.splitString(args[i], ',');
                    if (parts.length >= 2 && parts[1].length() > 0) {
                        counterMax = Long.parseLong(parts[1]);
                    }
                    if (parts.length >= 3 && parts[2].length() > 0) {
                        resetValue = Long.parseLong(parts[2]);
                    }
                    rate_options = new RateOptions(true, counterMax, resetValue);
                    i++;
                }
            }
            final boolean downsample = "downsample".equals(args[i]);
            if (downsample) {
                i++;
            }
            final long interval = downsample ? Long.parseLong(args[i++]) : 0;
            final Aggregator sampler = downsample ? Aggregators.get(args[i++]) : null;
            final String metric = args[i++];
            final HashMap<String, String> tags = new HashMap<String, String>();
            while (i < args.length && args[i].indexOf(' ', 1) < 0
                    && args[i].indexOf('=', 1) > 0) {
                Tags.parse(tags, args[i++]);
            }
            final Query query = tsdb.newQuery();
            query.setStartTime(start_ts);
            if (end_ts > 0) {
                query.setEndTime(end_ts);
            }
            query.setTimeSeries(metric, tags, agg, rate, rate_options);
            if (downsample) {
                query.downsample(interval, sampler);
            }
            queries.add(query);
        }
    }