Databricks Certified Data Engineer - Associate
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
A data engineer needs to ingest heart rate recordings data from medical devices in JSON format using Auto Loader and then create a temporary view. The column 'time' is incorrectly inferred as a 'string' instead of a 'timestamp' data type. Which of the following code blocks correctly enforces the schema information for this column?
A
(spark.readStream .format("cloudFiles") .option("cloudFiles.format", "json") .option("cloudFiles.enforceSchema", "time TIMESTAMP") .option("cloudFiles.schemaLocation", "dbfs:/mnt/datalake/bronze/checkpoint") .load("dbfs:/mnt/datalake/bronze/recordings") .createOrReplaceTempView("recordings_raw_temp"))
B
(spark.readStream .format("cloudFiles") .option("cloudFiles.format", "json") .option("cloudFiles.inferColumnTypes", "time TIMESTAMP") .option("cloudFiles.schemaLocation", "dbfs:/mnt/datalake/bronze/checkpoint") .load("dbfs:/mnt/datalake/bronze/recordings") .createOrReplaceTempView("recordings_raw_temp"))
C
(spark.readStream .format("cloudFiles") .option("cloudFiles.format", "json") .option("cloudFiles.schemaHints", "time TIMESTAMP") .option("cloudFiles.schemaLocation", "dbfs:/mnt/datalake/bronze/checkpoint") .load("dbfs:/mnt/datalake/bronze/recordings") .createOrReplaceTempView("recordings_raw_temp"))
D
(spark.readStream .format("cloudFiles") .option("cloudFiles.format", "json") .option("cloudFiles.schemaDetails", "time TIMESTAMP") .option("cloudFiles.schemaLocation", "dbfs:/mnt/datalake/bronze/checkpoint") .load("dbfs:/mnt/datalake/bronze/recordings") .createOrReplaceTempView("recordings_raw_temp"))
E
(spark.readStream .format("cloudFiles") .option("cloudFiles.format", "json") .option("cloudFiles.schemaHint", "time TIMESTAMP") .option("cloudFiles.schemaLocation", "dbfs:/mnt/datalake/bronze/checkpoint") .load("dbfs:/mnt/datalake/bronze/recordings") .createOrReplaceTempView("recordings_raw_temp"))