Databricks DE · Topic 12.1
The DE Associate exam is 7 weighted domains. Study to the weights — map each domain to the stages you've already built, and rehearse the kind of code each domain tests.
▸ bigger bar = more of your exam score
Lakehouse, workspace/architecture, medallion. Lowest weight — know the concepts.
-- Recognize the 3-level Unity Catalog namespace (a platform fundamental): SELECT * FROM main.sales.orders; -- catalog.schema.table
Auto Loader (cloudFiles), COPY INTO, Lakeflow Connect, schema evolution.
# Auto Loader — incremental file ingestion (high-yield): (spark.readStream.format("cloudFiles") .option("cloudFiles.format", "json") .option("cloudFiles.schemaLocation", "/Volumes/main/raw/_schema") .load("/Volumes/main/raw/orders") .writeStream.option("checkpointLocation", "/Volumes/main/raw/_ckpt") .toTable("main.bronze.orders"))
Highest weight. Delta, MERGE, SDP, expectations, PySpark/Spark-SQL ETL.
-- MERGE (upsert) — a classic exam item: MERGE INTO main.silver.customers t USING updates s ON t.id = s.id WHEN MATCHED THEN UPDATE SET * WHEN NOT MATCHED THEN INSERT *;
Tasks & dependencies, scheduling with Quartz cron, retries, alerts.
# 6-field Quartz cron (NOT 5-field Unix) — frequently tested: schedule: { quartz_cron_expression: "0 0 2 * * ?", timezone_id: "UTC" } # 02:00 daily
Databricks Asset Bundles, Git folders, dev/prod targets, deploy flow.
databricks bundle validate # check config (CI on PRs) databricks bundle deploy -t prod # promote on merge
OPTIMIZE/ZORDER/Liquid Clustering, VACUUM, query profile, run monitoring.
-- Liquid Clustering — added to the current syllabus (know it): ALTER TABLE main.silver.events CLUSTER BY (event_date, region); OPTIMIZE main.silver.events;
Unity Catalog grants, row filters / column masks, ABAC, Delta Sharing.
-- A GRANT on the UC 3-level namespace (high-yield governance item): GRANT SELECT ON TABLE main.sales.orders TO `analysts`;
▸ proportional time blocks — spend where the points are
Ingestion + Transformation + Jobs ≈ 59% → the bulk of your time.