WATERRSK条款

应用到 :检查标注是数据布列克斯SQL检查标注是Databricks运行时间12.0

选择语句中添加水印关系上头WATERSTARK条款仅适用于状态流数据查询,包括流流合并和聚合

语法

从_项目{{表名[表格维护程序条框万事通[watermark_clause万事通[表格别名万事通|约宁市条框|[后台万事通table_valued_function[表格别名万事通|VALUE语言条框|[后台万事通高山市查询)[表格维护程序条框万事通[watermark_clause万事通[表格别名万事通}watermark_clauseWATERSTARKnamed_expression变换调区间

参数解析

  • named_expression

    表达式提供类型值时间戳.表达式必须是引用现有列或确定式变换表达式加列时标类型,用于跟踪水印添加列可用查询

  • 区间设置

    区间字句定义水印延迟阈值必须是正值小于一个月

实例

假设流动关系定义dataFrameAPI溪流关系由关系创建

select语句定义水印>安全选择*从溪流关系WATERSTARKto_timestamp高山市ts)AS系统事件时间变换调INTERVAL系统10秒数AS系统stream_with_watermark;