Package org.apache.flink.connector.base.sink.writer.strategy

Interface Summary

Interface	Description
RateLimitingStrategy	RateLimitingStrategy is used to control the rate of requests.
RequestInfo	Interface for dataclass used to encapsulate information about starting requests.
ResultInfo	Interface for dataclass used to encapsulate results from completed requests.
ScalingStrategy<T>	ScalingStrategy provides an interface to control scale up / down behaviour.

Class Summary

Class	Description
AIMDScalingStrategy	AIMDScalingStrategy scales up linearly and scales down multiplicatively.
AIMDScalingStrategy.AIMDScalingStrategyBuilder	Builder for AIMDScalingStrategy.
BasicRequestInfo	Dataclass to encapsulate information about starting requests.
BasicResultInfo	Dataclass to encapsulate results from completed requests.
CongestionControlRateLimitingStrategy	A RateLimitingStrategy implementation that does the following: Scales up when any request is successful.
CongestionControlRateLimitingStrategy.CongestionControlRateLimitingStrategyBuilder	Builder for CongestionControlRateLimitingStrategy.
NoOpScalingStrategy<T>	NoOpScalingStrategy does not scale up / down the given value.