Package | Description |
---|---|
org.apache.flink.connector.base.sink.writer.strategy |
Modifier and Type | Class and Description |
---|---|
class |
AIMDScalingStrategy
AIMDScalingStrategy scales up linearly and scales down multiplicatively.
|
class |
NoOpScalingStrategy<T>
NoOpScalingStrategy does not scale up / down the given value.
|
Modifier and Type | Method and Description |
---|---|
CongestionControlRateLimitingStrategy.CongestionControlRateLimitingStrategyBuilder |
CongestionControlRateLimitingStrategy.CongestionControlRateLimitingStrategyBuilder.setScalingStrategy(ScalingStrategy<Integer> scalingStrategy) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.