Implementing Analytics Solutions Using Microsoft Fabric DP-600 Exam Questions with Experts Answers Updated Recently

Add the pickupDate column: .withColumn("pickupDate", df["pickupDateTime"].cast("date"))

Filter the DataFrame: .filter("fareAmount > 0 AND fareAmount < 100")

In PySpark, you can add a new column to a DataFrame using the .withColumn method, where the first argument is the new column name and the second argument is the expression to generate the content of the new column. Here, we use the .cast("date") function to extract only the date part from a timestamp. To filter the DataFrame, you use the .filter method with a condition that selects rows where fareAmount is greater than 0 and less than 100, thus ensuring only positive values less than 100 are included.

Comprehensive Detailed Explanation

We have a KQL table (TaxiData) with columns:

VendorID

tpep_pickup_datetime (timestamp)

payment_type

total_amount

The requirement:

Create a new column FirstPickupDateTime

It should contain the first pickup timestamp per hour

Partitioning should be done by payment_type

Step 1: Which windowing function?

row_cumsum → running cumulative sum (not needed here).

row_rank_dense → assigns ranks without gaps, but does not guarantee minimum value only.

row_rank_min → gives the first/minimum value in each window partition. ✅ Correct.

row_window_session → sessionization of events, not required.

So, the correct function is row_rank_min.

Step 2: Which comparison operator?

We need to select the row where the rank = 1 (the first per partition).

So the correct operator is == (equals).

Step 3: Partitioning

The KQL query should partition by:

bin(tpep_pickup_datetime, 1h) → buckets data into 1-hour windows

payment_type → partitions further by payment type

Completed KQL Query

TaxiData

| sort by tpep_pickup_datetime asc, payment_type asc

| extend FirstPickupDateTime = row_rank_min(tpep_pickup_datetime, 1h, 0m, payment_type)

| where FirstPickupDateTime == 1

This assigns a rank within each 1-hour, per-payment-type window, then keeps the first pickup timestamp.

Why This Works

row_rank_min → ensures we capture the first occurrence in each hour.

== → filters only the first row per partition.

bin(..., 1h) ensures grouping is by hour.

References

Kusto row_rank_min() function

KQL window functions

o add new data to the Delta table while meeting the specified requirements:

You should use the append mode to ensure that all new data is added to the table without affecting the existing rows.

You should set the mergeSchema option to true to allow the schema of the Delta table to be updated with the new columns found in the DataFrame.

The completed code would look like this:

df.write.format("delta").mode("append")

option("mergeSchema", "true")

saveAsTable("Lakehouse1.TableName")

Comprehensive Detailed Explanation

When assigning permissions to roles in a Fabric workspace for analytics workloads, you must align permissions with the responsibilities and tools typically used by each persona:

1. Data Engineers

Their primary tasks include building and transforming data pipelines, as well as making datasets usable by others.

The appropriate permission is Build Reports on the default dataset, because this allows them to create and manage reports using the curated semantic model while preparing data for analysts and scientists.

2. Data Analysts

Analysts work heavily with Apache Spark for exploratory analysis, cleansing, and shaping data.

The correct permission is Read All Apache Spark, as this grants them the ability to query and analyze Spark-based data directly without elevated permissions that are unnecessary for their role.

3. Data Scientists

Data scientists often use SQL analytics endpoints to run queries, train models, and integrate data into machine learning workflows.

The correct permission is Read All SQL analytics endpoint data, since it enables direct programmatic access to the SQL endpoint, which is needed for advanced modeling and experimentation.

Summary of Selections:

DataEngineers → Build Reports on the default dataset

DataAnalysts → Read All Apache Spark

DataScientists → Read All SQL analytics endpoint data

References (Microsoft Fabric – DP-600 exam scope):

Workspace roles and permissions in Microsoft Fabric

SQL analytics endpoint in Fabric

Apache Spark in Microsoft Fabric