Hi Yidan, Thank you for your reply. I was wondering if there is some way that the process function can kiw which condition fired the trigger.
Eg: If I set trigger to fire when he object associated with key have value 2, 8, 10 (3 conditions for the trigger to fire), then if he process function, I want to operate differently on them. On Mon, Feb 22, 2021, 11:23 AM yidan zhao <hinobl...@gmail.com> wrote: > You can self-define it using keyedStream.window(GlobalWindows.create() > ).trigger(self-defined-trigger). > > Abhinav Sharma <abhinavandfrie...@gmail.com> 于2021年2月21日周日 下午3:57写道： > >> Hi, >> >> Is there some way that I can configure an operator based on the key in a >> stream? >> Eg: If the key is 'abcd', then create a window of size X counts, if the >> key is 'bfgh', then create a window of size Y counts. >> >> Is this scenario possible in flink >> >>
