Uses of Package
org.apache.flink.connector.base.sink.writer.strategy
-
Classes in org.apache.flink.connector.base.sink.writer.strategy used by org.apache.flink.connector.base.sink.writer Class Description RequestInfo Interface for dataclass used to encapsulate information about starting requests. -
Classes in org.apache.flink.connector.base.sink.writer.strategy used by org.apache.flink.connector.base.sink.writer.config Class Description RateLimitingStrategy RateLimitingStrategy is used to control the rate of requests. -
Classes in org.apache.flink.connector.base.sink.writer.strategy used by org.apache.flink.connector.base.sink.writer.strategy Class Description AIMDScalingStrategy AIMDScalingStrategy scales up linearly and scales down multiplicatively.AIMDScalingStrategy.AIMDScalingStrategyBuilder Builder forAIMDScalingStrategy.CongestionControlRateLimitingStrategy ARateLimitingStrategyimplementation that does the following: Scales up when any request is successful.CongestionControlRateLimitingStrategy.CongestionControlRateLimitingStrategyBuilder Builder forCongestionControlRateLimitingStrategy.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 ScalingStrategy provides an interface to control scale up / down behaviour.