jugomezv commented on code in PR #9994:
URL: https://github.com/apache/pinot/pull/9994#discussion_r1064235087
##########
pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java:
##########
@@ -115,15 +117,24 @@ public class RealtimeTableDataManager extends
BaseTableDataManager {
private TableDedupMetadataManager _tableDedupMetadataManager;
private TableUpsertMetadataManager _tableUpsertMetadataManager;
+ // Object to track ingestion delay for all partitions
+ private IngestionDelayTracker _ingestionDelayTracker;
+ private Supplier<Boolean> _isReadyToServeQueries;
public RealtimeTableDataManager(Semaphore segmentBuildSemaphore) {
+ this(segmentBuildSemaphore, () -> true);
+ }
+
+ public RealtimeTableDataManager(Semaphore segmentBuildSemaphore,
Supplier<Boolean> isReadyToServeQueries) {
_segmentBuildSemaphore = segmentBuildSemaphore;
+ _isReadyToServeQueries = isReadyToServeQueries;
Review Comment:
This has been addressed in commit 2e4daa35609356522a483f2a9503dde263a2e5ff,
please close this at your earliest if this satisfy your request
--
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: commits-unsubscr...@pinot.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
