public boolean reduceStarted() {
    return this.jobExecHelper.reduceStarted();
  }
Set hive input format, and input format file if necessary.
ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java