org.apache.flink.streaming.api.operators

Interface InternalTimeServiceManager.ShouldStopAdvancingFn

Enclosing interface:

InternalTimeServiceManager<K>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@Internal
 @FunctionalInterface
public static interface InternalTimeServiceManager.ShouldStopAdvancingFn

Signals whether the watermark should continue advancing.

Method Summary

Modifier and Type	Method and Description
boolean	test()

Method Detail

test

boolean test()

Returns:

true if firing timers should be interrupted.