Class NoOpScalingStrategy<T>
- java.lang.Object
-
- org.apache.flink.connector.base.sink.writer.strategy.NoOpScalingStrategy<T>
-
- All Implemented Interfaces:
ScalingStrategy<T>
public class NoOpScalingStrategy<T> extends Object implements ScalingStrategy<T>
NoOpScalingStrategy does not scale up / down the given value.
-
-
Constructor Summary
Constructors Constructor Description NoOpScalingStrategy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TscaleDown(T currentValue)Returns the scaled down value.TscaleUp(T currentValue)Returns the scaled up value.
-
-
-
Method Detail
-
scaleUp
public T scaleUp(T currentValue)
Description copied from interface:ScalingStrategyReturns the scaled up value.- Specified by:
scaleUpin interfaceScalingStrategy<T>- Parameters:
currentValue- currentValue
-
scaleDown
public T scaleDown(T currentValue)
Description copied from interface:ScalingStrategyReturns the scaled down value.- Specified by:
scaleDownin interfaceScalingStrategy<T>- Parameters:
currentValue- currentValue
-
-