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

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

本文整理了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

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);

相关文章

微信公众号

最新文章

更多

Utilities类方法