@Override
  public void init(AtomicBoolean stop) throws Exception {
    super.init(stop);
    SLEEP_TIME = conf.getTimeVar(HiveConf.ConfVars.HIVE_COMPACTOR_WORKER_SLEEP_TIME, TimeUnit.MILLISECONDS);
    SLEEP_TIME_MAX = conf.getTimeVar(HiveConf.ConfVars.HIVE_COMPACTOR_WORKER_MAX_SLEEP_TIME, TimeUnit.MILLISECONDS);
    this.workerName = getWorkerId();
    setName(workerName);
  }
A class to do compactions.  This will run in a separate thread.  It will spin on the
compaction queue and look for new work to do.
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java