Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.util |
Modifier and Type | Method and Description |
---|---|
<K,V> BroadcastState<K,V> |
DefaultOperatorStateBackend.getBroadcastState(MapStateDescriptor<K,V> stateDescriptor) |
static <N,S> RegisteredKeyValueStateBackendMetaInfo<N,S> |
RegisteredKeyValueStateBackendMetaInfo.resolveKvStateCompatibility(StateMetaInfoSnapshot restoredStateMetaInfoSnapshot,
TypeSerializer<N> newNamespaceSerializer,
StateDescriptor<?,S> newStateDescriptor,
StateSnapshotTransformer<S> snapshotTransformer)
Checks compatibility of a restored k/v state, with the new
StateDescriptor provided to it. |
Modifier and Type | Method and Description |
---|---|
static StateMigrationException |
StateMigrationException.notSupported() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.