HuangZhenQiu commented on code in PR #18009:
URL: https://github.com/apache/hudi/pull/18009#discussion_r2730445155
##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java:
##########
@@ -711,4 +718,39 @@ public static void validateWriteStatus(
});
}
}
+
+ /**
+ * Extracts the commit time from a Hudi data file path.
+ * <p>
+ * Example: path
.../2026/01/26/09983c46-6160-48e7-a8ec-4e69f742b4ce-0_83-512-1_20260126034716930.parquet
+ * extracts "20260126034716930"
+ *
+ * @param filePath the file path to extract commit time from
+ * @return the commit time string, or empty string if filePath is empty
+ * @throws HoodieException if the file path is not a valid Hudi data file
+ */
+ public static String getFileCommitTime(Option<String> filePath) {
Review Comment:
Make sense. Replaced with FSUtils.getCommitTime
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
