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
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
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 |
CheckpointBoundKeyedStateHandle
KeyedStateHandle that is bound to a specific checkpoint. |
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,
long checkpointID)
Register given shared states in the registry.
|
void |
SharedStateRegistryImpl.registerAll(Iterable<? extends CompositeStateHandle> stateHandles,
long checkpointID) |
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 |
ChangelogStateBackendLocalHandle
State handle for local copies of
ChangelogStateHandleStreamImpl . |
class |
ChangelogStateHandleStreamImpl
ChangelogStateHandle implementation based on StreamStateHandle . |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryChangelogStateHandle
In-memory
ChangelogStateHandle . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.