如何將動態值傳遞給flink中的timeWindow（<dynamic_Time>）

Question

DataStream<Sensor> processStream = inputDataStream.filter(new TransientFallFilter()); 

DataStream<Event> outputStream = processStream.keyBy("k", "s").timeWindow(Time.minutes(2)).apply(new TransientRiseEventSelect()); 

有沒有可能性或API在哪裏可以將動態時間值傳遞給timeWindow（t）函數？我有一個關於時間框架根據關鍵而改變的要求。

Answer 1

不，這不受DataStream API的默認時間窗口支持。 但是，應該可以通過自定義WindowAssigner和Trigger來實現此類行爲。 A WindowAssigner將記錄分配給窗口，並且Trigger決定何時計算窗口。

查看docs瞭解詳情。