Watermark Processor
In this article
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
Field | Description |
---|---|
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. |
The user can add further Configuration by clicking at the ADD CONFIGURATION button.
Click Next to proceed further.
If you have any feedback on Gathr documentation, please email us!