Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.state |
Modifier and Type | Class and Description |
---|---|
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 |
KeyedStateHandle
Base for the handles of the checkpointed states in keyed streams.
|
Modifier and Type | Class and Description |
---|---|
class |
IncrementalKeyedStateHandle
The handle to states of an incremental snapshot.
|
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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.