Databricks Certified Data Engineer - Associate
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
A data engineer has developed a code block intended to perform a streaming read on a data source, but it's returning an error. The code block is as follows:
spark.read.schema(schema).format("cloudFiles").option("cloudFiles.format", "json").load(dataSource)
Which of the following modifications will correctly configure the block to perform a streaming read?
A
Insert a .stream line immediately after the spark line.
B
Replace the .read line with .readStream.
C
Add a .stream line right after the .read line.
D
Place a .stream line following the .load(dataSource) line.
E
Change the .format("cloudFiles") line to .format("streamingSource").