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.vil...@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. > >
