Uses of Package
org.apache.flink.api.common.watermark
-
Packages that use org.apache.flink.api.common.watermark Package Description org.apache.flink.api.common.watermark -
Classes in org.apache.flink.api.common.watermark used by org.apache.flink.api.common.watermark Class Description BoolWatermark TheBoolWatermarkrepresents a watermark with a boolean value and an associated identifier.BoolWatermarkDeclaration TheBoolWatermarkDeclarationclass implements theWatermarkDeclarationinterface and provides additional functionality specific to boolean-type watermarks.LongWatermark TheLongWatermarkrepresents a watermark with a long value and an associated identifier.LongWatermarkDeclaration TheLongWatermarkDeclarationclass implements theWatermarkDeclarationinterface and provides additional functionality specific to long-type watermarks.Watermark WatermarkCombinationFunction TheWatermarkCombinationFunctiondefines the watermark's comparison/combination semantics among multiple input channels.WatermarkCombinationFunction.BoolWatermarkCombinationFunction TheWatermarkCombinationFunction.BoolWatermarkCombinationFunctionenum defines the combination semantics for boolean watermarks.WatermarkCombinationFunction.NumericWatermarkCombinationFunction TheWatermarkCombinationFunction.NumericWatermarkCombinationFunctionenum defines the combination semantics for numeric watermarks.WatermarkCombinationPolicy TheWatermarkCombinationPolicydefines when and how to the combineWatermarks.WatermarkDeclaration This class represents the watermark creation and handling policy defined by the user.WatermarkDeclarations.WatermarkDeclarationBuilder Builder class forWatermarkDeclarations.WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder WatermarkDeclarations.WatermarkDeclarationBuilder.LongWatermarkDeclarationBuilder WatermarkHandlingResult This class defines watermark handling result for user-defined process function.WatermarkHandlingStrategy This class defines the framework's behavior when the user-definedWatermarkprocess method returnsWatermarkHandlingResult.PEEK.