Interface | Description |
---|---|
TimerService |
Interface for working with time and timers.
|
Class | Description |
---|---|
SimpleTimerService |
Implementation of
TimerService that uses a InternalTimerService . |
Enum | Description |
---|---|
CheckpointingMode |
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
TimeCharacteristic | Deprecated
In Flink 1.12 the default stream time characteristic has been changed to
TimeCharacteristic.EventTime , thus you don't need to call this method for enabling
event-time support anymore. |
TimeDomain |
TimeDomain specifies whether a firing timer is based on event time or processing time. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.