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

Interface Summary

Interface	Description
Watermark
WatermarkCombinationFunction	The WatermarkCombinationFunction defines the watermark's comparison/combination semantics among multiple input channels.
WatermarkDeclaration	This class represents the watermark creation and handling policy defined by the user.
WatermarkManager	The WatermarkManager interface provides a mechanism to emit watermarks from a process function.

Class Summary

Class	Description
BoolWatermark	The BoolWatermark represents a watermark with a boolean value and an associated identifier.
BoolWatermarkDeclaration	The BoolWatermarkDeclaration class implements the WatermarkDeclaration interface and provides additional functionality specific to boolean-type watermarks.
LongWatermark	The LongWatermark represents a watermark with a long value and an associated identifier.
LongWatermarkDeclaration	The LongWatermarkDeclaration class implements the WatermarkDeclaration interface and provides additional functionality specific to long-type watermarks.
WatermarkCombinationPolicy	The WatermarkCombinationPolicy defines when and how to the combine Watermarks.
WatermarkDeclarations	The Utils class is used to create WatermarkDeclaration.
WatermarkDeclarations.WatermarkDeclarationBuilder	Builder class for WatermarkDeclarations.
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder
WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder

Enum Summary

Enum	Description
WatermarkCombinationFunction.BoolWatermarkCombinationFunction	The WatermarkCombinationFunction.BoolWatermarkCombinationFunction enum defines the combination semantics for boolean watermarks.
WatermarkCombinationFunction.NumericWatermarkCombinationFunction	The WatermarkCombinationFunction.NumericWatermarkCombinationFunction enum defines the combination semantics for numeric watermarks.
WatermarkHandlingResult	This class defines watermark handling result for user-defined process function.
WatermarkHandlingStrategy	This class defines the framework's behavior when the user-defined Watermark process method returns WatermarkHandlingResult.PEEK.