窗口和時(shí)間語義

關(guān)于窗口和時(shí)間語義的介紹可以參考這篇文章。之前是在流上進(jìn)行討論的。Flink 在表上同樣支持相應(yīng)的邏輯。

4.1 時(shí)間語義

可以通過 DDL 方式創(chuàng)建兩種時(shí)間語義，但是比較晦澀，這里不做舉例，感興趣可以到官網(wǎng)查看。

4.1.1 processing time

注意處理時(shí)間屬性一定不能定義在一個(gè)已有字段上

• // 聲明一個(gè)額外的字段作為時(shí)間屬性字段val table = tEnv.fromDataStream(stream, $"UserActionTimestamp", $"user_name", $"data", $"user_action_time".proctime)