beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lukasz Cwik <lc...@google.com>
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 <jozo.vilcek@gmail.com> 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.
>
>

Mime
View raw message