Certified Data Engineer Associate Practice Exam

Join Us Among the Stars

Sign Up & unlock 100% of Exam Questions

Log in / Sign up

No Strings Attached!

192Practice Questions

3Study Modes

Free

TopicSort

Question 1

Databricks Intelligence Platform

Which of the following is a benefit of the Databricks Lakehouse Platform embracing open source technologies?

A Cloud-specific integrations
B Simplified governance
C Ability to scale storage
D Ability to scale workloads
E Avoiding vendor lock-in

Question 2

Data Processing & Transformations

Question 3

Development and Ingestion

Question 4

Data Processing & Transformations

Question 5

Databricks Intelligence Platform

Question 6

Productionizing Data Pipelines

Question 7

Productionizing Data Pipelines

Question 8

Development and Ingestion

Question 9

Data Processing & Transformations

Question 10

Databricks Intelligence Platform

Question 11

Development and Ingestion

Question 12

Data Processing & Transformations

Question 13

Development and Ingestion

Question 14

Data Processing & Transformations

Question 15

Development and Ingestion

Question 16

Data Governance & Quality

Question 17

Development and Ingestion

Question 18

Data Processing & Transformations

Question 19

Productionizing Data Pipelines

Question 20

Productionizing Data Pipelines

Question 21

Data Governance & Quality

Question 22

Development and Ingestion

Question 23

Data Governance & Quality

Question 24

Development and Ingestion

Question 28

Data Processing & Transformations

Page 1 of 8 • Questions 1-25 of 192

1 2 3 4 5

→

Know a question that should be here? Contribute to this exam

A data engineer is working with two tables. Each of these tables is displayed below in its entirety.

Question Image

The data engineer runs the following query to join these tables together:

Question Image

Which of the following will be returned by the above query?

A
B
C
D
E

Which of the following describes a scenario in which a data engineer will want to use a single-node cluster?

A When they are working interactively with a small amount of data
B When they are running automated reports to be refreshed as quickly as possible
C When they are working with SQL within Databricks SQL
D When they are concerned about the ability to automatically scale with larger data
E When they are manually running reports with a large amount of data

A data engineer has realized that the data files associated with a Delta table are incredibly small. They want to compact the small files to form larger files to improve performance.

Which of the following keywords can be used to compact the small files?

A REDUCE
B OPTIMIZE
C COMPACTION
D REPARTITION
E VACUUM

Which of the following can be used to simplify and unify siloed data architectures that are specialized for specific use cases?

A None of these
B Data lake
C Data warehouse
D All of these
E Data lakehouse

Question 6

Productionizing Data Pipelines

Question 7

Productionizing Data Pipelines

Question 8

Development and Ingestion

Question 9

Data Processing & Transformations

Question 10

Databricks Intelligence Platform

Question 11

Development and Ingestion

Question 12

Data Processing & Transformations

Question 13

Development and Ingestion

Question 14

Data Processing & Transformations

Question 15

Development and Ingestion

Question 16

Data Governance & Quality

Question 17

Development and Ingestion

Question 18

Data Processing & Transformations

Question 19

Productionizing Data Pipelines

Question 20

Productionizing Data Pipelines

Question 21

Data Governance & Quality

Question 22

Development and Ingestion

Question 23

Data Governance & Quality

Question 24

Development and Ingestion

Question 28

Data Processing & Transformations

A Delta Live Table pipeline includes two datasets defined using STREAMING LIVE TABLE. Three datasets are defined against Delta Lake table sources using LIVE TABLE.

The table is configured to run in Development mode using the Continuous Pipeline Mode.

Assuming previously unprocessed data exists and all definitions are valid, what is the expected outcome after clicking Start to update the pipeline?

A All datasets will be updated once and the pipeline will shut down. The compute resources will be terminated.
B All datasets will be updated at set intervals until the pipeline is shut down. The compute resources will persist until the pipeline is shut down.
C All datasets will be updated once and the pipeline will persist without any processing. The compute resources will persist but go unused.
D All datasets will be updated once and the pipeline will shut down. The compute resources will persist to allow for additional testing.
E All datasets will be updated at set intervals until the pipeline is shut down. The compute resources will persist to allow for additional testing.

A data engineer wants to schedule their Databricks SQL dashboard to refresh every hour, but they only want the associated SQL endpoint to be running when it is necessary. The dashboard has multiple queries on multiple datasets associated with it. The data that feeds the dashboard is automatically processed using a Databricks Job.

Which of the following approaches can the data engineer use to minimize the total running time of the SQL endpoint used in the refresh schedule of their dashboard?

A They can turn on the Auto Stop feature for the SQL endpoint.
B They can ensure the dashboard's SQL endpoint is not one of the included query's SQL endpoint.
C They can reduce the cluster size of the SQL endpoint.
D They can ensure the dashboard's SQL endpoint matches each of the queries' SQL endpoints.
E They can set up the dashboard's SQL endpoint to be serverless.

Which of the following describes a benefit of creating an external table from Parquet rather than CSV when using a CREATE TABLE AS SELECT statement?

A Parquet files can be partitioned
B CREATE TABLE AS SELECT statements cannot be used on files
C Parquet files have a well-defined schema
D Parquet files have the ability to be optimized
E Parquet files will become Delta tables

Which of the following SQL keywords can be used to convert a table from a long format to a wide format?

A TRANSFORM
B PIVOT
C SUM
D CONVERT
E WHERE

