如何实现event triggered window？

Hi 如果是需要 event triggered 的累計統計更新的話，可以考慮使用 SQL over aggregation [1]。例如文件中提供的如下範例，計算當前 row 往前一小時內的加總結果。

SELECT order_id, order_time, amount, SUM(amount) OVER ( PARTITION BY product ORDER BY order_time RANGE BETWEEN INTERVAL '1' HOUR PRECEDING AND CURRENT ROW ) AS one_hour_prod_amount_sumFROM Orders

但是這種作法只能根據收到的事件來觸發，無法根據處理時間。換句話說，如果 t=X 沒有數據進來的話，就不會有 t=(X-1) ~ X 的累計統計輸出。 考慮更複雜的情況需要結合事件和處理時間來觸發的話，需要透過 Process Function API 或者用 DataStream API 自定義 Trigger 的方式實現。

[1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/over-agg/*来自志愿者整理的flink邮件归档