Package 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 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