A data engineer has a Python notebook in Databricks, but they need to use SQL to accomplish a specific task within a cell. They still want all of the other cells to use Python without making any changes to those cells.

Which of the following describes how the data engineer can use SQL within a cell of their Python notebook?

A It is not possible to use SQL in a Python notebook
B They can attach the cell to a SQL endpoint rather than a Databricks cluster
C They can simply write SQL syntax in the cell
D They can add %sql to the first line of the cell
E They can change the default language of the notebook to SQL

A data engineer has developed a data pipeline to ingest data from a JSON source using Auto Loader, but the engineer has not provided any type inference or schema hints in their pipeline. Upon reviewing the data, the data engineer has noticed that all of the columns in the target table are of the string type despite some of the fields only including float or boolean values.

Which of the following describes why Auto Loader inferred all of the columns to be of the string type?

A There was a type mismatch between the specific schema and the inferred schema
B JSON data is a text-based format
C Auto Loader only works with string data
D All of the fields had at least one null value
E Auto Loader cannot infer the schema of ingested data

Which of the following data workloads will utilize a Gold table as its source?

A A job that enriches data by parsing its timestamps into a human-readable format
B A job that aggregates uncleaned data to create standard summary statistics
C A job that cleans data by removing malformatted records
D A job that queries aggregated data designed to feed into a dashboard
E A job that ingests raw data from a streaming source into the Lakehouse

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?

A
B
C
D
E

A data engineer needs to apply custom logic to identify employees with more than 5 years of experience in array column employees in table stores. The custom logic should create a new column exp_employees that is an array of all of the employees with more than 5 years of experience for each row. In order to apply this custom logic at scale, the data engineer wants to use the FILTER higher-order function.

Which of the following code blocks successfully completes this task?

A
B
C
D
E

Which of the following describes the type of workloads that are always compatible with Auto Loader?

A Streaming workloads
B Machine learning workloads
C Serverless workloads
D Batch workloads
E Dashboard workloads

A dataset has been defined using Delta Live Tables and includes an expectations clause:

CONSTRAINT valid_timestamp EXPECT (timestamp > '2020-01-01') ON VIOLATION FAIL UPDATE

What is the expected behavior when a batch of data containing data that violates these constraints is processed?

A Records that violate the expectation are dropped from the target dataset and recorded as invalid in the event log.
B Records that violate the expectation cause the job to fail.
C Records that violate the expectation are dropped from the target dataset and loaded into a quarantine table.
D Records that violate the expectation are added to the target dataset and recorded as invalid in the event log.
E Records that violate the expectation are added to the target dataset and flagged as invalid in a field added to the target dataset.

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

Question Image

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

A Replace predict with a stream-friendly prediction function
B Replace schema(schema) with option ("maxFilesPerTrigger", 1)
C Replace "transactions" with the path to the location of the Delta table
D Replace format("delta") with format("stream")
E Replace spark.read with spark.readStream

Which of the following statements regarding the relationship between Silver tables and Bronze tables is always true?

A Silver tables contain a less refined, less clean view of data than Bronze data.
B Silver tables contain aggregates while Bronze data is unaggregated.
C Silver tables contain more data than Bronze tables.
D Silver tables contain a more refined and cleaner view of data than Bronze tables.
E Silver tables contain less data than Bronze tables.

A data engineering team has noticed that their Databricks SQL queries are running too slowly when they are submitted to a non-running SQL endpoint. The data engineering team wants this issue to be resolved.

Which of the following approaches can the team use to reduce the time it takes to return results in this scenario?

A They can turn on the Serverless feature for the SQL endpoint and change the Spot Instance Policy to "Reliability Optimized."
B They can turn on the Auto Stop feature for the SQL endpoint.
C They can increase the cluster size of the SQL endpoint.
D They can turn on the Serverless feature for the SQL endpoint.
E They can increase the maximum bound of the SQL endpoint's scaling range.

Which of the following approaches should be used to send the Databricks Job owner an email in the case that the Job fails?

A Manually programming in an alert system in each cell of the Notebook
B Setting up an Alert in the Job page
C Setting up an Alert in the Notebook
D There is no way to notify the Job owner in the case of Job failure
E MLflow Model Registry Webhooks

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?

A They can set up an Alert with a custom template.
B They can set up an Alert with a new email alert destination.
C They can set up an Alert with one-time notifications.
D They can set up an Alert with a new webhook alert destination.
E They can set up an Alert without notifications.

Which of the following queries is performing a streaming hop from raw data to a Bronze table?

A
B
C
D
E

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.

What is the reason behind the deletion of all these files?

A The table was managed
B The table's data was smaller than 10 GB
C The table did not have a location
D The table was external

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 code block can the data engineer use to complete this task?

A
B
C
D

Which file format is used for storing Delta Lake Table?

A CSV
B Parquet
C JSON
D Delta

Join Us Among the Stars

Certified Data Engineer AssociatePreview

About the Certified Data Engineer Associate Exam

Mode Selection

Question 1

Question 2

Question 3

Question 4

Question 5

Question 6

Question 7

Question 8

Question 9

Question 10

Question 11

Question 12

Question 13

Question 14

Question 15

Question 16

Question 17

Question 18

Question 19

Question 20

Question 21

Question 22

Question 23

Question 24

Question 28

Question 6

Question 7

Question 8

Question 9

Question 10

Question 11

Question 12

Question 13

Question 14

Question 15

Question 16

Question 17

Question 18

Question 19

Question 20

Question 21

Question 22

Question 23

Question 24

Question 28