Watermark Processor

Watermark processor provides Spark Watermarking feature for late data handling and Stream-Stream Joins. The user can specify event column and delay for the incoming data to enable watermark on the dataset.

Processor Configuration #

Event Time Column: Select the Event Time Column. Event Time column is the timestamp field from incoming data on the basis of which the can enable watermarking.

Delay: Enter values for the delay fields.

You can add further Configuration by clicking at the ADD CONFIGURATION button.