Package org.apache.flink.api.common.eventtime

Class WatermarksWithIdleness.IdlenessTimer

java.lang.Object

org.apache.flink.api.common.eventtime.WatermarksWithIdleness.IdlenessTimer

Enclosing class:

WatermarksWithIdleness<T>

@VisibleForTesting
@Internal
public static final class WatermarksWithIdleness.IdlenessTimer
extends Object

Constructor Summary

Constructors

Constructor	Description
IdlenessTimer(RelativeClock clock, Duration idleTimeout)

Method Summary

Modifier and Type	Method	Description
void	activity()
boolean	checkIfIdle()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IdlenessTimer

public IdlenessTimer(RelativeClock clock,
                     Duration idleTimeout)

Method Detail

activity

public void activity()

checkIfIdle

public boolean checkIfIdle()