org.apache.gobblin.util.WriterUtils.mkdirsWithRecursivePermission()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(96)

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

WriterUtils.mkdirsWithRecursivePermission介绍

[英]Create the given dir as well as all missing ancestor dirs. All created dirs will have the given permission. This should be used instead of FileSystem#mkdirs(Path,FsPermission), since that method only sets the permission for the given dir, and not recursively for the ancestor dirs.
[中]创建给定的目录以及所有缺少的祖先目录。所有创建的目录都将具有给定的权限。应该使用该方法而不是文件系统#mkdirs(Path,FsPermission),因为该方法只为给定的dir设置权限,而不是递归地为祖先dir设置权限。

代码示例

代码示例来源:origin: apache/incubator-gobblin

private void moveDirectory(String sourceDir, String targetDir) throws IOException {
 // If targetDir exists, delete it
 if (this.fs.exists(new Path(targetDir))) {
  deleteDirectory(targetDir);
 }
 // Create parent directories of targetDir
 WriterUtils.mkdirsWithRecursivePermission(this.fs, new Path(targetDir).getParent(),
   FsPermission.getCachePoolDefault());
 // Move directory
 log.info("Moving directory: " + sourceDir + " to: " + targetDir);
 if (!this.fs.rename(new Path(sourceDir), new Path(targetDir))) {
  throw new IOException(String.format("Unable to move %s to %s", sourceDir, targetDir));
 }
}

代码示例来源:origin: apache/incubator-gobblin

MRCompactorJobRunner.COMPACTION_JOB_OUTPUT_DIR_PERMISSION,
    FsPermission.getDefault());
WriterUtils.mkdirsWithRecursivePermission(this.fs, dstPath, permission);
    FsPermission.getDefault());
WriterUtils.mkdirsWithRecursivePermission(this.fs, dstPath.getParent(), permission);
if (!this.fs.rename(tmpPath, dstPath)) {
 throw new IOException(

代码示例来源:origin: apache/incubator-gobblin

WriterUtils.mkdirsWithRecursivePermission(this.fs, this.outputFile.getParent(), this.dirPermission);
this.bytesWritten = Optional.absent();

代码示例来源:origin: org.apache.gobblin/gobblin-data-management

private void moveDirectory(String sourceDir, String targetDir) throws IOException {
 // If targetDir exists, delete it
 if (this.fs.exists(new Path(targetDir))) {
  deleteDirectory(targetDir);
 }
 // Create parent directories of targetDir
 WriterUtils.mkdirsWithRecursivePermission(this.fs, new Path(targetDir).getParent(),
   FsPermission.getCachePoolDefault());
 // Move directory
 log.info("Moving directory: " + sourceDir + " to: " + targetDir);
 if (!this.fs.rename(new Path(sourceDir), new Path(targetDir))) {
  throw new IOException(String.format("Unable to move %s to %s", sourceDir, targetDir));
 }
}

代码示例来源:origin: org.apache.gobblin/gobblin-compaction

MRCompactorJobRunner.COMPACTION_JOB_OUTPUT_DIR_PERMISSION,
    FsPermission.getDefault());
WriterUtils.mkdirsWithRecursivePermission(this.fs, dstPath, permission);
    FsPermission.getDefault());
WriterUtils.mkdirsWithRecursivePermission(this.fs, dstPath.getParent(), permission);
if (!this.fs.rename(tmpPath, dstPath)) {
 throw new IOException(

代码示例来源:origin: org.apache.gobblin/gobblin-core

WriterUtils.mkdirsWithRecursivePermission(this.fs, this.outputFile.getParent(), this.dirPermission);
this.bytesWritten = Optional.absent();

相关文章