Class WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder
- java.lang.Object
-
- org.apache.flink.api.common.watermark.WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder
-
- Enclosing class:
- WatermarkDeclarations.WatermarkDeclarationBuilder
@Experimental public static class WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder extends Object
-
-
Constructor Summary
Constructors Constructor Description BoolWatermarkDeclarationBuilder(String identifier)
-
Method Summary
-
-
-
Constructor Detail
-
BoolWatermarkDeclarationBuilder
public BoolWatermarkDeclarationBuilder(String identifier)
-
-
Method Detail
-
combineFunctionOR
public WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder combineFunctionOR()
Propagate the logical OR combination result of boolean watermarks downstream.
-
combineFunctionAND
public WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder combineFunctionAND()
Propagate the logical AND combination result of boolean watermarks downstream.
-
defaultHandlingStrategy
public WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder defaultHandlingStrategy(WatermarkHandlingStrategy strategy)
Define whether the framework should send theWatermarkto downstream tasks when the user-definedWatermarkprocess method returnsWatermarkHandlingResult.PEEK. If set toWatermarkHandlingStrategy.FORWARD, the framework will send the watermark to downstream tasks. If set toWatermarkHandlingStrategy.IGNORE, the framework will not take any action.
-
defaultHandlingStrategyForward
public WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder defaultHandlingStrategyForward()
-
defaultHandlingStrategyIgnore
public WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder defaultHandlingStrategyIgnore()
-
combineWaitForAllChannels
public WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder combineWaitForAllChannels(boolean combineWaitForAllChannels)
Whether the combine process should be executed after the process function receives watermarks from both upstream channels.
-
build
public BoolWatermarkDeclaration build()
-
-