Hello
I am developing a Flink 1.4.2 application currently with sliding windows
(Example below)
I want to ask if there is a way to create the window time dynamically also
the key has to change in some Use Cases and we don't want to create an
specific window for each UC
I want to send those values from the front end
SingleOutputStreamOperator<Object> windowed = ObjectDTO
.keyBy("Key")
.timeWindow(Time.minutes(10),Time.minutes(1))
.trigger(new AlertTrigger(env.getStreamTimeCharacteristic()))
.aggregate(new TxnAggregator(), new TxnWindowFn())
.name("TEN_MINUTES_WINDOW")
Thank you
Best Regards
