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

Utilities.getStatsPublisher介绍

暂无

代码示例

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

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);
StatsCollectionContext sc = new StatsCollectionContext(jc);
sc.setStatsTmpDir(conf.getTmpStatsDir());

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

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);

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

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);
StatsCollectionContext sc = new StatsCollectionContext(jc);
sc.setStatsTmpDir(conf.getTmpStatsDir());

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

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);

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

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);

代码示例来源：origin: org.apache.hadoop.hive/hive-exec

private void publishStats() {
  // Initializing a stats publisher
  StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);
  if (!statsPublisher.connect(jc)) {
   // just return, stats gathering should not block the main query.
   LOG.info("StatsPublishing error: cannot connect to database.");
   return;
  }

  String key;
  String taskID = Utilities.getTaskIdFromFilename(Utilities.getTaskId(hconf));
  if (partitionSpecs.isEmpty()) {
   // In case of a non-partitioned table, the key for temp storage is just
   // "tableName + taskID"
   key = conf.getStatsAggPrefix() + taskID;
  } else {
   // In case of a partition, the key for temp storage is
   // "tableName + partitionSpecs + taskID"
   key = conf.getStatsAggPrefix() + partitionSpecs + Path.SEPARATOR + taskID;
  }
  statsPublisher.publishStat(key, StatsSetupConst.ROW_COUNT, Long.toString(stat.getNumRows()));
  statsPublisher.closeConnection();
 }
}

代码示例来源：origin: org.apache.hadoop.hive/hive-exec

private void publishStats() {
 StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);

代码示例来源：origin: com.facebook.presto.hive/hive-apache

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);
if (!statsPublisher.connect(jc)) {

代码示例来源：origin: com.facebook.presto.hive/hive-apache

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);

代码示例来源：origin: com.facebook.presto.hive/hive-apache

StatsPublisher statsPublisher = Utilities.getStatsPublisher(jc);