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.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	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.util

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

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