From 156d80934023378aa17a8f96c5c063e3e3d696ce Mon Sep 17 00:00:00 2001 From: Amatya Date: Wed, 18 Oct 2023 11:39:35 +0530 Subject: [PATCH] Add javadoc --- .../supervisor/SeekableStreamSupervisor.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java index 9583688e87db..a0ec6d809eb5 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java @@ -1093,6 +1093,13 @@ public void resetOffsets(@Nonnull DataSourceMetadata resetDataSourceMetadata) addNotice(new ResetOffsetsNotice(resetDataSourceMetadata)); } + /** + * The base sequence name of a seekable stream task group is used as a prefix of the sequence names + * of pending segments published by it. + * This method can be used to identify the active pending segments for a datasource + * by checking if the sequence name begins with any of the active realtime sequence prefix returned by this method + * @return the set of base sequence names of both active and pending completion task gruops. + */ @Override public Set getActiveRealtimeSequencePrefixes() {