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

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

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

Utilities.join介绍

暂无

代码示例

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

private String getAggregationPrefix0(Table table, Partition partition) throws MetaException {
 // prefix is of the form dbName.tblName
 String prefix = table.getDbName() + "." + MetaStoreUtils.encodeTableName(table.getTableName());
 // FIXME: this is a secret contract; reusein getAggrKey() creates a more closer relation to the StatsGatherer
 // prefix = work.getAggKey();
 prefix = prefix.toLowerCase();
 if (partition != null) {
  return Utilities.join(prefix, Warehouse.makePartPath(partition.getSpec()));
 }
 return prefix;
}

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

private String getAggregationPrefix(Table table, Partition partition)
  throws MetaException {
 // prefix is of the form dbName.tblName
 String prefix = table.getDbName() + "." + MetaStoreUtils.encodeTableName(table.getTableName());
 if (partition != null) {
  return Utilities.join(prefix, Warehouse.makePartPath(partition.getSpec()));
 }
 return prefix;
}

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

String prefix = Utilities.join(conf.getStatsAggPrefix(), pspecs);

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

String prefix = Utilities.join(conf.getStatsAggPrefix(), pspecs);

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

prefix = Utilities.join(prefix, spSpec, dpSpec);
prefix = prefix.endsWith(Path.SEPARATOR) ? prefix : prefix + Path.SEPARATOR;
if (Utilities.FILE_OP_LOGGER.isTraceEnabled()) {

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

prefix = Utilities.join(prefix, spSpec, dpSpec);
prefix = prefix.endsWith(Path.SEPARATOR) ? prefix : prefix + Path.SEPARATOR;

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

private String getAggregationPrefix(boolean counter, Table table, Partition partition)
  throws MetaException {
 if (!counter && partition == null) {
  return work.getAggKey();
 }
 StringBuilder prefix = new StringBuilder();
 if (counter) {
  // prefix is of the form dbName.tblName
  prefix.append(table.getDbName()).append('.').append(table.getTableName());
 } else {
  // In case of a non-partitioned table, the key for stats temporary store is "rootDir"
  prefix.append(work.getAggKey());
 }
 if (partition != null) {
  return Utilities.join(prefix.toString(), Warehouse.makePartPath(partition.getSpec()));
 }
 return prefix.toString();
}

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

private List<String> getRequiredCounterPrefix(StatsTask statsTask) throws HiveException, MetaException {
 List<String> prefixs = new LinkedList<String>();
 StatsWork statsWork = statsTask.getWork();
 String tablePrefix = getTablePrefix(statsWork);
 List<Map<String, String>> partitionSpecs = getPartitionSpecs(statsWork);
 int maxPrefixLength = StatsFactory.getMaxPrefixLength(conf);
 if (partitionSpecs == null) {
  prefixs.add(Utilities.getHashedStatsPrefix(tablePrefix, maxPrefixLength));
 } else {
  for (Map<String, String> partitionSpec : partitionSpecs) {
   String prefixWithPartition = Utilities.join(tablePrefix, Warehouse.makePartPath(partitionSpec));
   prefixs.add(Utilities.getHashedStatsPrefix(prefixWithPartition, maxPrefixLength));
  }
 }
 return prefixs;
}

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

String prefix = Utilities.join(conf.getStatsAggPrefix(), pspecs);
if (!(statsPublisher instanceof StatsCollectionTaskIndependent)) {
 key = Utilities.join(prefix, taskID);

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

postfix = Utilities.join(lbSpec, taskID);
prefix = Utilities.join(prefix, spSpec, dpSpec);
prefix = Utilities.getHashedStatsPrefix(prefix, maxKeyLength);
String key = Utilities.join(prefix, postfix);

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

if (!(statsPublisher instanceof CounterStatsPublisher)) {
 String taskID = Utilities.getTaskIdFromFilename(Utilities.getTaskId(jc));
 key = Utilities.join(key, taskID);

相关文章

微信公众号

最新文章

更多

Utilities类方法