Sorry, that is BoundedWindow.TIMESTAMP_MAX_VALUE. On Tue, Jan 31, 2017 at 8:37 PM, Kenneth Knowles <k...@google.com> wrote:
> Hi Shen, > > Your runner should advance the watermark for the PCollection coming out of > the BoundedSource to BoundedWindow.MAX_TIMESTAMP, which is "positive > infinity" and indicates that even the global window has fired/expired (for > the global window these are the same instant). > > Kenn > > On Tue, Jan 31, 2017 at 8:32 PM, Shen Li <cs.she...@gmail.com> wrote: > >> 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 >> > >
