최신 Databricks-Certified-Professional-Data-Engineer 무료덤프 - Databricks Certified Professional Data Engineer

문제1

A Delta Lake table representing metadata about content from user has the following schema:
user_id LONG, post_text STRING, post_id STRING, longitude FLOAT, latitude FLOAT, post_time TIMESTAMP, date DATE Based on the above schema, which column is a good candidate for partitioning the Delta Table?

A. Post_time

B. Date

C. User_id

D. Post_id

정답: B

설명: (DumpTOP 회원만 볼 수 있음)

문제2

The marketing team is looking to share data in an aggregate table with the sales organization, but the field names used by the teams do not match, and a number of marketing specific fields have not been approval for the sales org.
Which of the following solutions addresses the situation while emphasizing simplicity?

A. Add a parallel table write to the current production pipeline, updating a new sales table that varies as required from marketing table.

B. Create a view on the marketing table selecting only these fields approved for the sales team alias the names of any fields that should be standardized to the sales naming conventions.

C. Use a CTAS statement to create a derivative table from the marketing table configure a production jon to propagation changes.

D. Create a new table with the required schema and use Delta Lake's DEEP CLONE functionality to sync up changes committed to one table to the corresponding table.

정답: B

설명: (DumpTOP 회원만 볼 수 있음)

문제3

Which statement describes Delta Lake Auto Compaction?

A. An asynchronous job runs after the write completes to detect if files could be further compacted; if yes, an optimize job is executed toward a default of 1 GB.

B. An asynchronous job runs after the write completes to detect if files could be further compacted; if yes, an optimize job is executed toward a default of 128 MB.

C. Data is queued in a messaging bus instead of committing data directly to memory; all data is committed from the messaging bus in one batch once the job is complete.

D. Before a Jobs cluster terminates, optimize is executed on all tables modified during the most recent job.

E. Optimized writes use logical partitions instead of directory partitions; because partition boundaries are only represented in metadata, fewer small files are written.

정답: B

설명: (DumpTOP 회원만 볼 수 있음)

문제4

The downstream consumers of a Delta Lake table have been complaining about data quality issues impacting performance in their applications. Specifically, they have complained that invalid latitude and longitude values in the activity_details table have been breaking their ability to use other geolocation processes.
A junior engineer has written the following code to add CHECK constraints to the Delta Lake table:

A senior engineer has confirmed the above logic is correct and the valid ranges for latitude and longitude are provided, but the code fails when executed.
Which statement explains the cause of this failure?

A. The activity details table already contains records that violate the constraints; all existing data must pass CHECK constraints in order to add them to an existing table.

B. The activity details table already exists; CHECK constraints can only be added during initial table creation.

C. Because another team uses this table to support a frequently running application, two-phase locking is preventing the operation from committing.

D. The current table schema does not contain the field valid coordinates; schema evolution will need to be enabled before altering the table to add a constraint.

E. The activity details table already contains records; CHECK constraints can only be added prior to inserting values into a table.

정답: A

설명: (DumpTOP 회원만 볼 수 있음)

문제5

The following table consists of items found in user carts within an e-commerce website.

The following MERGE statement is used to update this table using an updates view, with schema evaluation enabled on this table.

How would the following update be handled?

A. The update is moved to separate ''restored'' column because it is missing a column expected in the target schema.

B. The new restored field is added to the target schema, and dynamically read as NULL for existing unmatched records.

C. The new nested field is added to the target schema, and files underlying existing records are updated to include NULL values for the new field.

D. The update throws an error because changes to existing columns in the target schema are not supported.

정답: C

설명: (DumpTOP 회원만 볼 수 있음)

문제6

A data pipeline uses Structured Streaming to ingest data from kafka to Delta Lake. Data is being stored in a bronze table, and includes the Kafka_generated timesamp, key, and value. Three months after the pipeline is deployed the data engineering team has noticed some latency issued during certain times of the day.
A senior data engineer updates the Delta Table's schema and ingestion logic to include the current timestamp (as recoded by Apache Spark) as well the Kafka topic and partition. The team plans to use the additional metadata fields to diagnose the transient processing delays:
Which limitation will the team face while diagnosing this problem?

A. Updating the table schema requires a default value provided for each file added.

B. New fields not be computed for historic records.

C. Updating the table schema will invalidate the Delta transaction log metadata.

D. Spark cannot capture the topic partition fields from the kafka source.

정답: B

설명: (DumpTOP 회원만 볼 수 있음)

문제7

A Databricks job has been configured with 3 tasks, each of which is a Databricks notebook. Task A does not depend on other tasks. Tasks B and C run in parallel, with each having a serial dependency on Task A.
If task A fails during a scheduled run, which statement describes the results of this run?

A. Unless all tasks complete successfully, no changes will be committed to the Lakehouse; because task A failed, all commits will be rolled back automatically.

B. Because all tasks are managed as a dependency graph, no changes will be committed to the Lakehouse until all tasks have successfully been completed.

C. Tasks B and C will be skipped; task A will not commit any changes because of stage failure.

D. Tasks B and C will be skipped; some logic expressed in task A may have been committed before task failure.

E. Tasks B and C will attempt to run as configured; any changes made in task A will be rolled back due to task failure.

정답: D

설명: (DumpTOP 회원만 볼 수 있음)

문제8

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 .

A. Option E

B. Option D

C. Option C

D. Option B

E. Option A

정답: A

설명: (DumpTOP 회원만 볼 수 있음)

문제9

The data governance team is reviewing user for deleting records for compliance with GDPR. The following logic has been implemented to propagate deleted requests from the user_lookup table to the user aggregate table.

Assuming that user_id is a unique identifying key and that all users have requested deletion have been removed from the user_lookup table, which statement describes whether successfully executing the above logic guarantees that the records to be deleted from the user_aggregates table are no longer accessible and why?

A. No: the change data feed only tracks inserts and updates not deleted records.

B. Yes: Delta Lake ACID guarantees provide assurance that the DELETE command successed fully and permanently purged these records.

C. No: the Delta Lake DELETE command only provides ACID guarantees when combined with the MERGE INTO command

D. No: files containing deleted records may still be accessible with time travel until a BACUM command is used to remove invalidated data files.

정답: D

설명: (DumpTOP 회원만 볼 수 있음)

문제10

A junior data engineer seeks to leverage Delta Lake's Change Data Feed functionality to create a Type 1 table representing all of the values that have ever been valid for all rows in a bronze table created with the property delta.enableChangeDataFeed = true. They plan to execute the following code as a daily job:

Which statement describes the execution and results of running the above query multiple times?

A. Each time the job is executed, only those records that have been inserted or updated since the last execution will be appended to the target table giving the desired result.

B. Each time the job is executed, newly updated records will be merged into the target table, overwriting previous values with the same primary keys.

C. Each time the job is executed, the differences between the original and current versions are calculated; this may result in duplicate entries for some records.

D. Each time the job is executed, the entire available history of inserted or updated records will be appended to the target table, resulting in many duplicate entries.

E. Each time the job is executed, the target table will be overwritten using the entire history of inserted or updated records, giving the desired result.

정답: D

설명: (DumpTOP 회원만 볼 수 있음)

최신 Databricks-Certified-Professional-Data-Engineer 무료덤프 - Databricks Certified Professional Data Engineer

우리와 연락하기

유용한 링크

최신 업데이트