A daily batch pipeline loads sales data into a Lakehouse table. Sometimes the source system delivers files late, and the data for a previous day arrives after the pipeline has already run. The business requires that the final report always includes all data for the day, even if it arrives late. What is the best way to handle this?

Delete the entire table and reload all data every day.

Use a merge operation in the pipeline to upsert records into the existing table based on a unique key.

Append all incoming data to the table without checking for duplicates.

Ignore late-arriving data because the pipeline schedule is fixed.

A media company receives daily clickstream logs in Parquet format. A data engineer must write a PySpark notebook that removes duplicate events (same event_id) and then computes the total count of events per page. The data is large (multiple terabytes). Which code snippet should the engineer use?

df.distinct().groupBy('page').count()

df.drop_duplicates().groupBy('page').agg(count('event_id'))

df.groupBy('page').count().dropDuplicates(['event_id'])

df.dropDuplicates(['event_id']).groupBy('page').count()

What is KQL primarily used for in Microsoft Fabric?

Querying and transforming data in KQL databases

Microsoft Certified:Fabric Data Engineer Associate

Domain 2Objective 2

Ingest and Transform Batch Data DP-700 Practice Questions (Page 7)

Part of the Ingest and transform data domain, which accounts for 30–35% of the DP-700 exam. Microsoft does not publish an official question count, but from its 100-minute exam (~40–65 total, ~12–23 in this domain), expect 4–8 from this objective — we provide 48 practice questions to prepare you well beyond it. (estimate)

48questions here

10free pages

13concepts

30–35%of the exam

Questions 31–35

31foundation · easy
In PySpark, which method is used to perform grouping and aggregation on a DataFrame?
Select an answer first
32application · medium
A daily batch pipeline loads sales data into a Lakehouse table. Sometimes the source system delivers files late, and the data for a previous day arrives after the pipeline has already run. The business requires that the final report always includes all data for the day, even if it arrives late. What is the best way to handle this?
Select an answer first
33application · medium
A media company receives daily clickstream logs in Parquet format. A data engineer must write a PySpark notebook that removes duplicate events (same event_id) and then computes the total count of events per page. The data is large (multiple terabytes). Which code snippet should the engineer use?
Select an answer first
34foundation · easy
What is KQL primarily used for in Microsoft Fabric?
Select an answer first
35foundation · easy
Which SQL clause is used to group rows that have the same values in specified columns?
Select an answer first

Finished these 5 questions?

Review the revealed explanations, or continue through the curriculum.

Next 5 questions →Back to DP-700

Free Basic Practice is a study aid with revealable answers — not a scored exam. Examers.io is independent and not affiliated with or endorsed by Microsoft. “DP-700” is a trademark of its owner, used for identification only.

Ingest and Transform Batch Data DP-700 Practice Questions (Page 7)

Questions 31–35

In PySpark, which method is used to perform grouping and aggregation on a DataFrame?

A media company receives daily clickstream logs in Parquet format. A data engineer must write a PySpark notebook that removes duplicate events (same event_id) and then computes the total count of events per page. The data is large (multiple terabytes). Which code snippet should the engineer use?

What is KQL primarily used for in Microsoft Fabric?

Which SQL clause is used to group rows that have the same values in specified columns?

Keep studying — Ingest and transform data