This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from acdad54b49 fix Quickstart -bootstrapTableDir command line option.
(#9285)
add 1bef3890d5 add a freshness based consumption status checker (#9244)
No new revisions were added by this update.
Summary of changes:
.../realtime/LLRealtimeSegmentDataManager.java | 17 +-
.../server/starter/helix/BaseServerStarter.java | 50 +++-
.../FreshnessBasedConsumptionStatusChecker.java | 90 ++++++
...=> IngestionBasedConsumptionStatusChecker.java} | 48 ++--
.../helix/OffsetBasedConsumptionStatusChecker.java | 93 ++-----
...FreshnessBasedConsumptionStatusCheckerTest.java | 305 +++++++++++++++++++++
.../OffsetBasedConsumptionStatusCheckerTest.java | 22 +-
.../apache/pinot/spi/utils/CommonConstants.java | 9 +
8 files changed, 498 insertions(+), 136 deletions(-)
create mode 100644
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/FreshnessBasedConsumptionStatusChecker.java
copy
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/{OffsetBasedConsumptionStatusChecker.java
=> IngestionBasedConsumptionStatusChecker.java} (57%)
create mode 100644
pinot-server/src/test/java/org/apache/pinot/server/starter/helix/FreshnessBasedConsumptionStatusCheckerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
