code: public static int getParallelism(String[] args, int defaultParallelism) {
      return (args.length > 1) ? Integer.parseInt(args[1]) : defaultParallelism;
    }
docs: Fetches the topology's parallelism from the second-command-line
  argument or defers to a supplied default.