Uses of Class
org.apache.flink.api.common.watermark.WatermarkHandlingStrategy
-
Packages that use WatermarkHandlingStrategy Package Description org.apache.flink.api.common.watermark -
-
Uses of WatermarkHandlingStrategy in org.apache.flink.api.common.watermark
Fields in org.apache.flink.api.common.watermark declared as WatermarkHandlingStrategy Modifier and Type Field Description protected WatermarkHandlingStrategyLongWatermarkDeclaration. defaultHandlingStrategyMethods in org.apache.flink.api.common.watermark that return WatermarkHandlingStrategy Modifier and Type Method Description WatermarkHandlingStrategyBoolWatermarkDeclaration. getDefaultHandlingStrategy()WatermarkHandlingStrategyLongWatermarkDeclaration. getDefaultHandlingStrategy()static WatermarkHandlingStrategyWatermarkHandlingStrategy. valueOf(String name)Returns the enum constant of this type with the specified name.static WatermarkHandlingStrategy[]WatermarkHandlingStrategy. values()Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.api.common.watermark with parameters of type WatermarkHandlingStrategy Modifier and Type Method Description WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilderWatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder. defaultHandlingStrategy(WatermarkHandlingStrategy strategy)Define whether the framework should send theWatermarkto downstream tasks when the user-definedWatermarkprocess method returnsWatermarkHandlingResult.PEEK.WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilderWatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder. defaultHandlingStrategy(WatermarkHandlingStrategy strategy)Define whether the framework should send theWatermarkto downstream tasks when the user-definedWatermarkprocess method returnsWatermarkHandlingResult.PEEK.Constructors in org.apache.flink.api.common.watermark with parameters of type WatermarkHandlingStrategy Constructor Description BoolWatermarkDeclaration(String identifier, WatermarkCombinationPolicy combinationPolicy, WatermarkHandlingStrategy defaultHandlingStrategy)LongWatermarkDeclaration(String identifier, WatermarkCombinationPolicy combinationPolicy, WatermarkHandlingStrategy defaultHandlingStrategy)
-