Databricks Certified Data Engineer - Professional
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
A data engineer executes the following query in Databricks: spark.readStream.format('delta').table('stock_prices').join(table('company_info'), how = 'left', on='id').writeStream.option('checkpointLocation', '/tmp/share_details').format('delta').table('shares'). What happens to the streaming query if the schema of the company_info table is altered by a data analyst?
A
The streaming query fails immediately upon schema change in the company_info table._
B
The streaming query fails upon receiving the next batch in stock_prices only if the id column is dropped from company_info.
C
The streaming query fails upon receiving the next batch in stock_prices._
D
The streaming query fails upon receiving the next batch in stock_prices only if the id column is dropped or renamed in company_info.
E
The schema of company_info cannot be altered while the streaming query is active._