devmadhuu commented on code in PR #7723:
URL: https://github.com/apache/ozone/pull/7723#discussion_r1961466263
##########
hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/tasks/FileSizeCountTask.java:
##########
@@ -138,11 +145,17 @@ public Collection<String> getTaskTables() {
* Read the Keys from update events and update the count of files
* pertaining to a certain upper bound.
*
- * @param events Update events - PUT/DELETE.
- * @return Pair
+ * @param events The batch of OM update events to be processed.
+ * @param subTaskSeekPosMap A map containing the seek positions for
+ * each sub-task, indicating where to start
processing.
+ * @return A {@link TaskResult} containing:
+ * - The task name.
+ * - A map of sub-task names to their respective seek positions.
+ * - A boolean indicating whether the task was successful.
*/
@Override
- public Pair<String, Boolean> process(OMUpdateEventBatch events) {
+ public TaskResult process(OMUpdateEventBatch events,
+ Map<String, Integer> subTaskSeekPosMap) {
Review Comment:
No, current PR is only for NSSummary task, later the same interface can be
extended for tracking the event iterator position for other tasks as well in
future PRs if any.
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
