Uses of Class
org.apache.flink.util.StateMigrationException

Packages that use StateMigrationException

Package	Description
org.apache.flink.contrib.streaming.state
org.apache.flink.contrib.streaming.state.restore
org.apache.flink.runtime.state
org.apache.flink.runtime.state.restore
org.apache.flink.util

Uses of StateMigrationException in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that throw StateMigrationException

Modifier and Type	Method and Description
void	AbstractRocksDBState.migrateSerializedValue(DataInputDeserializer serializedOldValueInput, DataOutputSerializer serializedMigratedValueOutput, TypeSerializer<V> priorSerializer, TypeSerializer<V> newSerializer)

Uses of StateMigrationException in org.apache.flink.contrib.streaming.state.restore

Methods in org.apache.flink.contrib.streaming.state.restore that throw StateMigrationException

Modifier and Type	Method and Description
RocksDBRestoreResult	RocksDBHeapTimersFullRestoreOperation.restore() Restores all key-groups data that is referenced by the passed state handles.
RocksDBRestoreResult	RocksDBFullRestoreOperation.restore() Restores all key-groups data that is referenced by the passed state handles.

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

Methods in org.apache.flink.runtime.state that throw StateMigrationException

Modifier and Type	Method and Description
<K,V> BroadcastState<K,V>	DefaultOperatorStateBackend.getBroadcastState(MapStateDescriptor<K,V> stateDescriptor)

Uses of StateMigrationException in org.apache.flink.runtime.state.restore

Methods in org.apache.flink.runtime.state.restore that throw StateMigrationException

Modifier and Type	Method and Description
E	ThrowingIterator.next() Returns the next element in the iteration.
ThrowingIterator<SavepointRestoreResult>	FullSnapshotRestoreOperation.restore()

Uses of StateMigrationException in org.apache.flink.util

Methods in org.apache.flink.util that return StateMigrationException

Modifier and Type	Method and Description
static StateMigrationException	StateMigrationException.notSupported()