org.apache.hadoop.fs.FileUtil.checkDest()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(110)

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

FileUtil.checkDest介绍

暂无

代码示例

代码示例来源:origin: org.apache.hadoop/hadoop-common

private static Path checkDest(String srcName, FileSystem dstFS, Path dst,
  boolean overwrite) throws IOException {
 FileStatus sdst;
 try {
  sdst = dstFS.getFileStatus(dst);
 } catch (FileNotFoundException e) {
  sdst = null;
 }
 if (null != sdst) {
  if (sdst.isDirectory()) {
   if (null == srcName) {
    throw new PathIsDirectoryException(dst.toString());
   }
   return checkDest(null, dstFS, new Path(dst, srcName), overwrite);
  } else if (!overwrite) {
   throw new PathExistsException(dst.toString(),
     "Target " + dst + " already exists");
  }
 }
 return dst;
}

代码示例来源:origin: org.apache.hadoop/hadoop-common

Configuration conf) throws IOException {
Path src = srcStatus.getPath();
dst = checkDest(src.getName(), dstFS, dst, overwrite);
if (srcStatus.isDirectory()) {
 checkDependencies(srcFS, src, dstFS, dst);

代码示例来源:origin: org.apache.hadoop/hadoop-common

boolean deleteSource,
             Configuration conf) throws IOException {
dst = checkDest(src.getName(), dstFS, dst, false);

代码示例来源:origin: io.hops/hadoop-common

private static Path checkDest(String srcName, FileSystem dstFS, Path dst,
  boolean overwrite) throws IOException {
 if (dstFS.exists(dst)) {
  FileStatus sdst = dstFS.getFileStatus(dst);
  if (sdst.isDirectory()) {
   if (null == srcName) {
    throw new IOException("Target " + dst + " is a directory");
   }
   return checkDest(null, dstFS, new Path(dst, srcName), overwrite);
  } else if (!overwrite) {
   throw new IOException("Target " + dst + " already exists");
  }
 }
 return dst;
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

private static Path checkDest(String srcName, FileSystem dstFS, Path dst,
  boolean overwrite) throws IOException {
 if (dstFS.exists(dst)) {
  FileStatus sdst = dstFS.getFileStatus(dst);
  if (sdst.isDirectory()) {
   if (null == srcName) {
    throw new IOException("Target " + dst + " is a directory");
   }
   return checkDest(null, dstFS, new Path(dst, srcName), overwrite);
  } else if (!overwrite) {
   throw new IOException("Target " + dst + " already exists");
  }
 }
 return dst;
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

private static Path checkDest(String srcName, FileSystem dstFS, Path dst,
  boolean overwrite) throws IOException {
 if (dstFS.exists(dst)) {
  FileStatus sdst = dstFS.getFileStatus(dst);
  if (sdst.isDirectory()) {
   if (null == srcName) {
    throw new IOException("Target " + dst + " is a directory");
   }
   return checkDest(null, dstFS, new Path(dst, srcName), overwrite);
  } else if (!overwrite) {
   throw new IOException("Target " + dst + " already exists");
  }
 }
 return dst;
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

private static Path checkDest(String srcName, FileSystem dstFS, Path dst,
  boolean overwrite) throws IOException {
 if (dstFS.exists(dst)) {
  FileStatus sdst = dstFS.getFileStatus(dst);
  if (sdst.isDirectory()) {
   if (null == srcName) {
    throw new IOException("Target " + dst + " is a directory");
   }
   return checkDest(null, dstFS, new Path(dst, srcName), overwrite);
  } else if (!overwrite) {
   throw new IOException("Target " + dst + " already exists");
  }
 }
 return dst;
}

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

private static Path checkDest(String srcName, FileSystem dstFS, Path dst,
  boolean overwrite) throws IOException {
 if (dstFS.exists(dst)) {
  FileStatus sdst = dstFS.getFileStatus(dst);
  if (sdst.isDir()) {
   if (null == srcName) {
    throw new IOException("Target " + dst + " is a directory");
   }
   return checkDest(null, dstFS, new Path(dst, srcName), overwrite);
  } else if (!overwrite) {
   throw new IOException("Target " + dst + " already exists");
  }
 }
 return dst;
}

代码示例来源:origin: com.facebook.hadoop/hadoop-core

private static Path checkDest(String srcName, FileSystem dstFS, Path dst,
  boolean overwrite) throws IOException {
 if (dstFS.exists(dst)) {
  FileStatus sdst = dstFS.getFileStatus(dst);
  if (sdst.isDir()) {
   if (null == srcName) {
    throw new IOException("Target " + dst + " is a directory");
   }
   return checkDest(null, dstFS, new Path(dst, srcName), overwrite);
  } else if (!overwrite) {
   throw new IOException("Target " + dst + " already exists");
  }
 }
 return dst;
}

代码示例来源:origin: io.hops/hadoop-common

boolean deleteSource,
 Configuration conf, String addString) throws IOException {
dstFile = checkDest(srcDir.getName(), dstFS, dstFile, false);

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

boolean deleteSource,
               Configuration conf, String addString) throws IOException {
dstFile = checkDest(srcDir.getName(), dstFS, dstFile, false);

代码示例来源:origin: ch.cern.hadoop/hadoop-common

boolean deleteSource,
               Configuration conf, String addString) throws IOException {
dstFile = checkDest(srcDir.getName(), dstFS, dstFile, false);

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

boolean deleteSource,
               Configuration conf, String addString) throws IOException {
dstFile = checkDest(srcDir.getName(), dstFS, dstFile, false);

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

boolean deleteSource,
               Configuration conf, String addString) throws IOException {
dstFile = checkDest(srcDir.getName(), dstFS, dstFile, false);

代码示例来源:origin: com.facebook.hadoop/hadoop-core

boolean deleteSource,
               Configuration conf, String addString) throws IOException {
dstFile = checkDest(srcDir.getName(), dstFS, dstFile, false);

代码示例来源:origin: com.facebook.hadoop/hadoop-core

boolean deleteSource,
             Configuration conf) throws IOException {
dst = checkDest(src.getName(), dstFS, dst, false);

代码示例来源:origin: io.hops/hadoop-common

boolean deleteSource,
 Configuration conf) throws IOException {
dst = checkDest(src.getName(), dstFS, dst, false);

代码示例来源:origin: ch.cern.hadoop/hadoop-common

boolean deleteSource,
             Configuration conf) throws IOException {
dst = checkDest(src.getName(), dstFS, dst, false);

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

boolean deleteSource,
             Configuration conf) throws IOException {
dst = checkDest(src.getName(), dstFS, dst, false);

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

boolean deleteSource,
             Configuration conf) throws IOException {
dst = checkDest(src.getName(), dstFS, dst, false);

相关文章