Page History

context.schedule(interval, PunctuationType.STREAM_TIME, this::punctuate);

context.schedule(interval, PunctuationType.STREAM_TIME, timestamp -> {
	KeyValue<K,V> pair = punctuate(timestamp);
	if (record != null) {
		context.forward(pair.key, pair.value);
	}
});