本文整理了Java中org.apache.hadoop.hive.ql.exec.Utilities.generateTarFileName()
方法的一些代码示例,展示了Utilities.generateTarFileName()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Utilities.generateTarFileName()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.exec.Utilities
类名称:Utilities
方法名:generateTarFileName
暂无
代码示例来源:origin: apache/hive
private Path getBaseDir(MapredLocalWork localWork) throws Exception {
if (ShimLoader.getHadoopShims().isLocalMode(hconf)) {
return localWork.getTmpPath();
}
Path[] localArchives = DistributedCache.getLocalCacheArchives(hconf);
if (localArchives != null) {
String stageID = localWork.getStageID();
String suffix = Utilities.generateTarFileName(stageID);
FileSystem localFs = FileSystem.getLocal(hconf);
for (Path archive : localArchives) {
if (archive.getName().endsWith(suffix)) {
return archive.makeQualified(localFs);
}
}
}
return null;
}
代码示例来源:origin: apache/drill
private Path getBaseDir(MapredLocalWork localWork) throws Exception {
if (ShimLoader.getHadoopShims().isLocalMode(hconf)) {
return localWork.getTmpPath();
}
Path[] localArchives = DistributedCache.getLocalCacheArchives(hconf);
if (localArchives != null) {
String stageID = localWork.getStageID();
String suffix = Utilities.generateTarFileName(stageID);
FileSystem localFs = FileSystem.getLocal(hconf);
for (int j = 0; j < localArchives.length; j++) {
Path archive = localArchives[j];
if (!archive.getName().endsWith(suffix)) {
continue;
}
return archive.makeQualified(localFs);
}
}
return null;
}
代码示例来源:origin: apache/hive
String archiveFileName = Utilities.generateTarFileName(stageId);
localwork.setStageID(stageId);
代码示例来源:origin: apache/drill
String archiveFileName = Utilities.generateTarFileName(stageId);
localwork.setStageID(stageId);
代码示例来源:origin: com.facebook.presto.hive/hive-apache
private Path getBaseDir(MapredLocalWork localWork) throws Exception {
if (ShimLoader.getHadoopShims().isLocalMode(hconf)) {
return localWork.getTmpPath();
}
Path[] localArchives = DistributedCache.getLocalCacheArchives(hconf);
if (localArchives != null) {
String stageID = localWork.getStageID();
String suffix = Utilities.generateTarFileName(stageID);
FileSystem localFs = FileSystem.getLocal(hconf);
for (int j = 0; j < localArchives.length; j++) {
Path archive = localArchives[j];
if (!archive.getName().endsWith(suffix)) {
continue;
}
return archive.makeQualified(localFs);
}
}
return null;
}
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
Path[] localArchives;
String stageID = this.getExecContext().getLocalWork().getStageID();
String suffix = Utilities.generateTarFileName(stageID);
FileSystem localFs = FileSystem.getLocal(hconf);
localArchives = DistributedCache.getLocalCacheArchives(this.hconf);
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
String stageId = this.getId();
String archiveFileURI = Utilities.generateTarURI(parentDir, stageId);
String archiveFileName = Utilities.generateTarFileName(stageId);
localwork.setStageID(stageId);
代码示例来源:origin: com.facebook.presto.hive/hive-apache
String archiveFileName = Utilities.generateTarFileName(stageId);
localwork.setStageID(stageId);
内容来源于网络,如有侵权,请联系作者删除!