Class | Description |
---|---|
BootstrapTransformationWithID<T> |
A simple container class that represents a newly bootstrapped operator state within savepoints.
|
NeverFireProcessingTimeService |
A processing time service whose timers never fire so all timers are included in savepoints.
|
OperatorIDGenerator |
Utility for generating Operator Id's from uid strings.
|
SavepointEnvironment |
A minimally implemented
Environment that provides the functionality required to run the
state-processor-api . |
SavepointEnvironment.Builder |
SavepointEnvironment builder. |
SavepointLoader |
Utility class for loading
CheckpointMetadata metadata. |
SavepointRuntimeContext |
A streaming
RuntimeContext which delegates to the underlying batch RuntimeContext
along with a specified KeyedStateStore . |
VoidTriggerable<K,N> |
A
Triggerable that does nothing. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.