Uses of Class
org.apache.flink.api.common.eventtime.Watermark
-
Packages that use Watermark Package Description org.apache.flink.api.common.eventtime org.apache.flink.api.connector.sink org.apache.flink.api.connector.sink2 org.apache.flink.api.connector.source -
-
Uses of Watermark in org.apache.flink.api.common.eventtime
Fields in org.apache.flink.api.common.eventtime declared as Watermark Modifier and Type Field Description static WatermarkWatermark. MAX_WATERMARKThe watermark that signifies end-of-event-time.Methods in org.apache.flink.api.common.eventtime with parameters of type Watermark Modifier and Type Method Description voidWatermarkOutput. emitWatermark(Watermark watermark)Emits the given watermark. -
Uses of Watermark in org.apache.flink.api.connector.sink
Methods in org.apache.flink.api.connector.sink with parameters of type Watermark Modifier and Type Method Description default voidSinkWriter. writeWatermark(Watermark watermark)Deprecated.Add a watermark to the writer. -
Uses of Watermark in org.apache.flink.api.connector.sink2
Methods in org.apache.flink.api.connector.sink2 with parameters of type Watermark Modifier and Type Method Description default voidSinkWriter. writeWatermark(Watermark watermark)Adds a watermark to the writer. -
Uses of Watermark in org.apache.flink.api.connector.source
Methods in org.apache.flink.api.connector.source with parameters of type Watermark Modifier and Type Method Description voidReaderOutput. emitWatermark(Watermark watermark)Emits the given watermark.
-