How to pass dynamic value to timeWindow(<dynamic_Time>) in flink

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

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

Is there possibility or API Where I can pass a dynamic time value to timeWindow(t) function? I have a requirement where the time frame changes according to the key.

1 Answers
Related