Modifier and Type | Class and Description |
---|---|
class |
FinishedOperatorSubtaskState
A specialized
OperatorSubtaskState representing the subtask is finished. |
class |
FullyFinishedOperatorState
A special operator state implementation representing the operators whose instances are all
finished.
|
class |
OperatorState
Simple container class which contains the raw/managed operator state and key-group state handles
from all sub tasks of an operator and therefore represents the complete state of a logical
operator.
|
class |
OperatorSubtaskState
This class encapsulates the state for one parallel instance of an operator.
|
class |
SubtaskState
Container for the chained state of one parallel subtask of an operator/task.
|
class |
TaskState
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
class |
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IncrementalKeyedStateHandle
Common interface to all incremental
KeyedStateHandle . |
interface |
KeyedStateHandle
Base for the handles of the checkpointed states in keyed streams.
|
interface |
SavepointKeyedStateHandle
A
KeyedStateHandle that points to a savepoint taken in the unified format. |
Modifier and Type | Class and Description |
---|---|
class |
DirectoryKeyedStateHandle
This class is a keyed state handle based on a directory.
|
class |
IncrementalLocalKeyedStateHandle
State handle for local copies of
IncrementalRemoteKeyedStateHandle . |
class |
IncrementalRemoteKeyedStateHandle
The handle to states of an incremental snapshot.
|
class |
KeyGroupsSavepointStateHandle
A
KeyGroupsStateHandle that describes a savepoint in the unified format. |
class |
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
Modifier and Type | Method and Description |
---|---|
void |
SharedStateRegistry.registerAll(Iterable<? extends CompositeStateHandle> stateHandles)
Register given shared states in the registry.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChangelogStateBackendHandle
A handle to ChangelogStateBackend state.
|
interface |
ChangelogStateHandle
A handle to saved
state changes . |
Modifier and Type | Class and Description |
---|---|
static class |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl |
class |
ChangelogStateHandleStreamImpl
ChangelogStateHandle implementation based on StreamStateHandle . |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryChangelogStateHandle
In-memory
ChangelogStateHandle . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.