HeapInternalTimerService#advanceWatermark

[aitozi]

Hi,

i have read this snip of code again and again, but i cant understand the
usage of it , can anyone explain it for me. thank you very much.

        public void advanceWatermark(long time) throws Exception {
                currentWatermark = time;

                InternalTimer<K, N> timer;

                while ((timer = eventTimeTimersQueue.peek()) != null &&
timer.getTimestamp() <= time) {

                        Set<InternalTimer&lt;K, N>> timerSet =
getEventTimeTimerSetForTimer(timer);
                        timerSet.remove(timer);
                        eventTimeTimersQueue.remove();

                        keyContext.setCurrentKey(timer.getKey());
                        triggerTarget.onEventTime(timer);
                }
        }



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/