private void runOneLoopOfCompactorThread(CompactorThreadType type) throws Exception {
    TestTxnDbUtil.setConfValues(conf);
    CompactorThread t;
    switch (type) {
      case INITIATOR: t = new Initiator(); break;
      case WORKER: t = new Worker(); break;
      case CLEANER: t = new Cleaner(); break;
      default: throw new RuntimeException("Huh? Unknown thread type.");
    }
    t.setConf(conf);
    stop.set(true);
    t.init(stop);
    t.run();
  }
Super class for all of the compactor test modules.
ql/src/test/org/apache/hadoop/hive/ql/txn/compactor/CompactorTest.java