diff --git a/storage/src/main/java/io/delta/storage/commit/CoordinatedCommitsUtils.java b/storage/src/main/java/io/delta/storage/commit/CoordinatedCommitsUtils.java index 6197c88357..377e58c103 100644 --- a/storage/src/main/java/io/delta/storage/commit/CoordinatedCommitsUtils.java +++ b/storage/src/main/java/io/delta/storage/commit/CoordinatedCommitsUtils.java @@ -35,6 +35,9 @@ public class CoordinatedCommitsUtils { private CoordinatedCommitsUtils() {} + /** The subdirectory in which to store the delta log. */ + private static final String LOG_DIR_NAME = "_delta_log"; + /** The subdirectory in which to store the unbackfilled commit files. */ private static final String COMMIT_SUBDIR = "_commits"; @@ -127,6 +130,11 @@ public static FileStatus writeUnbackfilledCommitFile( return commitPath.getFileSystem(hadoopConf).getFileStatus(commitPath); } + /** Returns path to the directory which holds the delta log */ + public static Path logDirPath(Path tablePath) { + return new Path(tablePath, LOG_DIR_NAME); + } + /** Returns path to the directory which holds the unbackfilled commits */ public static Path commitDirPath(Path logPath) { return new Path(logPath, COMMIT_SUBDIR);