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