Answer-first summary for fast verification
Answer: trigger(processingTime = "15 Minutes")
In Structured Streaming, triggers control the execution behavior of streaming queries. The recommended trigger for this use case is `.trigger(processingTime = "15 minutes")`, which executes the query every 15 minutes. This is suitable for periodic batch processing of new data. Other trigger types include unspecified (default), fixed interval micro-batches, one-time micro-batch, and available-now trigger, each serving different purposes.
Author: LeetQuiz Editorial Team
Ultimate access to all questions.
What is the correct trigger option to build a Spark streaming process that reads from a Kafka queue and writes to a Delta table every 15 minutes?
A
trigger("15 minutes")
B
trigger(processingTime = "15 Minutes")
C
trigger(process "15 minutes")
D
trigger(processingTime = 15)
E
trigger(15)
No comments yet.