public static void initializeAndStartThread(CompactorThread thread, Configuration conf) {
    LOG.info("Starting compactor thread of type " + thread.getClass().getName());
    thread.setConf(conf);
    try {
      thread.init(new AtomicBoolean());
    } catch (Exception e) {
      throw new CompactionException(e, ErrorMsg.COMPACTION_THREAD_INITIALIZATION);
    }
    thread.start();
  }
Get the partition being compacted.
@param ci compaction info returned from the compaction queue
@return metastore partition, or null if there is not partition in this compaction info
@throws MetaException if underlying calls throw, or if the partition name resolves to more than
one partition.
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorThread.java