Package org.apache.flink.state.changelog.restore

Class ChangelogMigrationRestoreTarget<K>

java.lang.Object

org.apache.flink.state.changelog.restore.ChangelogMigrationRestoreTarget<K>

All Implemented Interfaces:

ChangelogRestoreTarget<K>

public class ChangelogMigrationRestoreTarget<K>
extends Object
implements ChangelogRestoreTarget<K>

A ChangelogRestoreTarget supports to migrate to the delegated keyed state backend.

Constructor Summary

Constructors

Constructor	Description
ChangelogMigrationRestoreTarget(AbstractKeyedStateBackend<K> keyedStateBackend, ChangelogStateFactory changelogStateFactory)

Method Summary

Modifier and Type	Method	Description
<N,S extends State,V> S	createKeyedState(TypeSerializer<N> namespaceSerializer, StateDescriptor<S,V> stateDescriptor)	Creates a keyed state which could be retrieved by ChangelogRestoreTarget.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 ChangelogRestoreTarget.getExistingState(String, BackendStateType) in the restore procedure.
ChangelogState	getExistingState(String name, StateMetaInfoSnapshot.BackendStateType type)	Returns the existing state created by ChangelogRestoreTarget.createKeyedState(TypeSerializer, StateDescriptor) or ChangelogRestoreTarget.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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChangelogMigrationRestoreTarget

public ChangelogMigrationRestoreTarget(AbstractKeyedStateBackend<K> keyedStateBackend,
                                       ChangelogStateFactory changelogStateFactory)

Method Detail

getKeyGroupRange

public KeyGroupRange getKeyGroupRange()

Description copied from interface: ChangelogRestoreTarget

Returns the key groups which this restore procedure covers.

Specified by:

getKeyGroupRange in interface ChangelogRestoreTarget<K>

createKeyedState

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

Description copied from interface: ChangelogRestoreTarget

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

Specified by:

createKeyedState in interface ChangelogRestoreTarget<K>

Throws:

Exception

createPqState

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

Description copied from interface: ChangelogRestoreTarget

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

Specified by:

createPqState in interface ChangelogRestoreTarget<K>

getExistingState

public ChangelogState getExistingState(String name,
                                       StateMetaInfoSnapshot.BackendStateType type)

Description copied from interface: ChangelogRestoreTarget

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

Specified by:

getExistingState in interface ChangelogRestoreTarget<K>

getRestoredKeyedStateBackend

public CheckpointableKeyedStateBackend<K> getRestoredKeyedStateBackend()

Description copied from interface: ChangelogRestoreTarget

Returns keyed state backend restored finally.

Specified by:

getRestoredKeyedStateBackend in interface ChangelogRestoreTarget<K>