public int runRandomInputGenerator(int numMappers, long numNodes, Path tmpOutput, Integer width,
      Integer wrapMultiplier, Integer numWalkers) throws Exception {
      LOG.info(
        "Running RandomInputGenerator with numMappers=" + numMappers + ", numNodes=" + numNodes);
      Job job = Job.getInstance(getConf());

      job.setJobName("Random Input Generator");
      job.setNumReduceTasks(0);
      job.setJarByClass(getClass());

      job.setInputFormatClass(GeneratorInputFormat.class);
      job.setOutputKeyClass(BytesWritable.class);
      job.setOutputValueClass(NullWritable.class);

      setJobConf(job, numMappers, numNodes, width, wrapMultiplier, numWalkers);

      job.setMapperClass(Mapper.class); // identity mapper

      FileOutputFormat.setOutputPath(job, tmpOutput);
      job.setOutputFormatClass(SequenceFileOutputFormat.class);
      TableMapReduceUtil.addDependencyJarsForClasses(job.getConfiguration(), Random64.class);

      boolean success = jobCompletion(job);

      return success ? 0 : 1;
    }
Randomly selects and walks a random flushed loop concurrently with the Generator Mapper by
spawning ConcurrentWalker's with specified StartNodes. These ConcurrentWalker's are
configured to only log erroneous nodes.
hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java