databricks-spark-declarative-pipelines

Build Databricks Lakeflow Spark Declarative Pipelines with SDP/LDP SQL or pyspark.pipelines code.

Updated May 20, 2026
One-click install
npx skills add https://github.com/ice-droid-99/BI-Dashboard-Generation-Agent-in-Databricks- --skill databricks-spark-declarative-pipelines-ice-droid-99
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: databricks-spark-declarative-pipelines
Source: https://github.com/ice-droid-99/BI-Dashboard-Generation-Agent-in-Databricks-/tree/main/.gemini/skills/databricks-spark-declarative-pipelines
Command: npx skills add https://github.com/ice-droid-99/BI-Dashboard-Generation-Agent-in-Databricks- --skill databricks-spark-declarative-pipelines-ice-droid-99

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) and assets (resource) components.

What problem does it solve?

It removes friction and mistakes when creating Databricks Lakeflow Spark Declarative Pipelines (SDP/LDP) by enforcing correct SDP syntax, sensible pipeline structure, and safe serverless defaults across ingestion, transformations, and CDC/SCD patterns.

Core Features & Use Cases

  • Creates serverless SDP objects correctly: enforces CREATE OR REFRESH STREAMING TABLE and CREATE OR REFRESH MATERIALIZED VIEW (never CREATE OR REPLACE) and keeps syntax aligned with Lakeflow requirements.
  • Builds ingestion-to-curation pipelines: supports streaming tables for bronze/silver layers and materialized views for gold aggregations, including Auto Loader ingestion patterns with rescue/quarantine guidance.
  • Implements CDC/SCD patterns reliably: provides routing and rules for AUTO CDC, SCD Type 1/Type 2, and key/sequence/column selection (including common pitfalls like sequence_by typing and SCD2 temporal querying).

Quick Start

Create a serverless Lakeflow pipeline that ingests raw files into a bronze streaming table, produces a silver streaming transformation, and publishes a gold materialized view for dashboard-ready aggregates.

Frequently Asked Questions about databricks-spark-declarative-pipelines

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I create a Lakeflow streaming table in Databricks SDP?

Databricks Lakeflow SDP requires using CREATE OR REFRESH STREAMING TABLE syntax for streaming ingestion, never CREATE OR REPLACE, to correctly build bronze and silver layer objects in a medallion architecture.

What is the correct syntax for SCD Type 2 in Databricks declarative pipelines?

SCD Type 2 in Databricks declarative pipelines requires careful sequence_by column typing and key selection to track historical changes. The pipeline applies correct SDP routing rules to maintain temporal query accuracy for slowly changing dimensions.

Does Databricks Lakeflow SDP support serverless Auto CDC ingestion?

Databricks Lakeflow SDP supports serverless Auto CDC ingestion by default. It applies safe routing and validation to ensure change data capture patterns correctly populate streaming tables without manual infrastructure configuration.

How do I build a medallion architecture pipeline with Spark declarative pipelines?

Building a medallion architecture pipeline with Spark declarative pipelines uses streaming tables for bronze and silver transformations, then materialized views for gold aggregations. The pipeline enforces correct CREATE OR REFRESH syntax for each layer.

Can I use Python instead of SQL for Databricks Lakeflow SDP transformations?

Databricks Lakeflow SDP transformations can use Python via pyspark.pipelines code as an alternative to SQL. You must explicitly select the SQL or Python language path to ensure the generated pipeline satisfies SDP syntax requirements correctly.

Why does my Databricks SDP materialized view fail to refresh?

Databricks SDP materialized views fail to refresh when using incorrect syntax like CREATE OR REPLACE. Correct SDP syntax requires CREATE OR REFRESH MATERIALIZED VIEW to properly execute gold layer aggregations in Lakeflow pipelines.