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

Interface ScalingStrategy<T>

All Known Implementing Classes:

AIMDScalingStrategy, NoOpScalingStrategy

@PublicEvolving
public interface ScalingStrategy<T>

ScalingStrategy provides an interface to control scale up / down behaviour.

Method Summary

Modifier and Type	Method and Description
T	scaleDown(T currentValue) Returns the scaled down value.
T	scaleUp(T currentValue) Returns the scaled up value.

Method Detail

scaleUp

T scaleUp(T currentValue)

Returns the scaled up value.

Parameters:

currentValue - currentValue

scaleDown

T scaleDown(T currentValue)

Returns the scaled down value.

Parameters:

currentValue - currentValue