AmatyaAvadhanula commented on code in PR #16667:
URL: https://github.com/apache/druid/pull/16667#discussion_r1673629480
##########
server/src/main/java/org/apache/druid/indexing/overlord/IndexerMetadataStorageCoordinator.java:
##########
@@ -473,4 +475,22 @@ SegmentPublishResult commitMetadataOnly(
* @return List of pending segment records
*/
List<PendingSegmentRecord> getPendingSegments(String datasource, Interval
interval);
+
+ /**
+ * Returns a mapping from the segments ids to their parent segments ids
+ *
+ * @param dataSource data source
+ * @param segmentIds ids of segments
+ * @return UpgradedFromSegmentsResponse
+ */
+ UpgradedFromSegmentsResponse retrieveUpgradedFromSegmentIds(String
dataSource, Set<String> segmentIds);
+
+ /**
+ * Returns a mapping from segment ids to their child segment ids
+ *
+ * @param dataSource data source
+ * @param upgradedFromSegmentIds ids of the first segments which had the
corresponding load spec
+ * @return UpgradedToSegmentsResponse
+ */
+ UpgradedToSegmentsResponse retrieveUpgradedToSegmentIds(String dataSource,
Set<String> upgradedFromSegmentIds);
Review Comment:
Done
##########
server/src/main/java/org/apache/druid/indexing/overlord/IndexerMetadataStorageCoordinator.java:
##########
@@ -473,4 +475,22 @@ SegmentPublishResult commitMetadataOnly(
* @return List of pending segment records
*/
List<PendingSegmentRecord> getPendingSegments(String datasource, Interval
interval);
+
+ /**
+ * Returns a mapping from the segments ids to their parent segments ids
+ *
+ * @param dataSource data source
+ * @param segmentIds ids of segments
+ * @return UpgradedFromSegmentsResponse
+ */
+ UpgradedFromSegmentsResponse retrieveUpgradedFromSegmentIds(String
dataSource, Set<String> segmentIds);
+
+ /**
+ * Returns a mapping from segment ids to their child segment ids
+ *
+ * @param dataSource data source
+ * @param upgradedFromSegmentIds ids of the first segments which had the
corresponding load spec
+ * @return UpgradedToSegmentsResponse
+ */
+ UpgradedToSegmentsResponse retrieveUpgradedToSegmentIds(String dataSource,
Set<String> upgradedFromSegmentIds);
Review Comment:
Done
--
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]
