水印条款

适用于:检查标记是的砖的SQL检查标记是的砖运行时12.0及以上

添加了水印在select语句的关系。的水印条款只适用于对有状态的流数据的查询,其中包括stream-stream连接和聚合。

语法

from_item{table_name(TABLESAMPLE条款](watermark_clause](table_alias]|加入条款|(横向]table_valued_function(table_alias]|价值条款|(横向](查询)(TABLESAMPLE条款](watermark_clause](table_alias]}watermark_clause水印named_expression延迟的时间间隔

参数

  • named_expression

    一个表达式,它提供了一个值的类型时间戳。表达式必须是一个引用现有的列,或者一个确定的变换对现有列(s)。时间戳的表达式添加一个列类型用于跟踪水印。添加列可以查询。

  • interval_clause

    一个定义延迟阈值区间文字水印的。不到一个月的时间必须是一个积极的价值。

例子

假设一个流媒体关系与DataFrame API定义,和一个临时视图命名stream_relation创建的关系。

在SELECT语句中定义水印>选择*从stream_relation水印to_timestamp(ts)作为event_time延迟的时间间隔10秒作为stream_with_watermark;