Package | Description |
---|---|
org.apache.flink.migration.state | |
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.state |
Modifier and Type | Class and Description |
---|---|
class |
MigrationKeyGroupStateHandle
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Modifier and Type | Class and Description |
---|---|
class |
OperatorState
Simple container class which contains the raw/managed/legacy operator state and key-group state handles for the sub
tasks of an operator.
|
class |
OperatorSubtaskState
Container for the state of one parallel subtask 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.
|
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.