Databricks Databricks-Certified-Professional-Data-Engineer Question Answer
A nightly job ingests data into a Delta Lake table using the following code:
The next step in the pipeline requires a function that returns an object that can be used to manipulate new records that have not yet been processed to the next table in the pipeline.
Which code snippet completes this function definition?
def new_records():
A.
return spark.readStream.table( " bronze " )
B.
return spark.readStream.load( " bronze " )
C.
D.
return spark.read.option( " readChangeFeed " , " true " ).table ( " bronze " )
E.
Databricks-Certified-Professional-Data-Engineer PDF/Engine
- Printable Format
- Value of Money
- 100% Pass Assurance
- Verified Answers
- Researched by Industry Experts
- Based on Real Exams Scenarios
- 100% Real Questions
Get 65% Discount on All Products,
Use Coupon: "ac4s65"
