This is an automated email from the ASF dual-hosted git repository.
sajjad pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git.
from 4e595a2 Implement Real Time Mutable FST (#8016)
add 513a7b4 Add consumption rate limiter for LLConsumer (#6291)
No new revisions were added by this update.
Summary of changes:
.../realtime/LLRealtimeSegmentDataManager.java | 11 +-
.../realtime/RealtimeConsumptionRateManager.java | 134 +++++++++++++++++++++
.../RealtimeConsumptionRateManagerTest.java | 73 +++++++++++
.../server/starter/helix/BaseServerStarter.java | 4 +
.../org/apache/pinot/spi/stream/StreamConfig.java | 19 ++-
.../pinot/spi/stream/StreamConfigProperties.java | 1 +
6 files changed, 239 insertions(+), 3 deletions(-)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeConsumptionRateManager.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/data/manager/realtime/RealtimeConsumptionRateManagerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
