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