org.apache.hadoop.hive.ql.exec.Utilities.getStatsTmpDirs()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(2.6k)|赞(0)|评价(0)|浏览(86)

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

Utilities.getStatsTmpDirs介绍

暂无

代码示例

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

private void initStatsPublisher(BaseWork work) throws HiveException {
  // initialize stats publisher if necessary
  if (work.isGatheringStats()) {
   StatsPublisher statsPublisher;
   StatsFactory factory = StatsFactory.newFactory(jobConf);
   if (factory != null) {
    statsPublisher = factory.getStatsPublisher();
    StatsCollectionContext sc = new StatsCollectionContext(jobConf);
    sc.setStatsTmpDirs(Utilities.getStatsTmpDirs(work, jobConf));
    if (!statsPublisher.init(sc)) { // creating stats table if not exists
     if (HiveConf.getBoolVar(jobConf, HiveConf.ConfVars.HIVE_STATS_RELIABLE)) {
      throw new HiveException(
        ErrorMsg.STATSPUBLISHER_INITIALIZATION_ERROR.getErrorCodedMsg());
     }
    }
   }
  }
 }
}

代码示例来源:origin: apache/drill

private void initStatsPublisher(BaseWork work) throws HiveException {
 // initialize stats publisher if necessary
 if (work.isGatheringStats()) {
  StatsPublisher statsPublisher;
  StatsFactory factory = StatsFactory.newFactory(jobConf);
  if (factory != null) {
   statsPublisher = factory.getStatsPublisher();
   StatsCollectionContext sc = new StatsCollectionContext(jobConf);
   sc.setStatsTmpDirs(Utilities.getStatsTmpDirs(work, jobConf));
   if (!statsPublisher.init(sc)) { // creating stats table if not exists
    if (HiveConf.getBoolVar(jobConf, HiveConf.ConfVars.HIVE_STATS_RELIABLE)) {
     throw new HiveException(
       ErrorMsg.STATSPUBLISHER_INITIALIZATION_ERROR.getErrorCodedMsg());
    }
   }
  }
 }
}

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

if (factory != null) {
 statsPublisher = factory.getStatsPublisher();
 List<String> statsTmpDir = Utilities.getStatsTmpDirs(mWork, job);
 if (rWork != null) {
  statsTmpDir.addAll(Utilities.getStatsTmpDirs(rWork, job));

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

if (factory != null) {
 StatsCollectionContext sCntxt = new StatsCollectionContext(conf);
 sCntxt.setStatsTmpDirs(Utilities.getStatsTmpDirs(work, conf));
 statsPublisher = factory.getStatsPublisher();
 if (!statsPublisher.init(sCntxt)) { // creating stats table if not exists

代码示例来源:origin: apache/drill

if (factory != null) {
 statsPublisher = factory.getStatsPublisher();
 List<String> statsTmpDir = Utilities.getStatsTmpDirs(mWork, job);
 if (rWork != null) {
  statsTmpDir.addAll(Utilities.getStatsTmpDirs(rWork, job));

代码示例来源:origin: apache/drill

if (factory != null) {
 StatsCollectionContext sCntxt = new StatsCollectionContext(conf);
 sCntxt.setStatsTmpDirs(Utilities.getStatsTmpDirs(work, conf));
 statsPublisher = factory.getStatsPublisher();
 if (!statsPublisher.init(sCntxt)) { // creating stats table if not exists

相关文章

微信公众号

最新文章

更多

Utilities类方法