Re: MergingWindow

2018-01-03 Thread Aljoscha Krettek
Yes, this is a very good description! To see this in action you can run MergingWindowSetTest and comment out the check in MergingWindowSet, then you will see test failures and can trace what situations lead to problematic behaviour without that check. > On 29. Dec 2017, at 15:07, jincheng sun

Re: MergingWindow

2017-12-29 Thread jincheng sun
Hi aitozi, `MergingWindowSet` is a Utility, used for keeping track of merging Windows when using a MergingWindowAssigner in a WindowOperator. In flink `MergingWindowAssigner` only used for SessionWindow. The implementations of `MergingWindowAssigner` are `EventTimeSessionWindows` and `Process

Re: MergingWindow

2017-12-27 Thread Ufuk Celebi
Please check your email before sending it the next time as three emails for the same message is a little spammy ;-) This is internal code that is used to implement session windows as far as I can tell. The idea is to not merge the new window as it never had any state associated with it. The genera