How to configure watermark settings for a Spark Streaming application to handle late data in Diyotta?
How to configure watermark settings for a Spark Streaming application to handle late data in Diyotta?
On DataStream, We can set the watermark time and column name at source (Kafka/DFS) data object à Watermark Properties.