databricks-spark-declarative-pipelines

Automate creation, configuration, and optimization of Databricks Lakeflow Spark Declarative Pipelines.

38|12|Updated Apr 24, 2026
One-click install
npx skills add https://github.com/databrickslabs/coding-agents-databricks-apps --skill databricks-spark-declarative-pipelines-databrickslabs
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: databricks-spark-declarative-pipelines
Source: https://github.com/databrickslabs/coding-agents-databricks-apps/tree/main/.claude/skills/databricks-spark-declarative-pipelines
Command: npx skills add https://github.com/databrickslabs/coding-agents-databricks-apps --skill databricks-spark-declarative-pipelines-databrickslabs

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Building production-grade data pipelines on Databricks with proper medallion architecture, streaming ingestion, change data capture, and performance optimization requires deep expertise in Lakeflow Spark Declarative Pipelines and introduces significant development overhead.

Core Features & Use Cases

  • Streaming Ingestion Patterns: Auto Loader for cloud storage, Kafka, Event Hub, and Kinesis with schema evolution, rescue data handling, and authentication best practices.
  • Medallion Architecture: Bronze, silver, and gold layer implementations with Liquid Clustering, deduplication, and data quality patterns.
  • CDC & SCD Type 2: AUTO CDC for change data capture, slowly changing dimensions, temporal queries, and point-in-time analysis.
  • Performance Optimization: State management, windowed aggregations, materialized views, and join optimization for high-throughput streaming workloads.
  • Project Initialization: Asset Bundle scaffolding, multi-environment deployments, and MCP tool integration for rapid development.

Quick Start

Use the databricks-spark-declarative-pipelines skill to create a new serverless streaming pipeline project with bronze, silver, and gold layers using SQL or Python.

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 build a Databricks streaming ingestion pipeline with Auto Loader?

You can build a Databricks streaming ingestion pipeline by automating Auto Loader configuration for cloud storage, Kafka, and Event Hub, applying schema evolution, rescue data handling, and authentication best practices for serverless compute.

What is the best way to implement medallion architecture on Databricks?

The best way to implement medallion architecture is automating bronze, silver, and gold layer configurations with deduplication, data quality patterns, and performance tuning using Liquid Clustering on serverless compute.

How do I handle change data capture and SCD Type 2 in Spark Declarative Pipelines?

To handle change data capture in Spark Declarative Pipelines, this skill automates AUTO CDC configuration, slowly changing dimensions, temporal queries, and point-in-time analysis for streaming and batch workloads.

Do I need Unity Catalog and serverless compute to use Spark Declarative Pipelines?

Yes, you need Unity Catalog and serverless compute to use these Spark Declarative Pipelines, as the automated configuration, Asset Bundle deployment, and performance optimization features require these Databricks environment prerequisites.

Can I use both SQL and Python APIs for Databricks Lakeflow pipeline deployment?

Yes, you can use both SQL and Python APIs for Databricks Lakeflow pipeline deployment, as this skill supports multi-environment Asset Bundle scaffolding and configuration across both programming interfaces.

How do I optimize streaming workloads with windowed aggregations in Databricks?

To optimize streaming workloads in Databricks, this skill automates state management, windowed aggregations, materialized views, and join optimization to improve throughput for high-performance serverless pipelines.