最新的Databricks Databricks-Certified-Data-Engineer-Associate免費考試真題

問題1

A data engineer is cleaning a Bronze table. The requirement is to eliminate rows where either the customer_email field or the customer_phone field is NULL. The cleaning must be performed in one operation using a single method call.
Which PySpark approach supports filtering multiple columns for NULL values in one call?

A. df.dropna(subset=["customer_email", "customer_phone"])

B. df.filter(col("customer_email").isNotNull() & col("customer_phone").isNotNull())

C. df.na.drop(how="all")

D. df.where("customer_email IS NOT NULL").where("customer_phone IS NOT NULL")

正確答案: A

問題2

In which of the following scenarios should a data engineer use the MERGE INTO command instead of the INSERT INTO command?

A. When the target table is an external table

B. When the source is not a Delta table

C. When the source table can be deleted

D. When the location of the data needs to be changed

E. When the target table cannot contain duplicate records

正確答案: E

說明：（僅 Fast2test 成員可見）

問題3

A data engineer is cleaning a Bronze table that receives the same customer records from multiple source systems. Duplicate rows have the same customer_id and email values but different ingestion_timestamp values. The Silver table should contain only one record for each unique combination of customer_id and email.
Which PySpark operation correctly deduplicates the records based on the business keys?

A. df.distinct()

B. df.select("customer_id", "email").distinct()

C. df.dropDuplicates(["customer_id", "email"])

D. df.groupBy("customer_id", "email").agg(max("ingestion_timestamp").alias("latest_ts"))

正確答案: C

問題4

A data engineer has created a new database using the following command:
CREATE DATABASE IF NOT EXISTS customer360;
In which of the following locations will the customer360 database be located?

A. dbfs:/user/hive/warehouse

B. dbfs:/user/hive/customer360

C. dbfs:/user/hive/database/customer360

D. More information is needed to determine the correct response

正確答案: A

說明：（僅 Fast2test 成員可見）

問題5

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

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

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

A. Option D

B. Option B

C. Option C

D. Option E

E. Option A

正確答案: E

說明：（僅 Fast2test 成員可見）

問題6

Which of the following commands will return the location of database customer360?

A. USE DATABASE customer360;

B. ALTER DATABASE customer360 SET DBPROPERTIES ('location' = '/user'};

C. DROP DATABASE customer360;

D. DESCRIBE LOCATION customer360;

E. DESCRIBE DATABASE customer360;

正確答案: E

說明：（僅 Fast2test 成員可見）

問題7

A data engineer has realized that they made a mistake when making a daily update to a table. They need to use Delta time travel to restore the table to a version that is 3 days old. However, when the data engineer attempts to time travel to the older version, they are unable to restore the data because the data files have been deleted.
Which of the following explains why the data files are no longer present?

A. The DELETE HISTORY command was run on the table

B. The VACUUM command was run on the table

C. The HISTORY command was run on the table

D. The OPTIMIZE command was nun on the table

E. The TIME TRAVEL command was run on the table

正確答案: B

說明：（僅 Fast2test 成員可見）

問題8

A data engineer manages multiple external tables linked to various data sources. The data engineer wants to manage these external tables efficiently and ensure that only the necessary permissions are granted to users for accessing specific external tables.
How should the data engineer manage access to these external tables?

A. Use Unity Catalog to manage access controls and permissions for each external table individually.

B. Create a single user role with full access to all external tables and assign it to all users.

C. Grant permissions on the Databricks workspace level, which will automatically apply to all external tables.

D. Set up Azure Blob Storage permissions at the container level, allowing access to all external tables.

正確答案: A

問題9

A data engineer has a Job that has a complex run schedule, and they want to transfer that schedule to other Jobs.
Rather than manually selecting each value in the scheduling form in Databricks, which of the following tools can the data engineer use to represent and submit the schedule programmatically?

A. pyspark.sql.types.DateType

B. pyspark.sql.types.TimestampType

C. Cron syntax

D. There is no way to represent and submit this information programmatically

E. datetime

正確答案: C

說明：（僅 Fast2test 成員可見）

問題10

Which of the following must be specified when creating a new Delta Live Tables pipeline?

A. A key-value pair configuration

B. A location of a target database for the written data

C. At least one notebook library to be executed

D. A path to cloud storage location for the written data

E. The preferred DBU/hour cost

正確答案: C

說明：（僅 Fast2test 成員可見）

問題11

A data engineer wants to schedule their Databricks SQL dashboard to refresh once per day, but they only want the associated SQL endpoint to be running when it is necessary.
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 set up the dashboard's SQL endpoint to be serverless.

B. They can reduce the cluster size of the SQL endpoint.

C. They can ensure the dashboard's SQL endpoint is not one of the included query's SQL endpoint.

D. They can ensure the dashboard's SQL endpoint matches each of the queries' SQL endpoints.

E. They can turn on the Auto Stop feature for the SQL endpoint.

正確答案: A

說明：（僅 Fast2test 成員可見）

問題12

A notebook task named check_volume calculates a daily data volume and writes it to a Lakeflow Jobs task value named record_count. If the count is greater than 1 million, the job should run high_volume_pipeline; otherwise, it should run normal_pipeline.
Which control-flow feature should be used?

A. Add an If/else condition task that reads the record_count task value and routes execution to different downstream tasks.

B. Configure Run if conditions based purely on task status.

C. Configure additional retries for check_volume until the count exceeds the threshold.

D. Use a For each task over record_count and stop when the value is below the threshold.

正確答案: A

問題13

A data engineer is designing a cost-optimized, event-driven pipeline. They configure a Lakeflow Job with a File Arrival trigger to watch an Amazon S3 bucket. The job runs a notebook that uses Auto Loader with trigger(availableNow=True) to ingest data into a Bronze table.
What is the technical relationship between the File Arrival trigger and Auto Loader in this integration pattern?

A. Using a File Arrival trigger requires the engineer to disable Auto Loader checkpointing to prevent the job from processing the same file multiple times.

B. The File Arrival trigger starts the job run, while Auto Loader uses its internal checkpoint to independently identify and process only the new files that have arrived since the last successful commit.

C. The File Arrival trigger automatically passes the specific file path of the new arrival to Auto Loader, allowing the engineer to omit the source-path configuration from the code.

D. Auto Loader must be configured in File Notification mode to work with a Lakeflow Job File Arrival trigger.

正確答案: B

問題14

A data engineer needs to ingest from both streaming and batch sources for a firm that relies on highly accurate dat a. Occasionally, some of the data picked up by the sensors that provide a streaming input are outside the expected parameters. If this occurs, the data must be dropped, but the stream should not fail.
Which feature of Delta Live Tables meets this requirement?

A. Expectations

B. Monitoring

C. Change Data Capture

D. Error Handling

正確答案: D

最新的Databricks Certified Data Engineer Associate - Databricks-Certified-Data-Engineer-Associate免費考試真題

聯系我們

站內鏈接

最新更新