public Path genInput()

in source/benchmark-sample/tpcds-gen/src/main/java/org/notmysock/tpcds/GenTable.java [132:147]

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

    public Path genInput(String table, int scale, int parallel) throws Exception {
        long epoch = System.currentTimeMillis()/1000;

        Path in = new Path("/tmp/"+table+"_"+scale+"-"+epoch);
        FileSystem fs = FileSystem.get(getConf());
        FSDataOutputStream out = fs.create(in);
        for(int i = 1; i <= parallel; i++) {
          if(table.equals("all")) {
            out.writeBytes(String.format("./dsdgen -dir $DIR -force Y -scale %d -parallel %d -child %d\n", scale, parallel, i));
          } else {
            out.writeBytes(String.format("./dsdgen -dir $DIR -table %s -force Y -scale %d -parallel %d -child %d\n", table, scale, parallel, i));
          }
        }
        out.close();
        return in;
    }