跳到主要内容

Delta Lake 引擎

Introduced or updated: v1.2.262

Databend 的 Delta Lake 引擎允许你无缝查询和分析存储在对象存储中的 Delta Lake 表数据。在 Databend 中使用 Delta Lake 引擎创建表时,你需要指定 Delta Lake 表数据文件的存储位置。这样即可直接访问该表,并在 Databend 内无缝执行查询。

  • Databend 的 Delta Lake 引擎目前仅支持只读操作,即可以查询 Delta Lake 表中的数据,但无法写入。
  • 使用 Delta Lake 引擎创建的表,其 Schema(模式)在创建时即已固定。若原始 Delta Lake 表的 Schema 发生变更,需在 Databend 中重新创建对应表以保持同步。
  • Databend 中的 Delta Lake 引擎基于官方 delta-rs 库构建。请注意,delta-protocol 定义的某些特性(如 Deletion Vector、Change Data Feed、Generated Columns 和 Identity Columns)目前尚不受支持。

语法

CREATE TABLE <table_name> 
ENGINE = Delta
LOCATION = 's3://<path_to_table>'
CONNECTION_NAME = '<connection_name>'

在使用 Delta Lake 引擎创建表之前,需先创建用于连接 S3 存储的连接对象。在 Databend 中,请使用 CREATE CONNECTION 命令创建连接。

示例

-- 建立连接
CREATE CONNECTION my_s3_conn
STORAGE_TYPE = 's3'
ACCESS_KEY_ID ='your-ak' SECRET_ACCESS_KEY ='your-sk';

-- 使用 Delta Lake 引擎创建表
CREATE TABLE test_delta
ENGINE = Delta
LOCATION = 's3://testbucket/admin/data/delta/delta-table/'
CONNECTION_NAME = 'my_s3_conn';
欢迎体验 Databend Cloud

基于 Rust + 对象存储构建的新一代多模态数仓,一个平台即可进行 BI、向量、全文检索及地理空间分析。

支持标准 SQL,自动弹性伸缩,助您快速构建现代化数据平台。

注册即领 ¥200 代金券。

注册体验