Modifier and Type | Method and Description |
---|---|
abstract TimerService |
KeyedStateBootstrapFunction.Context.timerService()
A
TimerService for querying time and registering timers. |
Modifier and Type | Class and Description |
---|---|
class |
LazyTimerService
A timer service that initializes its internal timer service lazily.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleTimerService
Implementation of
TimerService that uses a InternalTimerService . |
Modifier and Type | Method and Description |
---|---|
abstract TimerService |
KeyedProcessFunction.Context.timerService()
A
TimerService for querying time and registering timers. |
abstract TimerService |
ProcessFunction.Context.timerService()
A
TimerService for querying time and registering timers. |
Modifier and Type | Method and Description |
---|---|
abstract TimerService |
CoProcessFunction.Context.timerService()
A
TimerService for querying time and registering timers. |
abstract TimerService |
KeyedBroadcastProcessFunction.ReadOnlyContext.timerService()
A
TimerService for querying time and registering timers. |
abstract TimerService |
KeyedCoProcessFunction.Context.timerService()
A
TimerService for querying time and registering timers. |
Modifier and Type | Method and Description |
---|---|
default void |
CleanupState.registerProcessingCleanupTimer(ValueState<Long> cleanupTimeState,
long currentTime,
long minRetentionTime,
long maxRetentionTime,
TimerService timerService) |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractProcessStreamOperator.ContextImpl
Information available in an invocation of processElement.
|
Modifier and Type | Method and Description |
---|---|
TimerService |
AbstractProcessStreamOperator.ContextImpl.timerService() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.