Databricks Data Engineer Associate Certification Sample Questions
The purpose of this Sample Question Set is to provide you with information about the Databricks Certified Data Engineer Associate exam. These sample questions will make you very familiar with both the type and the difficulty level of the questions on the Data Engineer Associate certification test. To get familiar with real exam environment, we suggest you try our Sample Databricks Lakehouse Data Engineer Associate Certification Practice Exam. This sample practice exam gives you the feeling of reality and is a clue to the questions asked in the actual Databricks Certified Data Engineer Associate certification exam.
These sample questions are simple and basic questions that represent likeness to the real Databricks Certified Data Engineer Associate exam questions. To assess your readiness and performance with real-time scenario based questions, we suggest you prepare with our Premium Databricks Data Engineer Associate Certification Practice Exam. When you solve real time scenario based questions practically, you come across many difficulties that give you an opportunity to improve.
Databricks Data Engineer Associate Sample Questions:
01. A data engineering team has a Lakeflow Spark Declarative Pipeline (formerly Delta Live Tables) that keeps processing new data and updating its tables until it is manually stopped. Its compute resources keep running between updates to allow quick testing.
Which execution modes describe this pipeline?
a) Triggered pipeline mode in production mode
b) Triggered pipeline mode in development mode
c) Continuous pipeline mode in development mode
d) Continuous pipeline mode in production mode
Which execution modes describe this pipeline?
a) Triggered pipeline mode in production mode
b) Triggered pipeline mode in development mode
c) Continuous pipeline mode in development mode
d) Continuous pipeline mode in production mode
02. A data engineer manages the schema sales_data, which stores transactional sales information. The analysts group needs read-only access to all tables in the schema and already has USE CATALOG and USE SCHEMA.
Which SQL command grants the required access?
a) GRANT SELECT ON ALL TABLES IN SCHEMA sales_data TO analysts;
b) GRANT ALL PRIVILEGES ON SCHEMA sales_data TO analysts;
c) GRANT INSERT ON SCHEMA sales_data TO analysts;
d) GRANT SELECT ON SCHEMA sales_data TO analysts;
Which SQL command grants the required access?
a) GRANT SELECT ON ALL TABLES IN SCHEMA sales_data TO analysts;
b) GRANT ALL PRIVILEGES ON SCHEMA sales_data TO analysts;
c) GRANT INSERT ON SCHEMA sales_data TO analysts;
d) GRANT SELECT ON SCHEMA sales_data TO analysts;
03. The table faculties has an array column students, where each element is a struct with a total_courses field. The query below should return, in new_totals, each student's total_courses incremented by 1:
SELECT faculty_id, students, ___________ AS new_totals FROM faculties
Which expression fills the blank?
a) FILTER(students, i -> i.total_courses + 1)
b) TRANSFORM(students, i -> i.total_courses + 1)
c) EXISTS(students, i -> i.total_courses + 1)
d) TRANSFORM(students, total_courses + 1)
SELECT faculty_id, students, ___________ AS new_totals FROM faculties
Which expression fills the blank?
a) FILTER(students, i -> i.total_courses + 1)
b) TRANSFORM(students, i -> i.total_courses + 1)
c) EXISTS(students, i -> i.total_courses + 1)
d) TRANSFORM(students, total_courses + 1)
04. A data engineer is setting up data sharing in Unity Catalog with Delta Sharing (now OpenSharing). Internal teams in several departments need to read and update the data, while external partners must only be able to read it.
Which configuration meets these requirements?
a) Share the tables with partners through a share, and grant internal groups SELECT and MODIFY in Unity Catalog.
b) Add the tables to a share, and grant both partners and internal teams MODIFY through the share.
c) Grant SELECT to partners and SELECT plus MODIFY to internal teams, both on the share.
d) Create a share, generate one access URL, and distribute it to internal teams and partners.
Which configuration meets these requirements?
a) Share the tables with partners through a share, and grant internal groups SELECT and MODIFY in Unity Catalog.
b) Add the tables to a share, and grant both partners and internal teams MODIFY through the share.
c) Grant SELECT to partners and SELECT plus MODIFY to internal teams, both on the share.
d) Create a share, generate one access URL, and distribute it to internal teams and partners.
05. A data engineer runs the following statements in Unity Catalog. The hr catalog was created with its own managed storage location.
CREATE SCHEMA hr.db_hr MANAGED LOCATION 's3://corp-data/hr/';
CREATE TABLE hr.db_hr.employees (id INT, name STRING);
Where is the data for the managed table employees stored?
a) dbfs:/user/hive/warehouse/db_hr.db/employees
b) In the metastore-level managed storage location
c) In the managed storage location of the hr catalog
d) Under the schema's managed location, s3://corp-data/hr/
CREATE SCHEMA hr.db_hr MANAGED LOCATION 's3://corp-data/hr/';
CREATE TABLE hr.db_hr.employees (id INT, name STRING);
Where is the data for the managed table employees stored?
a) dbfs:/user/hive/warehouse/db_hr.db/employees
b) In the metastore-level managed storage location
c) In the managed storage location of the hr catalog
d) Under the schema's managed location, s3://corp-data/hr/
06. A data engineer has been given a new record:
id STRING = 'a1'
rank INTEGER = 6
rating FLOAT = 9.4
Which SQL command appends this record to the existing Delta table my_table?
a) INSERT INTO my_table VALUES ('a1', 6, 9.4)
b) INSERT VALUES ('a1', 6, 9.4) INTO my_table
c) UPDATE VALUES ('a1', 6, 9.4) my_table
d) UPDATE my_table VALUES ('a1', 6, 9.4)
id STRING = 'a1'
rank INTEGER = 6
rating FLOAT = 9.4
Which SQL command appends this record to the existing Delta table my_table?
a) INSERT INTO my_table VALUES ('a1', 6, 9.4)
b) INSERT VALUES ('a1', 6, 9.4) INTO my_table
c) UPDATE VALUES ('a1', 6, 9.4) my_table
d) UPDATE my_table VALUES ('a1', 6, 9.4)
07. In Lakeflow Jobs, how can a data engineer make Task B run only after Task A completes?
a) They can assign Task A an order number of 1 and Task B an order number of 2
b) They can configure the dependency at the notebook level using the dbutils.jobs utility
c) Lakeflow Jobs do not support linear dependencies between tasks; this is possible only in Lakeflow Spark Declarative Pipelines
d) They can add both tasks to the job, since tasks always run in the order they were created
e) They can select Task A in the Depends on field of the Task B configuration
a) They can assign Task A an order number of 1 and Task B an order number of 2
b) They can configure the dependency at the notebook level using the dbutils.jobs utility
c) Lakeflow Jobs do not support linear dependencies between tasks; this is possible only in Lakeflow Spark Declarative Pipelines
d) They can add both tasks to the job, since tasks always run in the order they were created
e) They can select Task A in the Depends on field of the Task B configuration
08. A data engineer runs the following statement in Unity Catalog:
GRANT USE SCHEMA ON SCHEMA main.sales_db TO finance_team
What does the USE SCHEMA privilege give the group?
a) Nothing that affects access control
b) Full control of the schema
c) Access to objects in the schema, only when combined with other privileges
d) Read access to every table in the schema
GRANT USE SCHEMA ON SCHEMA main.sales_db TO finance_team
What does the USE SCHEMA privilege give the group?
a) Nothing that affects access control
b) Full control of the schema
c) Access to objects in the schema, only when combined with other privileges
d) Read access to every table in the schema
09. Which mechanism lets Auto Loader track ingestion progress and store metadata about the files it has discovered?
a) mergeSchema
b) Z-Ordering
c) COPY INTO
d) Watermarking
e) Checkpointing
a) mergeSchema
b) Z-Ordering
c) COPY INTO
d) Watermarking
e) Checkpointing
10. A data engineer defines the following dataset in a Lakeflow Spark Declarative Pipelines pipeline:
CREATE OR REFRESH STREAMING TABLE sales_silver AS SELECT store_id, total + tax AS total_after_tax FROM sales_bronze
The pipeline fails to start with an error on this query. Which FROM clause correctly reads the upstream table incrementally?
a) FROM STREAM_TABLE(sales_bronze)
b) FROM STREAM(sales_bronze)
c) FROM STREAMING(sales_bronze)
d) FROM sales_bronze WITH STREAM
CREATE OR REFRESH STREAMING TABLE sales_silver AS SELECT store_id, total + tax AS total_after_tax FROM sales_bronze
The pipeline fails to start with an error on this query. Which FROM clause correctly reads the upstream table incrementally?
a) FROM STREAM_TABLE(sales_bronze)
b) FROM STREAM(sales_bronze)
c) FROM STREAMING(sales_bronze)
d) FROM sales_bronze WITH STREAM
Answers:
|
Question: 01 Answer: c |
Question: 02 Answer: d |
Question: 03 Answer: b |
Question: 04 Answer: a |
Question: 05 Answer: d |
|
Question: 06 Answer: a |
Question: 07 Answer: e |
Question: 08 Answer: c |
Question: 09 Answer: e |
Question: 10 Answer: b |
Note: For any error in Databricks Certified Data Engineer Associate certification exam sample questions, please update us by writing an email on feedback@certfun.com.
- Data Engineer Associate Questions |
- Data Engineer Associate Quiz |
- Data Engineer Associate |
- Databricks Data Engineer Associate Certification |
- Databricks Data Engineer Associate Question Bank |
- Lakehouse Data Engineer Associate Mock Exam |
- Lakehouse Data Engineer Associate |
- Databricks Lakehouse Data Engineer Associate Certification |
- Data Engineer Associate Sample Questions |
- Databricks Data Engineer Associate Practice Test Free |
- Lakehouse Data Engineer Associate Certification Sample Questions
