diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java index 3e68501956be3..5d079f351cea8 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java @@ -36,7 +36,6 @@ import java.io.IOException; import java.io.Serializable; import java.text.ParseException; -import java.time.Instant; import java.util.Arrays; import java.util.Collections; import java.util.Date; @@ -78,13 +77,6 @@ public static Date parseDateFromInstantTime(String timestamp) throws ParseExcept return HoodieInstantTimeGenerator.parseDateFromInstantTime(timestamp); } - /** - * Format the java.time.Instant to a String representing the timestamp of a Hoodie Instant. - */ - public static String formatInstantTime(Instant timestamp) { - return HoodieInstantTimeGenerator.formatInstantTime(timestamp); - } - /** * Format the Date to a String representing the timestamp of a Hoodie Instant. */ @@ -198,12 +190,6 @@ public static void deleteInstantFile(FileSystem fs, String metaPath, HoodieInsta } } - public void deletePendingIfExists(HoodieInstant.State state, String action, String instantStr) { - HoodieInstant instant = new HoodieInstant(state, action, instantStr); - ValidationUtils.checkArgument(!instant.isCompleted()); - deleteInstantFileIfExists(instant); - } - public void deleteCompactionRequested(HoodieInstant instant) { ValidationUtils.checkArgument(instant.isRequested()); ValidationUtils.checkArgument(Objects.equals(instant.getAction(), HoodieTimeline.COMPACTION_ACTION));