本文整理了Java中org.apache.hadoop.hive.ql.txn.compactor.Worker.init()方法的一些代码示例，展示了Worker.init()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Worker.init()方法的具体详情如下：
包路径：org.apache.hadoop.hive.ql.txn.compactor.Worker
类名称：Worker
方法名：init

Worker.init介绍

暂无

代码示例

代码示例来源：origin: apache/hive

private static void runWorker(HiveConf hiveConf) throws MetaException {
 AtomicBoolean stop = new AtomicBoolean(true);
 Worker t = new Worker();
 t.setThreadId((int) t.getId());
 t.setHiveConf(hiveConf);
 AtomicBoolean looped = new AtomicBoolean();
 t.init(stop, looped);
 t.run();
}

代码示例来源：origin: apache/hive

/**
 * this is a clone from TestHiveStreamingConnection.TxnStatement2....
 */
public static void runWorker(HiveConf hiveConf) throws Exception {
 AtomicBoolean stop = new AtomicBoolean(true);
 Worker t = new Worker();
 t.setThreadId((int) t.getId());
 t.setConf(hiveConf);
 AtomicBoolean looped = new AtomicBoolean();
 t.init(stop, looped);
 t.run();
}

代码示例来源：origin: apache/hive

/**
 * this is a clone from TestTxnStatement2....
 */
public static void runWorker(HiveConf hiveConf) throws Exception {
 AtomicBoolean stop = new AtomicBoolean(true);
 Worker t = new Worker();
 t.setThreadId((int) t.getId());
 t.setConf(hiveConf);
 AtomicBoolean looped = new AtomicBoolean();
 t.init(stop, looped);
 t.run();
}