Package | Description |
---|---|
org.apache.flink.runtime.state |
Modifier and Type | Field and Description |
---|---|
protected RegisteredOperatorBackendStateMetaInfo.Snapshot<S> |
OperatorBackendStateMetaInfoSnapshotReaderWriters.AbstractOperatorBackendStateMetaInfoWriter.stateMetaInfo |
Modifier and Type | Method and Description |
---|---|
RegisteredOperatorBackendStateMetaInfo.Snapshot<S> |
OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReader.readStateMetaInfo(DataInputView in) |
RegisteredOperatorBackendStateMetaInfo.Snapshot<S> |
OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV1.readStateMetaInfo(DataInputView in) |
RegisteredOperatorBackendStateMetaInfo.Snapshot<S> |
OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV2.readStateMetaInfo(DataInputView in) |
RegisteredOperatorBackendStateMetaInfo.Snapshot<S> |
RegisteredOperatorBackendStateMetaInfo.snapshot() |
Modifier and Type | Method and Description |
---|---|
List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> |
OperatorBackendSerializationProxy.getStateMetaInfoSnapshots() |
Modifier and Type | Method and Description |
---|---|
static <S> OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriter |
OperatorBackendStateMetaInfoSnapshotReaderWriters.getWriterForVersion(int version,
RegisteredOperatorBackendStateMetaInfo.Snapshot<S> stateMetaInfo) |
Constructor and Description |
---|
AbstractOperatorBackendStateMetaInfoWriter(RegisteredOperatorBackendStateMetaInfo.Snapshot<S> stateMetaInfo) |
OperatorBackendStateMetaInfoWriterV1(RegisteredOperatorBackendStateMetaInfo.Snapshot<S> stateMetaInfo) |
OperatorBackendStateMetaInfoWriterV2(RegisteredOperatorBackendStateMetaInfo.Snapshot<S> stateMetaInfo) |
Constructor and Description |
---|
OperatorBackendSerializationProxy(List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> stateMetaInfoSnapshots) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.