beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lukasz Cwik <>
Subject Re: Access to current watermark
Date Thu, 17 May 2018 15:02:10 GMT
This is not exposed programatically. Depending on which runner your using,
you may be able to query for the watermark through its monitoring APIs if
it is exposed as a metric and you know what it is called. This is likely to
be brittle implementation and also the data is likely to be stale.

On Thu, May 17, 2018 at 1:31 AM Jozef Vilcek <> wrote:

> Hello,
> is there a way to observe `current watermark` when processing elements of
> triggered window?
> What I am trying to achieve is, to have on one window quite large late
> comer event allowance and I want to log information on how much late behind
> the watermark event did came in.

View raw message