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.

Watermark Processor Configuration

FieldDescription
Event Time ColumnSelect the Event Time Column. Event Time column is the timestamp field from incoming data on the basis of which the can enable watermarking.
DelayEnter values for the delay fields.

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

Click Next to proceed further.

Top