本文整理了Java中org.apache.gobblin.util.WriterUtils.mkdirsWithRecursivePermission()
方法的一些代码示例,展示了WriterUtils.mkdirsWithRecursivePermission()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WriterUtils.mkdirsWithRecursivePermission()
方法的具体详情如下:
包路径:org.apache.gobblin.util.WriterUtils
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!