|
Rename Method public readStateMetaInfo(in DataInputView) : RegisteredOperatorBackendStateMetaInfo.Snapshot<S> renamed to public readOperatorStateMetaInfo(in DataInputView) : RegisteredOperatorBackendStateMetaInfo.Snapshot<S> in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV1 |
From |
To |
|
Rename Method public readStateMetaInfo(in DataInputView) : RegisteredOperatorBackendStateMetaInfo.Snapshot<S> renamed to public readOperatorStateMetaInfo(in DataInputView) : RegisteredOperatorBackendStateMetaInfo.Snapshot<S> in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV2 |
From |
To |
|
Rename Method public writeStateMetaInfo(out DataOutputView) : void renamed to public writeOperatorStateMetaInfo(out DataOutputView) : void in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriterV1 |
From |
To |
|
Rename Method public writeStateMetaInfo(out DataOutputView) : void renamed to public writeOperatorStateMetaInfo(out DataOutputView) : void in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriterV2 |
From |
To |
|
Rename Method private deserializeStateValues(stateListForName PartitionableListState<S>, in FSDataInputStream, metaInfo OperatorStateHandle.StateMetaInfo) : void renamed to private deserializeOperatorStateValues(stateListForName PartitionableListState<S>, in FSDataInputStream, metaInfo OperatorStateHandle.StateMetaInfo) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Rename Method public readStateMetaInfo(in DataInputView) : RegisteredOperatorBackendStateMetaInfo.Snapshot<S> renamed to public readOperatorStateMetaInfo(in DataInputView) : RegisteredOperatorBackendStateMetaInfo.Snapshot<S> in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReader |
From |
To |
|
Rename Method public writeStateMetaInfo(out DataOutputView) : void renamed to public writeOperatorStateMetaInfo(out DataOutputView) : void in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriter |
From |
To |
|
Rename Method public getReaderForVersion(version int, userCodeClassLoader ClassLoader) : OperatorBackendStateMetaInfoReader<S> renamed to public getOperatorStateReaderForVersion(version int, userCodeClassLoader ClassLoader) : OperatorBackendStateMetaInfoReader<S> in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters |
From |
To |
|
Rename Method public getWriterForVersion(version int, stateMetaInfo RegisteredOperatorBackendStateMetaInfo.Snapshot<S>) : OperatorBackendStateMetaInfoWriter renamed to public getOperatorStateWriterForVersion(version int, stateMetaInfo RegisteredOperatorBackendStateMetaInfo.Snapshot<S>) : OperatorBackendStateMetaInfoWriter in class org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters |
From |
To |
|
Rename Method public getStateMetaInfoSnapshots() : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> renamed to public getOperatorStateMetaInfoSnapshots() : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in class org.apache.flink.runtime.state.OperatorBackendSerializationProxy |
From |
To |
|
Rename Variable stateListForName : PartitionableListState<?> to listStateForName : PartitionableListState<?> in method public restore(restoreSnapshots Collection<OperatorStateHandle>) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Rename Variable registeredStatesDeepCopies : Map<String,PartitionableListState<?>> to registeredOperatorStatesDeepCopies : Map<String,PartitionableListState<?>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<OperatorStateHandle> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Rename Variable numKvStates : int to numOperatorStates : int in method public read(in DataInputView) : void in class org.apache.flink.runtime.state.OperatorBackendSerializationProxy |
From |
To |
|
Rename Variable metaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> to operatorMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public performOperation() : OperatorStateHandle in class org.apache.flink.runtime.state.DefaultOperatorStateBackend.snapshot.ioCallable |
From |
To |
|
Rename Variable restoredMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> to restoredOperatorMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public restore(restoreSnapshots Collection<OperatorStateHandle>) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |