
Explanation:
Structured Streaming in Apache Spark ensures recovery from failures through two primary techniques:
Both of these techniques ensure fault tolerance and data consistency in case of failures. Other options, like 'watermarking,' are used for handling late data and managing event time, but they do not directly relate to failure recovery.
Ultimate access to all questions.
No comments yet.
How does structured streaming ensure recovery from failures during stream processing?
A
Delta time travel
B
Checkpointing and write-ahead logging
C
Write ahead logging and watermarking
D
The stream will failover to available nodes in the cluster
E
Checkpointing and Watermarking
F
Checkpointing and Idempotent sinks