java.lang.Object
- org.apache.flink.api.common.watermark.WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder

@Experimental
public static class WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder
extends Object

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`LongWatermarkDeclaration`	`build()`
`WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder`	`combineFunctionMax()`	Combine and propagate the maximum watermark to downstream.
`WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder`	`combineFunctionMin()`	Combine and propagate the minimum watermark to downstream.
`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`	`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`	`defaultHandlingStrategyForward()`
`WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder`	`defaultHandlingStrategyIgnore()`

public LongWatermarkDeclarationBuilder(String identifier)

public WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder combineFunctionMax()

Combine and propagate the maximum watermark to downstream.

public WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder combineFunctionMin()

Combine and propagate the minimum watermark to downstream.

defaultHandlingStrategy
```
public 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. 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.

public WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder defaultHandlingStrategyForward()

public WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder defaultHandlingStrategyIgnore()

public WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder combineWaitForAllChannels(boolean combineWaitForAllChannels)

Whether the combine process should be executed after the process function receives watermarks from both upstream channels.

public LongWatermarkDeclaration build()

Class WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder