AmatyaAvadhanula commented on code in PR #16667:
URL: https://github.com/apache/druid/pull/16667#discussion_r1677289703
##########
server/src/main/java/org/apache/druid/indexing/overlord/IndexerMetadataStorageCoordinator.java:
##########
@@ -473,4 +474,23 @@ SegmentPublishResult commitMetadataOnly(
* @return List of pending segment records
*/
List<PendingSegmentRecord> getPendingSegments(String datasource, Interval
interval);
+
+ /**
+ * List of SegmentUpgradeInfo for a given datasource and a list of segment
ids
+ * This method assumes that all the segments belong to the same datasource
+ * @param dataSource data source
+ * @param segmentIds ids of segments
+ * @return segment upgrade infos with the given list as the ids
+ */
+ List<SegmentUpgradeInfo> retrieveUpgradedFromSegmentIds(String dataSource,
List<String> segmentIds);
+
+ /**
+ * List of SegmentUpgradeInfo for a given datasource and list of
upgradedFromSegmentIds
+ * Assumes that all hte upgradedFromSegmentIds are non-null and belong to
the given datasource
Review Comment:
Fixed
--
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]
