A sensor telemetry stream has columns `device_id`, `reading_time`, and `temperature`. The team writes: ```python cleaned = sensor_df \ .withWatermark("reading_time", "15 minutes") \ .dropDuplicates(["device_id", "reading_time"]) ``` A record for `device_id="A1"` with `reading_time="10:00:00"` arrives, is processed, and the watermark subsequently advances to `10:20:00`. A duplicate record for the same `device_id` and `reading_time="10:00:00"` then arrives. What happens to this late duplicate?
Select one answer.
Purchase Full Access to view answer options & explanation
The first 118 questions in this bank are completely free. Unlock Full Access on the exam page to view all answer choices, verified answers, explanations, and community discussions for all 392 questions.
