Package com.linkedin.davinci.kafka.consumer

Class VeniceAdaptiveIngestionThrottler

java.lang.Object

com.linkedin.venice.throttle.EventThrottler

com.linkedin.davinci.kafka.consumer.VeniceAdaptiveIngestionThrottler

All Implemented Interfaces:

VeniceRateLimiter

public class VeniceAdaptiveIngestionThrottler
extends EventThrottler

Nested Class Summary

Nested classes/interfaces inherited from interface com.linkedin.venice.throttle.VeniceRateLimiter

VeniceRateLimiter.RateLimiterType

Field Summary

Fields inherited from class com.linkedin.venice.throttle.EventThrottler

BLOCK_STRATEGY, REJECT_STRATEGY

Constructor Summary

Constructors

Constructor	Description
VeniceAdaptiveIngestionThrottler(int signalIdleThreshold, long quotaPerSecond, List<Double> factors, long timeWindow, String throttlerName)

Method Summary

Modifier and Type	Method	Description
void	checkSignalAndAdjustThrottler()
long	getCurrentThrottlerRate()
String	getThrottlerName()
void	maybeThrottle(double eventsSeen)	Sleeps if necessary to slow down the caller.
void	registerBoosterSignal(BooleanSupplier supplier)
void	registerLimiterSignal(BooleanSupplier supplier)

Methods inherited from class com.linkedin.venice.throttle.EventThrottler

getConfiguredMaxRatePerSecond, getMaxRatePerSecond, getQuota, getRateConfig, getTime, isCheckQuotaBeforeRecording, setQuota, toString, tryAcquirePermit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

VeniceAdaptiveIngestionThrottler

public VeniceAdaptiveIngestionThrottler(int signalIdleThreshold,
 long quotaPerSecond,
 List<Double> factors,
 long timeWindow,
 String throttlerName)

Method Details

getThrottlerName

public String getThrottlerName()

Overrides:

getThrottlerName in class EventThrottler

maybeThrottle

public void maybeThrottle(double eventsSeen)

Description copied from class: EventThrottler

Sleeps if necessary to slow down the caller.

Overrides:

maybeThrottle in class EventThrottler

Parameters:

eventsSeen - Number of events seen since last invocation. Basis for determining whether its necessary to sleep.

registerLimiterSignal

public void registerLimiterSignal(BooleanSupplier supplier)

registerBoosterSignal

public void registerBoosterSignal(BooleanSupplier supplier)

checkSignalAndAdjustThrottler

public void checkSignalAndAdjustThrottler()

getCurrentThrottlerRate

public long getCurrentThrottlerRate()