From d3ed27790f42bd1ea43d9d317985ef5d3ca98f6b Mon Sep 17 00:00:00 2001 From: Yuya Ebihara Date: Sat, 19 Oct 2024 11:01:01 +0900 Subject: [PATCH] Fix typo --- .../java/io/delta/kernel/internal/replay/DeltaLogFile.java | 2 +- .../io/delta/kernel/internal/snapshot/SnapshotManager.java | 6 +++--- .../main/java/io/delta/kernel/internal/util/FileNames.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/replay/DeltaLogFile.java b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/replay/DeltaLogFile.java index 5e0d77e63c9..6086231fdd1 100644 --- a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/replay/DeltaLogFile.java +++ b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/replay/DeltaLogFile.java @@ -43,7 +43,7 @@ public static DeltaLogFile forCommitOrCheckpoint(FileStatus file) { } else if (FileNames.isClassicCheckpointFile(fileName)) { logType = LogType.CHECKPOINT_CLASSIC; version = FileNames.checkpointVersion(fileName); - } else if (FileNames.isMulitPartCheckpointFile(fileName)) { + } else if (FileNames.isMultiPartCheckpointFile(fileName)) { logType = LogType.MULTIPART_CHECKPOINT; version = FileNames.checkpointVersion(fileName); } else if (FileNames.isV2CheckpointFile(fileName)) { diff --git a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java index 8c760dbaf0c..7a3f82d9630 100644 --- a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java +++ b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java @@ -141,9 +141,9 @@ public Snapshot getSnapshotAt(Engine engine, long version) throws TableNotFoundE Optional.of(version) /* versionToLoadOpt */, Optional.empty() /* tableCommitHandlerOpt */); - // For non-coordinated commit table, the {@code getCoodinatedCommitsAwareSnapshot} will + // For non-coordinated commit table, the {@code getCoordinatedCommitsAwareSnapshot} will // create the snapshot with the {@code logSegmentOpt} built here and will not trigger other - // operations. For coordinated commit table, the {@code getCoodinatedCommitsAwareSnapshot} + // operations. For coordinated commit table, the {@code getCoordinatedCommitsAwareSnapshot} // will create the snapshot with the {@code logSegmentOpt} built here and will build the // logSegment again by also fetching the unbackfilled commits from the commit coordinator. // With the unbackfilled commits plus the backfilled commits in Delta log, a new snapshot @@ -403,7 +403,7 @@ protected final Optional> listDeltaAndCheckpointFiles( break; } - // Ideally listFromOrNone should return lexiographically sorted + // Ideally listFromOrNone should return lexicographically sorted // files and so maxDeltaVersionSeen should be equal to fileVersion. // But we are being defensive here and taking max of all the // fileVersions seen. diff --git a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/util/FileNames.java b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/util/FileNames.java index 93c554c9e8f..93b1e918ecd 100644 --- a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/util/FileNames.java +++ b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/util/FileNames.java @@ -136,7 +136,7 @@ public static boolean isClassicCheckpointFile(String fileName) { return CLASSIC_CHECKPOINT_FILE_PATTERN.matcher(fileName).matches(); } - public static boolean isMulitPartCheckpointFile(String fileName) { + public static boolean isMultiPartCheckpointFile(String fileName) { return MULTI_PART_CHECKPOINT_FILE_PATTERN.matcher(fileName).matches(); }