All Microsoft exams
Free DP-750 practice test: 30 questions with answers
30 original questions for Implementing Data Engineering Solutions Using Azure Databricks, drawn from every topic area. Answer each one to see whether you got it right and why. No sign-up.
- Free questions
- 30
- Full bank
- 100 questions
All 30 DP-750 questions with answers
The same questions as the test above, grouped by exam topic. Open any question to see the answer and explanation.
Ingest and transform data (10 questions)
Question 1
A data engineer must continuously ingest new JSON files that arrive in an Azure Data Lake Storage folder, with the schema evolving over time. Which Databricks feature is designed for this incremental file ingestion?
- AA one-time COPY INTO run each Friday
- BAuto Loader with schema evolution enabled
- CA manual notebook that lists the folder and reads everything
- DDelta Sharing with a read-only share
Show answer and explanationHide answer
Correct answer: BAuto Loader incrementally discovers new files and can evolve the schema as new fields appear, which suits continuous ingestion. A weekly COPY INTO misses timely loads, manual full reads reprocess everything, and Delta Sharing is for sharing data with other consumers.
Question 2
A streaming pipeline in Databricks must write each micro-batch exactly once to a Delta table after a failure and restart. Which mechanism provides this guarantee?
- ACheckpoint location for the streaming query, combined with idempotent Delta writes
- BWriting with no checkpoint so the job restarts from scratch on every run
- CStoring the offsets in a notebook widget that is reset whenever the cluster restarts
- DDisabling transactions in the Delta table so writes skip the commit log and apply in place
Show answer and explanationHide answer
Correct answer: AA checkpoint records progress so the query resumes from the last committed batch, and Delta transactions make writes idempotent. Without a checkpoint the job reprocesses data, disabling transactions removes atomicity, and widgets do not persist offsets reliably.
Question 3
A team wants a declarative pipeline in which tables are defined by their queries, and Databricks manages dependencies, retries and data quality expectations. Which framework provides this?
- AStructured Streaming with manual dependency code
- BLakeflow Spark Declarative Pipelines
- CA cron job that runs notebooks in random order
- DPower BI dataflows
Show answer and explanationHide answer
Correct answer: BDeclarative pipelines let engineers define datasets as queries and manage dependencies, retries and expectations automatically. Manual streaming code and cron-driven notebooks require the team to manage that orchestration, and Power BI dataflows are a different product.
Question 4
A Delta table receives many small files from frequent streaming writes, which slows down queries. Which maintenance operation compacts these files into larger ones?
- AVACUUM with a retention of zero hours
- BOPTIMIZE on the table
- CSHOW TABLES
- DDESCRIBE HISTORY
Show answer and explanationHide answer
Correct answer: BOPTIMIZE rewrites small files into larger ones, improving read performance. VACUUM removes files no longer referenced, DESCRIBE HISTORY shows table versions, and SHOW TABLES lists tables without changing file layout.
Question 5
An engineer must merge daily change records into a Delta table, updating matching rows and inserting new ones in one atomic operation. Which statement fits?
- AINSERT OVERWRITE on the entire table every day
- BMERGE INTO with a matching condition on the business key
- CCREATE OR REPLACE TABLE AS SELECT with no join keys
- DTRUNCATE then a separate INSERT in another job
Show answer and explanationHide answer
Correct answer: BMERGE INTO updates matched rows and inserts unmatched ones atomically based on the key condition. Overwriting everything each day is costly, CTAS does not upsert, and truncate-then-insert in separate jobs risks partial results.
Question 6
A data engineer needs to read a Delta table as it was at a specific version to investigate a bad load. Which feature supports this?
- ATime travel with VERSION AS OF or TIMESTAMP AS OF
- BRestoring the backup from another region only
- CReading the raw Parquet files in the storage folder directly
- DExporting the table to CSV by hand
Show answer and explanationHide answer
Correct answer: ADelta time travel queries earlier versions of a table by version number or timestamp. Restoring from another region is slow and not needed for this, and reading raw Parquet files does not respect the transaction log.
Question 7
A Spark job joins a very large fact table with a small dimension table and runs slowly because of shuffling. Which optimization is most appropriate?
- AConverting the fact table to a single CSV file
- BIncreasing the number of shuffle partitions to ten million
- CRunning the join on a single worker
- DA broadcast join hint for the small dimension table
Show answer and explanationHide answer
Correct answer: DBroadcasting the small table sends it to every executor and avoids shuffling the large table. A single CSV file and a single worker remove parallelism, and huge shuffle partition counts add overhead.
Question 8
A notebook needs to read a CSV file that has a header row and a semicolon delimiter. Which read option set is correct for Spark?
- Aheader set to true and sep set to a semicolon
- Bdelimiter set to the literal word tab
- CinferSchema set to the full file path
- Dheader set to false, sep set to a comma
Show answer and explanationHide answer
Correct answer: AThe header option tells Spark the first row contains column names, and sep sets the delimiter to a semicolon. The other options set the wrong delimiter or treat the header incorrectly.
Question 9
A Delta table is written by several jobs at the same time, and occasionally two jobs modify the same rows. Which Delta feature detects and prevents conflicting writes?
- AOptimistic concurrency control with conflict detection on the transaction log
- BWriting to separate physical copies of the table on each scheduled run
- CUsing a shared text file on the driver as a lock for each writer job
- DTurning off transactions for speed by writing directly to Parquet files
Show answer and explanationHide answer
Correct answer: ADelta uses optimistic concurrency with conflict detection on the transaction log, so conflicting commits fail and can be retried. Disabling transactions removes safety, separate copies break the single source of truth, and text-file locks are unreliable.
Question 10
Which two techniques reduce the cost and time of a daily batch load that appends only new rows to a large Delta table? (Choose two.)
- AFilter the source to rows changed since the last successful watermark
- BRewrite the entire target table every day with overwrite
- CRead the full source history on every run
- DUse incremental ingestion such as Auto Loader or a change feed
- EDisable partition pruning on the target table
Show answer and explanationHide answer
Correct answer: A, DProcessing only new or changed rows using a watermark or incremental ingestion avoids reprocessing the whole dataset. Full overwrites, full history reads and disabled pruning all increase cost and time.
Operate and optimize data pipelines (10 questions)
Question 11
A scheduled Databricks job must run a notebook every night and notify the on-call engineer if it fails. Which feature provides this?
- AA manual run each morning by an analyst who checks the job output
- BA personal reminder in a shared team calendar to check the job daily
- CA cell that sleeps until morning, then a person reruns the notebook
- DDatabricks Jobs with a schedule and failure notifications
Show answer and explanationHide answer
Correct answer: DDatabricks Jobs runs tasks on a schedule and can send notifications on failure, which automates operations. Calendar reminders, sleeping cells and manual runs rely on people and are not reliable.
Question 12
A multi-task job has a transformation task that must run only after an ingestion task succeeds, and a reporting task that must run after both. Which job feature defines these dependencies?
- ASeparate schedules for each task at random times
- BAsking the engineer to start each task by hand
- CCopying the code of all tasks into one cell
- DTask dependencies in the job definition
Show answer and explanationHide answer
Correct answer: DTask dependencies in a multi-task job define the order and ensure each task waits for its upstream tasks. Random schedules, merged cells and manual starts do not enforce the required order.
Question 13
A cluster used for a nightly job is kept running for hours after the job finishes, which increases cost. Which setting addresses this?
- ATurning on more worker nodes for the entire day so each job finishes sooner
- BAuto-termination on the cluster or job cluster that stops it after a period of inactivity
- CDisabling the job's logs to reduce cost of storage writes while removing the stack traces used by engineers
- DRunning the job every minute on a dedicated interactive cluster with auto-termination disabled for stability
Show answer and explanationHide answer
Correct answer: BAuto-termination stops idle clusters after a set time, which removes unnecessary compute cost. More workers increase cost, disabling logs saves little and hides problems, and running every minute multiplies cost.
Question 14
A nightly job sometimes runs far longer than usual because one partition holds most of the data. Which technique helps balance the work?
- AAdaptive query execution with skew handling enabled
- BRemoving every partition from the Delta table
- CIncreasing the driver memory and keeping executors
- DForcing the job to run on one core of a single executor node
Show answer and explanationHide answer
Correct answer: AAdaptive query execution can detect and split skewed partitions at runtime, which rebalances the work. A single core removes parallelism, removing partitions does not fix skew, and driver memory does not affect executor-side skew.
Question 15
A team wants to deploy the same Databricks job definitions to development and production workspaces from source control. Which approach is best?
- ACopy the job JSON from a colleague's email and paste it into each workspace's jobs UI by hand
- BRecreate each job by hand in each workspace through the Jobs UI, copying cluster settings and libraries
- CDefine jobs as code in a bundle and deploy per environment through a CI/CD pipeline
- DEdit production jobs directly and skip source control so changes ship faster on Friday afternoons
Show answer and explanationHide answer
Correct answer: CDefining jobs as code in a bundle and deploying through CI/CD keeps environments consistent and reviewable. Manual recreation, emailed JSON and direct production edits create drift and untracked change.
Question 16
A streaming job's lag is growing because the input rate has increased. Which action is most direct for improving throughput?
- AScale the cluster or adjust the trigger and parallelism to match the input rate
- BStop the stream and wait for the backlog to disappear while new input keeps arriving
- CTurn off the checkpoint so that old data is skipped and the stream starts from the latest offset
- DReduce the number of partitions in the source to one so each micro-batch is read by a single task
Show answer and explanationHide answer
Correct answer: AScaling compute and tuning trigger and parallelism lets the stream process data faster than it arrives. Stopping the stream lets lag grow, disabling checkpoints risks data loss or duplicates, and one partition limits parallelism.
Question 17
A data quality rule requires that no order row has a null customer identifier. The pipeline should record violations and keep processing the valid rows. Which declarative feature supports this?
- AA manual SQL check job run after the pipeline finishes
- BA comment in the table description that tells analysts to check null rows by hand
- CExpectations with a warn or drop action in the pipeline definition
- DDeleting every row that contains a null value in a column of the orders table
Show answer and explanationHide answer
Correct answer: CExpectations evaluate a rule on each row and can warn or drop violations while recording metrics, which fits this requirement. Manual checks after the fact, table comments and deleting every row with any null value do not meet the requirement.
Question 18
Which two actions help diagnose a slow Spark job in Databricks? (Choose two.)
- ARestart the workspace each time the job runs slowly
- BDelete the cluster logs before reviewing them
- CIncrease the notebook font size for easier reading
- DCheck the query profile or execution plan for expensive operations
- EReview the Spark UI stages for skewed tasks and large shuffle spills
Show answer and explanationHide answer
Correct answer: D, EThe Spark UI shows stage-level skew and spills, and query profiles or plans show which operations are expensive. Restarting the workspace, deleting logs and changing fonts do not diagnose performance.
Question 19
A nightly pipeline has tasks that depend on external APIs that sometimes time out. The operations team wants failed tasks retried automatically a limited number of times. Which job setting provides this?
- ATask retry settings with a maximum retry count and retry interval
- BTurning off notifications for tasks so errors go unnoticed by the team
- CSetting the job timeout to zero, so each run is cancelled before it starts
- DRunning the job continuously in a loop with no limit on attempts until success
Show answer and explanationHide answer
Correct answer: ATask retries with a maximum count and interval handle transient failures without endless loops. Continuous loops waste resources, silent failures hide problems, and a zero timeout fails every run.
Question 20
A daily job must start only when a new file lands in a storage location, rather than running on a fixed schedule. Which trigger type should be configured?
- AA manual run started by the on-call engineer
- BA file arrival trigger on the storage location
- CA trigger on the cluster's start event and init script
- DA cron schedule that polls every minute for new data
Show answer and explanationHide answer
Correct answer: BA file arrival trigger starts the job when new files arrive, which matches the event-driven requirement. Frequent cron runs waste compute, and manual or cluster-start triggers do not respond to the arriving data.
Manage data governance and security (10 questions)
Question 21
A company uses Unity Catalog and wants analysts to see only the rows for their own region in a shared table. Which feature enforces this at query time?
- AA separate copy of the table for each analyst
- BA view that the analyst can edit and reshape
- CRow filters applied to the table in Unity Catalog
- DA comment that asks analysts to filter
Show answer and explanationHide answer
Correct answer: CRow filters in Unity Catalog are enforced by the governance layer for each query, so users only see permitted rows. Copies multiply data, comments are not enforcement, and editable views allow users to remove the restriction.
Question 22
A sensitive column containing customer email addresses must be hidden from most users but readable by a compliance group. Which Unity Catalog capability should be used?
- ASharing the column through a public link on a Delta Sharing share with no expiry
- BDeleting the column for everyone using ALTER TABLE DROP
- CEncrypting the entire workspace with one customer-managed key in Azure Key Vault
- DColumn masks applied to the column, with the compliance group exempted
Show answer and explanationHide answer
Correct answer: DColumn masks return masked values to most users while allowing the authorized group to read the raw data. Deleting the column removes data needed by compliance, workspace-wide encryption does not control column visibility, and public links expose the data.
Question 23
A data platform team must grant a Databricks group read access to a schema in Unity Catalog without giving it rights to modify the tables. Which privilege should be granted?
- AALL PRIVILEGES on the regional metastore
- BMANAGE on the catalog for the admin group
- CCREATE TABLE on the schema for new data
- DUSE SCHEMA and SELECT on the tables
Show answer and explanationHide answer
Correct answer: DUSE SCHEMA with SELECT allows reading the tables and no modification. ALL PRIVILEGES and MANAGE grant administrative rights, and CREATE TABLE allows creating new tables rather than reading existing ones.
Question 24
An auditor asks who accessed a sensitive Unity Catalog table during the last quarter. Which source provides this evidence?
- AThe notebook's cell output from last month's scheduled runs
- BThe cluster's Spark UI with no history retained after the job finishes
- CUnity Catalog audit logs delivered to the monitoring destination
- DThe table's comment field, which holds free-text remarks
Show answer and explanationHide answer
Correct answer: CAudit logs record access events for Unity Catalog objects with the principal and time, and they can be delivered for retention. Cell output, the Spark UI and table comments do not provide a reliable access record.
Question 25
A workspace is connected to an Azure Data Lake Storage account. The team wants Databricks to access the storage without storing account keys in notebooks. Which approach is recommended?
- APasting the storage account key into each notebook cell so every session can read the container directly
- BSharing a SAS token in a chat message with the vendor support team so they can troubleshoot the ADLS mount
- CA Unity Catalog storage credential backed by a managed identity or access connector with a role on the storage account
- DMaking the container public for read access so anonymous clients on the internet can list and download every blob without authenticating
Show answer and explanationHide answer
Correct answer: CA storage credential backed by a managed identity or access connector avoids keys in code and enables governed access through Unity Catalog. Keys in notebooks, shared SAS tokens and public containers all expose access.
Question 26
Which two practices protect data in a Databricks workspace according to least privilege? (Choose two.)
- AGrant access to groups rather than individual users and limit privileges to what each group needs
- BScope privileges to specific catalogs and schemas for each group
- CUse personal access tokens with admin rights for daily work
- DStore secrets in notebook code so that they are easy to share
- EGrant ALL PRIVILEGES to every analyst for convenience
Show answer and explanationHide answer
Correct answer: A, BGranting access through groups and limiting privileges to what each group needs applies least privilege, and scoping privileges to specific catalogs and schemas keeps access narrow. Broad readability across the tenant, admin tokens and secrets in notebooks all expand exposure.
Question 27
Which two statements about Unity Catalog governance are correct? (Choose two.)
- APermissions are managed centrally for objects across workspaces attached to the metastore
- BGovernance applies only to Python notebooks and not SQL
- CEvery table must be copied into each workspace to be governed
- DLineage is captured automatically for many tables and queries
- EAudit information is available only in the cluster driver logs
Show answer and explanationHide answer
Correct answer: A, DUnity Catalog captures lineage and manages permissions centrally across workspaces attached to a metastore. Governance covers SQL and Python alike, copies are unnecessary, and audit data is not limited to driver logs.
Question 28
A Unity Catalog administrator wants a group to use a catalog and create tables in one schema, but not to drop tables created by others. Which pattern implements this?
- AGrant the group the full set of privileges on the metastore so it can manage catalogs, schemas and tables
- BAdd the group to the workspace admins group so it inherits administrator rights across the workspace
- CMake the group the owner of the catalog so it can rename, drop objects inside it, including tables created by others
- DGrant USE CATALOG, USE SCHEMA and CREATE TABLE on the schema, without MANAGE or ownership of other tables
Show answer and explanationHide answer
Correct answer: DGranting the usage and create privileges on the schema allows creating tables without broad ownership of others' objects. Metastore-wide privileges, admin groups and catalog ownership all exceed the requirement.
Question 29
A data product in Unity Catalog must be shared with a partner organization that uses a different Databricks account, without copying the data. Which feature is designed for this?
- AExporting the table to a shared drive
- BDelta Sharing
- CGiving the partner the metastore admin password
- DEmailing a CSV extract each day
Show answer and explanationHide answer
Correct answer: BDelta Sharing gives recipients governed read access to shared data without copying it, across accounts and platforms. Exports, email extracts and shared admin passwords create copies or unacceptable access.
Question 30
A governance team wants to tag all columns containing personal data across catalogs so that policies can be applied by tag. Which Unity Catalog capability supports this?
- ANaming columns with the prefix pii_ in their names and aliases
- BStoring the tags as a comment at the top of a notebook that the team opens
- CTags on columns and tables, used to find and govern sensitive data
- DUsing the cluster name as a tag on each table and column in the catalog
Show answer and explanationHide answer
Correct answer: CGoverned tags on columns and tables let teams find sensitive data and apply policies by tag consistently. Name prefixes are fragile, notebook comments are not searchable governance metadata, and cluster names describe compute, not data.
Want more DP-750 questions?
The full bank has 100 questions with answers and explanations, as a PDF, an online practice exam, or both.
Both formats together. The best value.
Instant access after payment, with 90 days of updates. Checkout is on our store, AIExamCerts.