本文整理了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
暂无
代码示例来源: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);
内容来源于网络,如有侵权,请联系作者删除!