Skip to main content

Build Data Pipelines with Apache Spark Declarative Pipelines

This course introduces users to the essential concepts and skills needed to build data pipelines using Apache Spark™ Declarative Pipelines (SDP) in Databricks for incremental batch or streaming ingestion and processing through multiple streaming tables and materialized views. Designed for data engineers new to Spark Declarative Pipelines, the course provides a comprehensive overview of core components such as incremental data processing, streaming tables, materialized views, and temporary views, highlighting their specific purposes and differences.


Topics covered include:

• Developing and debugging ETL pipelines with the multi-file editor in Spark Declarative Pipelines using SQL (with Python code examples provided)

• How Spark Declarative Pipelines track data dependencies in a pipeline through the pipeline graph

• Configuring pipeline compute resources, data assets, trigger modes, and other advanced options


Next, the course introduces data quality expectations in Spark Declarative Pipelines, guiding users through the process of integrating expectations into pipelines to validate and enforce data integrity. Learners will then explore how to put a pipeline into production, including scheduling options, and enabling pipeline event logging to monitor pipeline performance and health.


Finally, the course covers how to implement Change Data Capture (CDC) using the AUTO CDC INTO syntax within Spark Declarative Pipelines to manage slowly changing dimensions (SCD Type 1 and Type 2), preparing users to integrate CDC into their own pipelines.


Note: For SCORM lecture files, please ensure that you close the SCORM window after completing the content. Do not click the ‘Next Lesson’ button, as doing so may prevent the SCORM module from being marked as complete.

Skill Level
Associate
Duration
2h
Prerequisites

In this course, the content was developed for participants with these skills/knowledge/abilities:  

• Basic understanding of the Databricks Data Intelligence platform, including Databricks Workspaces, Apache Spark, Delta Lake, the Medallion Architecture, Lakeflow Jobs and Unity Catalog.

• Experience ingesting raw data into Delta tables, including using the read_files SQL function to load formats like CSV, JSON, TXT, and Parquet.

• Proficiency in transforming data using SQL, including writing intermediate-level queries and a basic understanding of SQL joins.

• Understanding of ETL concepts, and batch/streaming workflows.

Self-Paced

Custom-fit learning paths for data, analytics, and AI roles and career paths through on-demand videos

See all our registration options

Registration options

Databricks has a delivery method for wherever you are on your learning journey

Runtime

Self-Paced

Custom-fit learning paths for data, analytics, and AI roles and career paths through on-demand videos

Register now

Instructors

Instructor-Led

Public and private courses taught by expert instructors across half-day to two-day courses

Register now

Learning

Blended Learning

Self-paced and weekly instructor-led sessions for every style of learner to optimize course completion and knowledge retention. Go to Subscriptions Catalog tab to purchase

Purchase now

Scale

Skills@Scale

Comprehensive training offering for large scale customers that includes learning elements for every style of learning. Inquire with your account executive for details

Upcoming Public Classes

Get Started with Databricks for Data Engineering - Mandarin Chinese

本课程介绍在 Databricks Data Intelligence Platform 上执行基本数据工程工作流所需的基础技能。您将浏览 workspace,使用 Unity Catalog,并学习数据工程师在 Databricks 上日常使用的核心构建模块。

本课程采用实践路径。您从熟悉 workspace 开始,然后针对每个主题完成配套的演示笔记本和实验室笔记本。演示部分将由讲师或引导式笔记本带您了解相关概念。

课程内容涵盖:

Databricks Data Intelligence Platform,以及 Databricks workspace、Unity Catalog 和笔记本之间的协作关系。

创建和管理 Delta Lake 表。

使用 INSERT、UPDATE 和 DELETE 修改数据。

浏览 UC 表的版本历史与 time travel 功能。

使用 LakeFlow Connect 的多种方式摄取数据:CTAS、上传 UI 以及 COPY INTO。

构建奖章架构管道,将数据依次经过铜牌、银牌和金牌层进行转换。

使用 LakeFlow Jobs 实现管道自动化。

(附加内容)使用 Apache Spark™ Declarative Pipelines 构建声明式管道。

完成本课程后,您将能够熟练创建 Delta Lake 表、向其中摄取数据、通过奖章管道对数据进行转换,并将整个流程自动化为定时任务。

注意:Databricks Academy 正在将 Databricks 环境中的课堂课程转为基于 notebook 的形式,并停止在讲座中使用幻灯片。您可以在 Vocareum 实验环境中访问课程 notebook。

Free
2h
instructor-led
Onboarding

Questions?

If you have any questions, please refer to our Frequently Asked Questions page.