Uses of Interface
org.apache.flink.runtime.state.SharedStateRegistry

Packages that use SharedStateRegistry

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.state
org.apache.flink.runtime.state.changelog
org.apache.flink.runtime.state.changelog.inmemory
org.apache.flink.runtime.state.filemerging

Uses of SharedStateRegistry in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return SharedStateRegistry

Modifier and Type	Method and Description
SharedStateRegistry	DeactivatedCheckpointCompletedCheckpointStore.getSharedStateRegistry()
SharedStateRegistry	AbstractCompleteCheckpointStore.getSharedStateRegistry()
SharedStateRegistry	CompletedCheckpointStore.getSharedStateRegistry() Returns the SharedStateRegistry used to register the shared state.

Methods in org.apache.flink.runtime.checkpoint with parameters of type SharedStateRegistry

Modifier and Type	Method and Description
void	TaskState.registerSharedStates(SharedStateRegistry sharedStateRegistry, long checkpointID) Deprecated.
void	OperatorState.registerSharedStates(SharedStateRegistry sharedStateRegistry, long checkpointID)
void	SubtaskState.registerSharedStates(SharedStateRegistry sharedStateRegistry, long checkpointID) Deprecated.
void	TaskStateSnapshot.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)
void	OperatorSubtaskState.registerSharedStates(SharedStateRegistry sharedStateRegistry, long checkpointID)
void	CompletedCheckpoint.registerSharedStatesAfterRestored(SharedStateRegistry sharedStateRegistry, RestoreMode restoreMode) Register all shared states in the given registry.

Constructors in org.apache.flink.runtime.checkpoint with parameters of type SharedStateRegistry

Constructor and Description
AbstractCompleteCheckpointStore(SharedStateRegistry sharedStateRegistry)
DefaultCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain, StateHandleStore<CompletedCheckpoint,R> stateHandleStore, CheckpointStoreUtil completedCheckpointStoreUtil, Collection<CompletedCheckpoint> completedCheckpoints, SharedStateRegistry sharedStateRegistry, Executor executor) Creates a DefaultCompletedCheckpointStore instance.
EmbeddedCompletedCheckpointStore(int maxRetainedCheckpoints, Collection<CompletedCheckpoint> initialCheckpoints, SharedStateRegistry sharedStateRegistry)

Uses of SharedStateRegistry in org.apache.flink.runtime.state

Classes in org.apache.flink.runtime.state that implement SharedStateRegistry

Modifier and Type	Class and Description
class	SharedStateRegistryImpl SharedStateRegistry implementation.

Methods in org.apache.flink.runtime.state that return SharedStateRegistry

Modifier and Type	Method and Description
SharedStateRegistry	SharedStateRegistryFactory.create(Executor deleteExecutor, Collection<CompletedCheckpoint> checkpoints, RestoreMode restoreMode) Factory method for SharedStateRegistry.
SharedStateRegistry	IncrementalRemoteKeyedStateHandle.getSharedStateRegistry()

Methods in org.apache.flink.runtime.state with parameters of type SharedStateRegistry

Modifier and Type	Method and Description
void	CompositeStateHandle.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID) Register both newly created and already referenced shared states in the given SharedStateRegistry.
void	IncrementalRemoteKeyedStateHandle.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)
void	KeyGroupsStateHandle.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)
void	IncrementalLocalKeyedStateHandle.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)

Uses of SharedStateRegistry in org.apache.flink.runtime.state.changelog

Methods in org.apache.flink.runtime.state.changelog with parameters of type SharedStateRegistry

Modifier and Type	Method and Description
void	ChangelogStateBackendLocalHandle.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)
void	ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)
void	ChangelogStateHandleStreamImpl.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)

Uses of SharedStateRegistry in org.apache.flink.runtime.state.changelog.inmemory

Methods in org.apache.flink.runtime.state.changelog.inmemory with parameters of type SharedStateRegistry

Modifier and Type	Method and Description
void	InMemoryChangelogStateHandle.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointID)

Uses of SharedStateRegistry in org.apache.flink.runtime.state.filemerging

Methods in org.apache.flink.runtime.state.filemerging with parameters of type SharedStateRegistry

Modifier and Type	Method and Description
void	FileMergingOperatorStreamStateHandle.registerSharedStates(SharedStateRegistry stateRegistry, long checkpointId)