Class | Description |
---|---|
BatchExecutionCheckpointStorage |
A simple
CheckpointStorage which is used in a BATCH style execution. |
BatchExecutionInternalTimeService<K,N> |
An implementation of a
InternalTimerService that manages timers with a single active key
at a time. |
BatchExecutionInternalTimeServiceManager<K> |
An implementation of a
InternalTimeServiceManager that manages timers with a single
active key at a time. |
BatchExecutionKeyedStateBackend<K> |
A
CheckpointableKeyedStateBackend which keeps values for a single key at a time. |
BatchExecutionStateBackend |
A simple
StateBackend which is used in a BATCH style execution. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.