Create and Write Streaming DataFrames and Streaming Datasets, Including the Basic Output Modes and Output Sinks. ASSOCIATE-DEVELOPER-APACHE-SPARK Practice Questions (Page 3)

Questions 11–13

1. 11application · medium

   A streaming query reads from Kafka and writes aggregated results to a memory sink. The team notices that the query stops silently after a transient network failure. They want the query to automatically resume from where it left off. What is the required configuration?

   • ASet a checkpoint location
   • BSet a trigger interval
   • CUse the complete output mode
   • DIncrease the number of shuffle partitions
   Reveal Solution Discussion Select an answer first
2. 12foundation · easy

   Which output mode is only supported when the streaming query has an aggregation (e.g., a groupBy) and writes the entire updated result table to the sink?

   • AOverwrite
   • BUpdate
   • CComplete
   • DAppend
   Reveal Solution Discussion Select an answer first
3. 13application · medium

   A team is writing a streaming query that reads from Kafka and writes to a memory sink. They want the query to process data every 10 seconds. Which writeStream configuration is correct?

   • A.trigger(Trigger.Once()).start()
   • B.trigger(Trigger.Continuous("10 seconds")).start()
   • C.trigger(Trigger.ProcessingTime("10 seconds")).start()
   • D.option("trigger", "10 seconds").start()
   Reveal Solution Discussion Select an answer first