三角直播表SQL语言参考

文章提供Delta Live表SQL编程接口的细节和实例完整API规范见sqlAPI规范.

约束

上头插头项不支持 。上头偏角spark操作需要热加输入数据计算输出模式三角洲直播表不支持此功能

SQL数据集

使用环境变换活生生视网膜环境变换OR系统内弗瑞斯特活生生表单语法创建 sql视图或表从外部数据源或从管道定义的数据集读取数据集从内部数据集读取预设活生生关键字数据集名下示例定义两个不同的数据集:表调用计程车JSON文件输入源和表调用过滤数据计程车表输入

环境变换OR系统内弗瑞斯特活生生表单计程车AS系统安全选择*公元前.'/数据砖块-数据集/妮卡西/采样/公元前/'环境变换OR系统内弗瑞斯特活生生表单过滤数据AS系统安全选择.活生生.计程车

Delta Live表自动捕捉管道定义数据集之间的依存关系并使用此依存信息判定执行顺序并记录管道事件日志线信息

视图和表均有下列可选属性:

  • 评语人文化描述此数据集

  • 数据质量约束强制期望值.

表还提供附加控件实现

  • 指定表格如何分治使用构件化BY.可使用分区加速查询

  • 可设置表属性使用TBPROPERIE.看吧表属性详解详解

  • 设置存储位置使用定位设置默认时表数据存储管道存储定位不设置

  • 可使用生成列模式定义

看吧sqlAPI规范获取更多表视图属性信息

使用赛特指定表或视图配置值,包括spark配置表格或视图后笔记本定义赛特语句存取定义值任何spark配置使用赛特语句用于执行SET报表后表或视图Spark查询读取查询配置值时使用字符串插法语法美元.下示例设置Spark配置值命名启动日期并使用值查询

SET启动Date='20200101'Create或RefresthLiveTable过滤 secle

要指定多配置值,请使用单片赛特语句对数值

从流源读数据,例如自动加载器或内部数据集定义STRAMING活生生表数 :

环境变换OR系统内弗瑞斯特STRAMING活生生表单customers_bronzeAS系统安全选择*云文件高山市"/databricks-datasets/retail-org/customers/",Csv)环境变换OR系统内弗瑞斯特STRAMING活生生表单customers_silverAS系统安全选择*斯特林高山市活生生.customers_bronze)

更多流数据信息见进程流数据与Delta直播表.

sqlAPI规范

创建表

CREATE或REFERSH[temori负期望-名-一Expect-servation-serve-serve-drop-serve-serve-s上位数2+++++++++++++++++++++++++++++++++++++++++++AS选择语句

创建视图

Create过渡[straking]LiveView视图_name[Col_name1[Col_nameCol_Col_Servation1]]Col_name2[ColmentCol_Servation2]负期望-名-一Expect-servation-serve-serve-drop-serve-serve-ss选择语句

SQL属性

Create表或视图

暂时性

创建临时表无元数据持续本表

STRAMING

创建表读入数据集流输入数据集必须是流数据源自动加载器STRAMING活生生表格内

编委

可选列列表供划分表使用

定位

可选存储表数据未设置系统默认管道存储

评语

可选表描述

TBPROPERIE

可选列表表属性面向表

select_statement

DeltaLive表查询定义表数据集

约束条款

EXPECT期望名

定义数据质量约束expectation_name.if上传违章行为未定义约束,添加违反约束目标数据集行

上违章

可选行取失败

  • 费城更新即时停止管道执行

  • DROP系统ROW系统:删除记录并持续处理

表属性

除表属性支持三角湖中,您可以设置下表属性

表属性

pipelines.autoOptimize.managed

默认值 :真实性

启动或禁用自动调度优化表

pipelines.autoOptimize.zOrderCols

默认值:无

可选字符串内含用逗号划分列名列表举个例子pipelines.autoOptimize.zOrderCols=年月

pipelines.reset.allowed

默认值 :真实性

控制是否允许全新本表