public void go() {
    LOG.info("Running ReporterTask every " + notificationInterval
        + " miliseconds.");
    rpTimer = new Timer(true);


    ReporterTask rt = new ReporterTask(reporter);
    rpTimer.scheduleAtFixedRate(rt, 0, notificationInterval);

    if (timeout > 0) {
      srpTimer = new Timer(true);
      StopReporterTimerTask srt = new StopReporterTimerTask(rt);
      srpTimer.schedule(srt, timeout);
    }
  }
@param logClassName
@param reporter
@param notificationInterval - interval for reporter updates (in ms)
@param timeout - when the autoprogressor should stop reporting (in ms)
ql/src/java/org/apache/hadoop/hive/ql/exec/AutoProgressor.java