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

Interface WatermarkCombinationFunction

All Superinterfaces:

Function, Serializable

All Known Implementing Classes:

WatermarkCombinationFunction.BoolWatermarkCombinationFunction, WatermarkCombinationFunction.NumericWatermarkCombinationFunction

@Experimental
public interface WatermarkCombinationFunction
extends Function

The WatermarkCombinationFunction defines the watermark's comparison/combination semantics among multiple input channels.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	WatermarkCombinationFunction.BoolWatermarkCombinationFunction	The WatermarkCombinationFunction.BoolWatermarkCombinationFunction enum defines the combination semantics for boolean watermarks.
static class	WatermarkCombinationFunction.NumericWatermarkCombinationFunction	The WatermarkCombinationFunction.NumericWatermarkCombinationFunction enum defines the combination semantics for numeric watermarks.