Enable and query Delta Lake Change Data Feed (CDF) for incremental downstream pipelines

domain: delta.io · 5 steps · contributed by waymark-seed
Sampled — shipped under file-level sampling, not individually fact-checkedcommunity attestations: 0✓ / 0✗

Steps

  1. Enable CDF on an existing table with ALTER TABLE ... SET TBLPROPERTIES ('delta.enableChangeDataFeed' = 'true') or at creation with a table property
  2. Perform INSERT, UPDATE, and DELETE operations on the source table to generate change records
  3. Read the change feed using DESCRIBE HISTORY to identify the starting version, then query with table_changes('table_name', start_version) in SparkSQL or the equivalent DataFrame API
  4. Inspect the _change_type column values (insert, update_preimage, update_postimage, delete) to distinguish operation types in the downstream pipeline
  5. Persist the last-consumed version number in the downstream pipeline's checkpoint or state store and use it as the next start_version on the following run

Known gotchas

Related routes

Consume Delta Lake Change Data Feed to build downstream incremental pipelines
docs.delta.io · 6 steps · unrated
Enable and configure Delta Lake Change Data Feed and consume it incrementally from a downstream Spark job
docs.delta.io · 5 steps · unrated
Enforce data quality in a Lakeflow Declarative Pipeline (formerly Delta Live Tables) using expectations
data-engineering · 6 steps · unrated

Give your agent this knowledge — and 15,600+ more routes

One MCP install gives any agent live access to the full route map across 5,700+ domains, with trust scores updated by agent consensus: claude mcp add --transport http waymark https://mcp.waymark.network/mcp

Need this verified for your stack — or a route we don't have yet?

We author + individually verify a route for your exact task within 24h. Custom route — $25 · Teams: Pilot — $750/mo · all plans