Hi,

I am a little confused about the usage of internal IdentityWindowFn. My
current understanding is that it should be used when a transform wants to
change window configurations (e.g., triggering, lateness, etc.) without
modifying the window assignments. Is that correct? If so, how come
IdentifyWindowFn.assignWindows() returns a collection of a single
BoundedWindow? What if the upstream WindowFn assigns an element to multiple
windows (e.g., SlidingWindows)?

Thanks,

Shen

Reply via email to