Skip to main content

Advanced Techniques with Apache Spark Declarative Pipelines - Mandarin Chinese

本课程探讨 Databricks 的 Apache Spark Declarative Pipelines(SDP),用于构建生产级流式处理管道。您将学习高级设计模式、强健的数据质量执行机制,以及实际湖仓工程中不可或缺的跨平台集成技术。


在整个课程中,您将深入了解现代数据摄取与处理技术,掌握 Liquid Clustering 布局优化工具以及用于混合 schema 事件的多路复用流式处理模式。完成各模块学习后,您将能够自信地处理 schema演进、自动化变更数据捕获(CDC)并确保数据完整性。


通过讲授与实操演示,您将:

• 构建多流管道,将多源数据摄取至统一的铜层表中。

• 在白银层与黄金层中应用 Liquid Clustering 与数据质量期望规则。

• 结合 Iceberg UniForm 实现多路复用模式,以支持跨平台数据访问。

• 使用 AUTO CDC INTO 自动化 SCD Type 2 历史追踪。

• 设计零数据丢失的隔离管道,以审计和管理无效记录。


注意:

  1. 本课程是 ‘Advanced Data Engineering with Databricks’ 系列的第一门课程。
  2. 对于 SCORM 讲座文件,请确保在完成内容后关闭 SCORM 窗口。请勿点击‘Next Lesson’按钮,否则 SCORM 模块可能无法标记为已完成。
Skill Level
Professional
Duration
2h
Prerequisites

本课程的内容是为具备以下技能、知识和能力的学员开发的:  

• Spark Declarative Pipelines — 完成"使用 Apache Spark Declarative Pipelines 构建数据管道"课程,或熟悉 CREATE OR REFRESH STREAMING TABLE、CONSTRAINTS 以及 Pipelines UI

• Delta Lake Fundamentals — 了解 Delta 表以及 Delta 如何管理数据文件和事务日志

• 流式处理概念 — 掌握 SDP 中的微批流式处理、检查点及事件时间处理的相关知识

• SQL 能力 — 能够读写 SQL,包括 SELECT、JOIN、MERGE、CASE WHEN 以及常用聚合函数

• Databricks Notebooks 中的 Python — 能够在 Databricks Notebooks 中阅读和运行 Python 代码

• Unity Catalog 基础 — 了解 Unity Catalog 中的目录、架构、表和卷

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

Model Development at Scale

In this course, you will learn to design and implement machine learning workflows that scale from a single machine to distributed compute on Databricks. The curriculum is organized into three modules: foundations of model development (when and why to distribute, and how Spark executes work), scalable model development with Spark ML and MLflow, and distributed model training with Ray and PyTorch — closing with a framework for choosing the right tool for a given workload.

Through hands-on demos and labs, you will build distributed Spark ML pipelines using Transformers, Estimators, and the fit/transform paradigm; scale existing pandas code with the Pandas API on Spark; and track, compare, and govern experiments with MLflow 3 and Unity Catalog. You will then train models across a cluster with Ray Train and PyTorch (TorchDistributor and DeepSpeed), and learn to match each workload to the right framework based on data size, model size, hardware, and cost.

The course concludes with a capstone that takes a problem end to end — engineering features, training a model at scale, tracking it with MLflow, and registering it in Unity Catalog with a governance alias. (Production deployment, serving, and monitoring are covered in the separate Advanced MLOps course.)

By the end, you will be able to choose, build, and justify distributed, reproducible, and governed model-development workflows on Databricks.

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.

Free
4h
Professional

Questions?

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