n3nash commented on a change in pull request #2202:
URL: https://github.com/apache/hudi/pull/2202#discussion_r513522889
##########
File path:
hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java
##########
@@ -710,6 +721,40 @@ private String formatPartitionKey(String partitionStr) {
*/
abstract void removePendingCompactionOperations(Stream<Pair<String,
CompactionOperation>> operations);
+ /**
+ * Check if there is an outstanding clustering operation
(requested/inflight) scheduled for this file.
+ *
+ * @param fgId File-Group Id
+ * @return true if there is a pending clustering, false otherwise
+ */
+ protected abstract boolean
isPendingClusteringScheduledForFileId(HoodieFileGroupId fgId);
+
+ /**
+ * Get pending clustering instant time for specified file group. Return
None if file group is not in pending
+ * clustering operation.
+ */
+ protected abstract Option<HoodieInstant> getPendingClusteringInstant(final
HoodieFileGroupId fileGroupId);
+
+ /**
+ * Fetch all file groups in pending clustering.
+ */
+ protected abstract Stream<Pair<HoodieFileGroupId, HoodieInstant>>
fetchFileGroupsInPendingClustering();
+
+ /**
+ * resets the pending clustering operation and overwrite with the new list.
+ */
+ abstract void resetFileGroupsInPendingClustering(Map<HoodieFileGroupId,
HoodieInstant> fgIdToInstantMap);
Review comment:
How will this API be used ?
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
