Uses of Class
org.apache.flink.api.common.watermark.WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder

Packages that use WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder

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

Uses of WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder in org.apache.flink.api.common.watermark

Methods in org.apache.flink.api.common.watermark that return WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder

Modifier and Type	Method	Description
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder	WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder.combineFunctionMax()	Combine and propagate the maximum watermark to downstream.
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder	WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder.combineFunctionMin()	Combine and propagate the minimum watermark to downstream.
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder	WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder.combineWaitForAllChannels(boolean combineWaitForAllChannels)	Whether the combine process should be executed after the process function receives watermarks from both upstream channels.
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder	WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder.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.LongWatermarkDeclarationBuilder	WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder.defaultHandlingStrategyForward()
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder	WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder.defaultHandlingStrategyIgnore()
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder	WatermarkDeclarations.WatermarkDeclarationBuilder.typeLong()