flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aitozi <gjying1...@gmail.com>
Subject HeapInternalTimerService#advanceWatermark
Date Sun, 10 Sep 2017 06:47:00 GMT
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/

Mime
View raw message