Question 1

When using CLI or REST API to get results from jobs with multiple tasks, which statement correctly describes the response structure?

Options :

A : Each run of a job will have a unique job_id; all tasks within this job will have a unique job_id

B : Each run of a job will have a unique job_id; all tasks within this job will have a unique task_id

C : Each run of a job will have a unique orchestration_id; all tasks within this job will have a unique run_id

D : Each run of a job will have a unique run_id; all tasks within this job will have a unique task_id

E : Each run of a job will have a unique run_id; all tasks within this job will also have a unique run_id

Answer: D

Question 2

Which of the following establishes a Python file as a notebook in Databricks ?

Options :

A : The magic command %databricks on the first line of the file’s source code

B : The comment ‘# Databricks notebook source’ on the first line of the file’s source code

C : The import of the dbutils.notebook module in the file’s source code

D : The creation of a spark session using SparkSession.builder.getOrCreate() in the file’s source code

E : None of the above statements is correct. Notebooks are binary files with .pydb file extension.

Answer: B

Question 3

A data architect has designed a system in which two Structured Streaming jobs will concurrently write to a single bronze Delta table. Each job is subscribing to a different topic from an Apache Kafka source, but they will write data with the same schema. To keep the directory structure simple, a data engineer has decided to nest a checkpoint directory to be shared by both streams. The proposed directory structure is displayed below:

Databricks-Certified-Professional-Data-Engineer-page61-image5

Which statement describes whether this checkpoint directory structure is valid for the given scenario and why?

Options :

A : No; Delta Lake manages streaming checkpoints in the transaction log.

B : Yes; both of the streams can share a single checkpoint directory.

C : No; only one stream can write to a Delta Lake table

D : Yes; Delta Lake supports infinite concurrent writers.

E : No; each of the streams needs to have its own checkpoint directory.

Answer: E

Question 4

The data engineering team maintains the following join logic between three Delta tables:

1. df_students = spark.table("students")

2. df_courses = spark.table("courses")

3. df_enrollments = spark.table("enrollments")

4.

5. df_join_1 = (df_students.join(df_enrollments, df_students.student_id == df_enrollments.student_id)

6. .select(df_students.student_id,

7. df_students.student_name,

8. df_enrollments.course_id)

9. )

10.

11. df_join_2 = (df_join_1.join(df_courses, df_join_1.course_id == df_courses.course_id)

12. .select(df_join_1.student_id,

13. df_join_1.student_name,

14. df_courses.course_name)

15. )

16.

17. (df_join_2.write

18. .mode("overwrite")

19. .table("students_courses_details"))

Which statement describes the result of this code block each time it is executed ?

Options :

A : All records in the current version of the source tables will be considered in the join operations. The matched records will overwrite the students_courses_details table.

B : All records in the current version of the source tables will be considered in the join operations. The unmatched records will overwrite the students_courses_details table.

C : Only newly added records to any of the source tables will be considered in the join operations. The matched records will overwrite the students_courses_details table.

D : Only newly added records to any of the source tables will be considered in the join operations. The unmatched records will overwrite the students_courses_details table.

E : These join operations are stateful, meaning that they will wait for unmatched records to be added to the source tables prior to calculating the results.

Answer: A

Question 5

A developer has successfully configured their credentials for Databricks Repos and cloned a remote Git repository. They do not have privileges to make changes to the main branch, which is the only branch currently visible in their workspace.

Which approach allows this user to share their code updates without the risk of overwriting the work of their teammates?

Options :

A : Use Repos to create a new branch, commit all changes, and push changes to the remote Git repository.

B : Use Repos to create a fork of the remote repository, commit all changes, and make a pull request on the source repository.

C : Use Repos to pull changes from the remote Git repository; commit and push changes to a branch that appeared as changes were pulled.

D : Use Repos to merge all differences and make a pull request back to the remote repository.

Answer: A

Confidently Practice Online with Free Databricks-Certified-Professional-Data-Engineer Exam Cram

Buying Options: