水印條款

適用於:檢查標記是的磚的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;