Package | Description |
---|---|
org.apache.flink.connector.base.sink.writer.config | |
org.apache.flink.connector.base.sink.writer.strategy |
Class and Description |
---|
RateLimitingStrategy
RateLimitingStrategy is used to control the rate of requests.
|
Class and Description |
---|
AIMDScalingStrategy
AIMDScalingStrategy scales up linearly and scales down multiplicatively.
|
AIMDScalingStrategy.AIMDScalingStrategyBuilder
Builder for
AIMDScalingStrategy . |
CongestionControlRateLimitingStrategy
A
RateLimitingStrategy implementation that does the following:
Scales up when any request is successful. |
CongestionControlRateLimitingStrategy.CongestionControlRateLimitingStrategyBuilder
Builder for
CongestionControlRateLimitingStrategy . |
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.