Correct. Context gives you access to the element timestamp <https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/ProcessFunction.java#L99>. But it also gives you access to the current watermark via timerService <https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/ProcessFunction.java#L104> -> currentWatermark <https://github.com/apache/flink/blob/a0f4239faee533545c6d923a944f242b519759d1/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/TimerService.java#L39> .
On Tue, Jul 31, 2018 at 7:45 AM Julio Biason <julio.bia...@azion.com> wrote: > Thanks for the tips. Unfortunately, it seems `Context` only have > information from the element being processed ( > https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/ProcessFunction.java#L91) > and the RuntimeContext doesn't have access to any watermark information ( > https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java#L57 > ). > >