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でこのような動作を実装することは可能です。 WindowAssignerはウィンドウにレコードを割り当て、Triggerはウィンドウを計算するタイミングを決定します。

詳細については、docsを参照してください。