Hi,

My runner is translating GroupByKey using
GroupAlsoByWindowViaWindowSetDoFn. Say I have a BoundedSource with five
tuples all placed into a global window. When the source is depleted, how
should the runner notify the downstream
GroupByKey(GroupAlsoByWindowViaWindowSetDoFn) that it should fire the
global window?

Thanks,

Shen

Reply via email to