Explanation:
In PySpark Structured Streaming, the fundamental code change to switch from a batch (static) read to a streaming read is to replace spark.read with spark.readStream. This initializes a DataStreamReader instead of a DataFrameReader.
Ultimate access to all questions.
A
Change the format to 'stream'.
B
Add .option('stream', 'true').
C
Add .trigger(once=True).
D
Replace spark.read with spark.readStream.
No comments yet.