Package | Description |
---|---|
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> |
KeyedBackendStateMetaInfoSnapshotReaderWriters.KeyedBackendStateMetaInfoReader.readStateMetaInfo(DataInputView in) |
RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> |
RegisteredKeyedBackendStateMetaInfo.snapshot() |
Modifier and Type | Method and Description |
---|---|
List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> |
KeyedBackendSerializationProxy.getStateMetaInfoSnapshots() |
Modifier and Type | Method and Description |
---|---|
static <N,S> KeyedBackendStateMetaInfoSnapshotReaderWriters.KeyedBackendStateMetaInfoWriter |
KeyedBackendStateMetaInfoSnapshotReaderWriters.getWriterForVersion(int version,
RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> stateMetaInfo) |
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. |
Constructor and Description |
---|
KeyedBackendSerializationProxy(TypeSerializer<K> keySerializer,
List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> stateMetaInfoSnapshots,
boolean compression) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.