Question 96

A data engineer is using the following code block as part of a batch ingestion pipeline to read from a composable table:

Which of the following changes needs to be made so this code block will work when the transactions table is a stream source?
  • Question 97

    A data engineer is maintaining a data pipeline. Upon data ingestion, the data engineer notices that the source data is starting to have a lower level of quality. The data engineer would like to automate the process of monitoring the quality level.
    Which of the following tools can the data engineer use to solve this problem?
  • Question 98

    A data engineer has been using a Databricks SQL dashboard to monitor the cleanliness of the input data to a data analytics dashboard for a retail use case. The job has a Databricks SQL query that returns the number of store-level records where sales is equal to zero. The data engineer wants their entire team to be notified via a messaging webhook whenever this value is greater than 0.
    Which of the following approaches can the data engineer use to notify their entire team via a messaging webhook whenever the number of stores with $0 in sales is greater than zero?
  • Question 99

    A data engineer is attempting to drop a Spark SQL table my_table and runs the following command:
    DROP TABLE IF EXISTS my_table;
    After running this command, the engineer notices that the data files and metadata files have been deleted from the file system.
    Which of the following describes why all of these files were deleted?
  • Question 100

    A data engineer that is new to using Python needs to create a Python function to add two integers together and return the sum?
    Which of the following code blocks can the data engineer use to complete this task?