
Ultimate access to all questions.
A data engineer is converting their existing data pipeline to use Auto Loader for incremental processing of JSON files. The following code snippet is part of their implementation:
streaming_df = (
spark
.readStream
.format("cloudFiles")
.______________________
.option("cloudFiles.schemaLocation", schemaLocation)
.load(sourcePath)
)
streaming_df = (
spark
.readStream
.format("cloudFiles")
.______________________
.option("cloudFiles.schemaLocation", schemaLocation)
.load(sourcePath)
)
Which of the following code snippets correctly fills the blank to enable the use of Auto Loader for ingesting the data?___
A
option("format", "json")
option("format", "json")
B
option("cloudFiles.format", "json")
option("cloudFiles.format", "json")
C
option("cloudFiles", "json")
option("cloudFiles", "json")
D
option(cloudFiles.format, json)
option(cloudFiles.format, json)
E
option("json")
option("json")