导航：首页 > 互联网科技 >

如何分析delta lake表schema演进

发表于：2026-11-02 作者：千家信息网编辑

千家信息网最后更新 2026年11月02日，如何分析delta lake表schema演进，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。下面主要是深入探究一下del

千家信息网最后更新 2026年11月02日如何分析delta lake表schema演进

如何分析delta lake表schema演进，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

下面主要是深入探究一下delta lake的schema演变。

数据，就像我们的经验一样，总是在不断发展和积累。为了跟上时代的步伐，我们的思维模式必须适应新数据，其中一些包含新的维度-一种新的方式来查看我们以前从未想到的事物。这些思维模式与表的schema没有什么不同，它们定义了我们如何对新信息进行分类和处理。

随着业务问题和需求的发展，数据的结构也将随之变化。使用Delta Lake，随着数据的变化，合并新维度变得容易。用户可以使用简单的语义来控制其表的schema。这些工具包括schema校验（可防止用户因错误或垃圾数据而无意中污染其表）以及schema演进（也就是为了丰富数据而增加一些新的列）。

了解表schema

Apache Spark™中的每个DataFrame都包含一个schema，定义了数据的格式，例如数据类型和列以及元数据。使用Delta Lake，表的schema以JSON格式保存在事务日志中。

什么是schema校验？

schema校验是Delta Lake中的一种安全措施，它通过拒绝对表的schema不匹配的写入来确保数据质量。就像忙碌的餐厅的前台经理只接受预订一样，它会检查插入表中的数据中的每一列是否在其预期列的列表中（换句话说，每一列是否都有"预订"），以及拒绝所有不在列表中的列的写操作。

schema 校验如何工作？

Delta Lake 在write操作上使用schema验证，这意味着在写入时会检查对表的所有新写入是否与目标表的schema兼容。如果schema不兼容，则Delta Lake将完全取消事务（不写入任何数据），并引发异常以使用户知道不匹配的情况。

为了确定对表的写入是否兼容，Delta Lake使用以下规则。要写入的DataFrame：

不能包含目标表的架构中不存在的任何其他列。相反输入的数据不包含表中的某些列是可以的，这些列将被简单地分配为空值。
列的数据类型不能与目标表中的列数据类型不同。如果目标表的列包含StringType数据，但DataFrame中的相应列包含IntegerType数据，则schema强制实施将引发异常并阻止进行写操作。
不能包含仅大小写不同的列名。这意味着不能在同一表中定义诸如" Foo"和" foo"之类的列。尽管Spark可用于区分大小写或不区分大小写（默认）模式，但是Delta Lake保留大小写，却在存储schema时不区分大小写。存储和返回列信息时，Parquet区分大小写。为了避免潜在的错误，数据损坏或丢失问题，才添加此限制。

为了说明，请看下面的代码，当试图将一些新计算的列追加到不兼容它们的delta lake表的时候，将发生什么。


# Generate a DataFrame of loans that we'll append to our Delta Lake tableloans = sql("""            SELECT addr_state, CAST(rand(10)*count as bigint) AS count,            CAST(rand(10) * 10000 * count AS double) AS amount            FROM loan_by_state_delta            """)
# Show original DataFrame's schemaoriginal_loans.printSchema()
"""root  |-- addr_state: string (nullable = true)  |-- count: integer (nullable = true)"""
# Show new DataFrame's schemaloans.printSchema()
"""root  |-- addr_state: string (nullable = true)  |-- count: integer (nullable = true)  |-- amount: double (nullable = true) # new column"""
# Attempt to append new DataFrame (with new column) to existing tableloans.write.format("delta") \           .mode("append") \           .save(DELTALAKE_PATH)
""" Returns:
A schema mismatch detected when writing to the Delta table.
To enable schema migration, please set:'.option("mergeSchema", "true")\'
Table schema:root-- addr_state: string (nullable = true)-- count: long (nullable = true)

Data schema:root-- addr_state: string (nullable = true)-- count: long (nullable = true)-- amount: double (nullable = true)
If Table ACLs are enabled, these options will be ignored. Please use the ALTER TABLE command for changing the schema.
"""

Delta Lake不会自动添加新列，而是强制校验schema并阻止写入。为了帮助确定导致不匹配的列，Spark在堆栈跟踪中打印出了两种schema以进行比较。

模式校验有何用处？

由于这种检查非常严格，所以数据可以直接用于生产环境。常见的使用场景如下：

机器学习算法
BI仪表板
数据分析和可视化工具
任何需要高度结构化，强类型语义schema的生产系统

防止数据稀疏

强制性的schema校验，可能会导致大家在编写spark任务的时候拘束比较多，一遇到schema不兼容任务就会崩溃，这个可能是会令人头疼。

但是假设不对schema进行校验，那么随时可能新增列，导致表变的越来越稀疏。其实，这也是一种性能消耗。

所以，schema校验也有防止数据变的越来越稀疏的作用。

什么是schema演变？

schema演变简单来数就是表的schema会随着数据的变化而变化。最常见的是，在执行附加或覆盖操作时使用它来自动调整schema以包括一个或多个新列。

schema演变如何工作？

配置很简单，通过添加 .option('mergeSchema', 'true')到您的.write或.writeStreamSpark命令来启动schema演变。

# Add the mergeSchema optionloans.write.format("delta") \           .option("mergeSchema", "true") \           .mode("append") \           .save(DELTALAKE_SILVER_PATH)

执行下面的sql表达式：

# Create a plot with the new column to confirm the write was successful%sqlSELECT addr_state, sum(`amount`) AS amountFROM loan_by_state_deltaGROUP BY addr_stateORDER BY sum(`amount`)DESC LIMIT 10

可以绘制一张统计图：

通过mergeSchema设置为true，DataFrame中存在但目标表中不存在的所有列将作为写事务的一部分自动添加到schema的末尾。还可以添加嵌套字段，并且这些字段也将添加到其各自的struct列的末尾。

数据工程师和科学家可以使用此选项在其现有的机器学习生产表中添加新列（也许是新跟踪的指标，或本月销售数字的列），而不会破坏依赖旧列的现有模型。

在表追加或覆盖期间，以下类型的模式更改可用于schema演变：