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) |
Constructor and Description |
---|
KeyedBackendSerializationProxy(TypeSerializer<K> keySerializer,
List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> stateMetaInfoSnapshots) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.