Re: Apache Flink - Question about Global Windows

2017-11-15 Thread M Singh
Hi Xingcan:  Thanks for your response. So to summarize - global windows can be applied to keyed and non keyed windows - we only have to specify trigger with it to invoke the computation function. Thanks Mans On Wednesday, November 15, 2017 5:43 AM, Xingcan Cui wrote: Hi Mans, the "glob

Re: Apache Flink - Question about Global Windows

2017-11-15 Thread Xingcan Cui
Hi Mans, the "global" here indicates the "horizontal" (count, time, etc.) dimension instead of the "vertical" (keyBy) dimension, i.e., all the received data will be placed into a single huge window. Actually, it's an orthogonal concept with the *KeyBy* operations since both *DataStream* and *Keyed

Apache Flink - Question about Global Windows

2017-11-14 Thread M Singh
Hi: I am reading about global windows and the documentation indicates: 'A global windows assigner assigns all elements with the same key to the same single global window' >From my understanding if we have a keyed stream - then all elements with the >same key are also assigned to a single window.