org.apache.flink.state.changelog.restore

Interface ChangelogRestoreTarget<K>

All Known Implementing Classes:

ChangelogMigrationRestoreTarget

@Internal
public interface ChangelogRestoreTarget<K>

Maintains metadata operation related to Changelog recovery.

Method Summary

Modifier and Type	Method and Description
<N,S extends State,V> S	createKeyedState(TypeSerializer<N> namespaceSerializer, StateDescriptor<S,V> stateDescriptor) Creates a keyed state which could be retrieved by #getExistingState(String, BackendStateType) in the restore procedure.
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	createPqState(String stateName, TypeSerializer<T> byteOrderedElementSerializer) Creates a KeyGroupedInternalPriorityQueue which could be retrieved by #getExistingState(String, BackendStateType) in the restore procedure.
ChangelogState	getExistingState(String name, StateMetaInfoSnapshot.BackendStateType type) Returns the existing state created by createKeyedState(TypeSerializer, StateDescriptor) or createPqState(String, TypeSerializer) in the restore procedure.
KeyGroupRange	getKeyGroupRange() Returns the key groups which this restore procedure covers.
CheckpointableKeyedStateBackend<K>	getRestoredKeyedStateBackend() Returns keyed state backend restored finally.

Method Detail

getKeyGroupRange

KeyGroupRange getKeyGroupRange()

Returns the key groups which this restore procedure covers.

createKeyedState

<N,S extends State,V> S createKeyedState(TypeSerializer<N> namespaceSerializer,
                                         StateDescriptor<S,V> stateDescriptor)
                                  throws Exception

Creates a keyed state which could be retrieved by #getExistingState(String, BackendStateType) in the restore procedure. The interface comes from KeyedStateBackend.getOrCreateKeyedState(TypeSerializer, StateDescriptor).

Throws:

Exception

createPqState

@Nonnull
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T> createPqState(@Nonnull
                                                                                                                                          String stateName,
                                                                                                                                          @Nonnull
                                                                                                                                          TypeSerializer<T> byteOrderedElementSerializer)

Creates a KeyGroupedInternalPriorityQueue which could be retrieved by #getExistingState(String, BackendStateType) in the restore procedure. The interface comes from PriorityQueueSetFactory.create(String, TypeSerializer).

getExistingState

ChangelogState getExistingState(String name,
                                StateMetaInfoSnapshot.BackendStateType type)

Returns the existing state created by createKeyedState(TypeSerializer, StateDescriptor) or createPqState(String, TypeSerializer) in the restore procedure.

getRestoredKeyedStateBackend

CheckpointableKeyedStateBackend<K> getRestoredKeyedStateBackend()

Returns keyed state backend restored finally.