public int run()

in stresso/src/main/java/stresso/trie/Load.java [52:85]

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

  public int run(String[] args) throws Exception {

    if (args.length != 3) {
      log.error(
          "Usage: " + this.getClass().getSimpleName() + "<fluo conn props> <app name> <input dir>");
      System.exit(-1);
    }

    FluoConfiguration props = new FluoConfiguration(new File(args[0]));
    props.setApplicationName(args[1]);
    final Path input = new Path(args[2]);

    Job job = Job.getInstance(getConf());

    job.setJobName(Load.class.getName());

    job.setJarByClass(Load.class);

    job.setInputFormatClass(SequenceFileInputFormat.class);
    SequenceFileInputFormat.addInputPath(job, input);

    job.setMapperClass(LoadMapper.class);

    job.setNumReduceTasks(0);

    job.setOutputFormatClass(FluoOutputFormat.class);
    FluoOutputFormat.configure(job, props);

    job.getConfiguration().setBoolean("mapreduce.map.speculative", false);
    job.getConfiguration().set("mapreduce.job.classloader", "true");

    boolean success = job.waitForCompletion(true);
    return success ? 0 : 1;
  }