Package org.apache.flink.api.common.watermark

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

Modifier and Type	Method	Description
BoolWatermarkDeclaration	build()
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder	combineFunctionAND()	Propagate the logical AND combination result of boolean watermarks downstream.
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder	combineFunctionOR()	Propagate the logical OR combination result of boolean watermarks downstream.
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder	combineWaitForAllChannels(boolean combineWaitForAllChannels)	Whether the combine process should be executed after the process function receives watermarks from both upstream channels.
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder	defaultHandlingStrategy(WatermarkHandlingStrategy strategy)	Define whether the framework should send the Watermark to downstream tasks when the user-defined Watermark process method returns WatermarkHandlingResult.PEEK.
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder	defaultHandlingStrategyForward()
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder	defaultHandlingStrategyIgnore()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 the Watermark to downstream tasks when the user-defined Watermark process method returns WatermarkHandlingResult.PEEK. If set to WatermarkHandlingStrategy.FORWARD, the framework will send the watermark to downstream tasks. If set to WatermarkHandlingStrategy.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()