productiveAnalytics/databricks-lakeflow-data-pipelines

2026-08-21

Language: Unknown (Python + SQL)

Link: https://github.com/productiveAnalytics/databricks-lakeflow-data-pipelines

This repository tackles one of the trickier corners of modern data engineering: implementing Slowly Changing Dimensions (SCD Type 1 and Type 2) as streaming pipelines using Databricks' Lakeflow Declarative Pipelines (formerly Delta Live Tables, or DLT). It offers concrete examples in both Python and SQL, which is unusual — most SCD tutorials pick one flavor and stick with it.

For the uninitiated, SCD patterns are how data warehouses handle dimension records that change over time:

What makes this repo interesting is that it bridges a real gap. Databricks recently rebranded DLT to Lakeflow and pushed streaming SCD support via APPLY CHANGES INTO, but public examples are still thin — most Google results return marketing pages or Databricks' own docs. Having a working reference implementation with side-by-side Python and SQL versions is genuinely useful for teams trying to migrate batch merge logic into declarative streaming pipelines.

Who would benefit:

The zero-star status probably reflects newness and a narrow audience rather than quality — Databricks-specific tooling doesn't attract drive-by GitHub stars, but the people who need it, really need it.

Why check it out: A rare working reference for streaming SCD Type 1/Type 2 pipelines in Databricks Lakeflow, with both Python and SQL implementations.

All newsletters