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
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
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
Hi,
i cant unserstand usage of this snippest of the code in
MergingWindowSet.java, can anyone explain this for me ?
if (!(mergedWindows.contains(mergeResult) && mergedWindows.size() == 1)) {
mergeFunction.merge(mergeResult,
Hi,
i cant understand the usage of this snippest of this code , can anyone
explain foe me ? thanks
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
