Hi, TriggerContext.getWaterMark() returns the current watermark (i.e., event-time) of the window operator. An operator tracks for each of its inputs the maximum received watermark and computes its own watermark as the minimum of all these maximums. Until an operator has not received watermarks from all its inputs, its own watermark will be Long.MIN_VALUE.
So, the watermark can indeed be used as an indicator for time progress but until it hasn't received wms from all inputs it's not initialized yet. Hope this helps. Best, Fabian 2017-12-17 3:24 GMT+01:00 Vishal Santoshi <vishal.santo...@gmail.com>: > I think I got the 0 wrong, I do however want to figure out, how much I can > depend on this watermark to represent the progress of the window. > > On Sat, Dec 16, 2017 at 9:06 PM, Vishal Santoshi < > vishal.santo...@gmail.com> wrote: > >> What does TriggerContext.getWaterMark() represent. Is it the system level >> watermark for the window operator ? When I pull it out I get a value of 0 a >> hole bunch of times ... >> > >
