Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
void |
OperatorSubtaskState.registerSharedStates(SharedStateRegistry sharedStateRegistry) |
void |
TaskState.registerSharedStates(SharedStateRegistry sharedStateRegistry)
Deprecated.
|
void |
TaskStateSnapshot.registerSharedStates(SharedStateRegistry stateRegistry) |
void |
SubtaskState.registerSharedStates(SharedStateRegistry sharedStateRegistry) |
void |
OperatorState.registerSharedStates(SharedStateRegistry sharedStateRegistry) |
void |
CompletedCheckpoint.registerSharedStatesAfterRestored(SharedStateRegistry sharedStateRegistry)
Register all shared states in the given registry.
|
Modifier and Type | Method and Description |
---|---|
SharedStateRegistry |
SharedStateRegistryFactory.create(Executor deleteExecutor)
Factory method for
SharedStateRegistry . |
SharedStateRegistry |
IncrementalRemoteKeyedStateHandle.getSharedStateRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
CompositeStateHandle.registerSharedStates(SharedStateRegistry stateRegistry)
Register both newly created and already referenced shared states in the given
SharedStateRegistry . |
void |
KeyGroupsStateHandle.registerSharedStates(SharedStateRegistry stateRegistry) |
void |
IncrementalRemoteKeyedStateHandle.registerSharedStates(SharedStateRegistry stateRegistry) |
void |
DirectoryKeyedStateHandle.registerSharedStates(SharedStateRegistry stateRegistry) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.