|
Change Parameter Type unregisteredSstFiles : Map<String,StreamStateHandle> to createdSharedState : Map<StateHandleID,StreamStateHandle> in method public IncrementalKeyedStateHandle(operatorIdentifier String, keyGroupRange KeyGroupRange, checkpointId long, createdSharedState Map<StateHandleID,StreamStateHandle>, referencedSharedState Map<StateHandleID,StreamStateHandle>, privateState Map<StateHandleID,StreamStateHandle>, metaStateHandle StreamStateHandle) in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Parameter Type restoreStateHandle : RocksDBIncrementalKeyedStateHandle to restoreStateHandle : IncrementalKeyedStateHandle in method private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type keyedStateStream : KeyGroupsStateHandle to keyedStateStream : KeyedStateHandle in method public createOperatorStates(random Random, numTaskStates int, numSubtasksPerTask int) : Collection<OperatorState> in class org.apache.flink.runtime.checkpoint.savepoint.CheckpointTestUtils |
From |
To |
|
Change Variable Type oldSstFileName : Map.Entry<String,StreamStateHandle> to oldSstFileName : Map.Entry<StateHandleID,StreamStateHandle> in method public registerSharedStates(stateRegistry SharedStateRegistry) : void in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Variable Type sstFiles : Map<String,StreamStateHandle> to sstFiles : Map<StateHandleID,StreamStateHandle> in method private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type fileName : String to stateHandleID : StateHandleID in method private readAllStateData(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type keyedStateHandle : RocksDBIncrementalKeyedStateHandle to keyedStateHandle : IncrementalKeyedStateHandle in method package restore(restoreStateHandles Collection<KeyedStateHandle>) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type oldSstFiles : Map<String,StreamStateHandle> to oldSstFiles : Map<StateHandleID,StreamStateHandle> in method private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type newSstFiles : Map<String,StreamStateHandle> to newSstFiles : Map<StateHandleID,StreamStateHandle> in method private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type miscFiles : Map<String,StreamStateHandle> to miscFiles : Map<StateHandleID,StreamStateHandle> in method private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type keyedStateBackend : KeyGroupsStateHandle to keyedStateBackend : KeyedStateHandle in method public createOperatorStates(random Random, numTaskStates int, numSubtasksPerTask int) : Collection<OperatorState> in class org.apache.flink.runtime.checkpoint.savepoint.CheckpointTestUtils |
From |
To |
|
Change Variable Type miscFileEntry : Map.Entry<String,StreamStateHandle> to entry : Map.Entry<StateHandleID,StreamStateHandle> in method private readAllStateData(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type oldSstFileEntry : Map.Entry<String,StreamStateHandle> to oldSstFileEntry : Map.Entry<StateHandleID,StreamStateHandle> in method public unregisterSharedStates(stateRegistry SharedStateRegistry) : void in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Variable Type newSstFileEntry : Map.Entry<String,StreamStateHandle> to newSstFileEntry : Map.Entry<StateHandleID,StreamStateHandle> in method public unregisterSharedStates(stateRegistry SharedStateRegistry) : void in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Variable Type miscFileName : String to stateHandleID : StateHandleID in method private createFileHardLinksInRestorePath(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type newSstFileEntry : Map.Entry<String,StreamStateHandle> to newSstFileEntry : Map.Entry<StateHandleID,StreamStateHandle> in method public registerSharedStates(stateRegistry SharedStateRegistry) : void in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Variable Type sstFiles : Map<String,StreamStateHandle> to sstFiles : Map<StateHandleID,StreamStateHandle> in method package materializeSnapshot() : KeyedStateHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation |
From |
To |
|
Rename Variable miscFileName : String to stateHandleID : StateHandleID in method private createFileHardLinksInRestorePath(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Rename Variable fileName : String to stateHandleID : StateHandleID in method private readAllStateData(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Rename Variable miscFileEntry : Map.Entry<String,StreamStateHandle> to entry : Map.Entry<StateHandleID,StreamStateHandle> in method private readAllStateData(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Return Type Map<String,StreamStateHandle> to Map<StateHandleID,StreamStateHandle> in method public getReferencedSharedState() : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Return Type Map<String,StreamStateHandle> to Map<StateHandleID,StreamStateHandle> in method public getCreatedSharedState() : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Return Type Map<String,StreamStateHandle> to Map<StateHandleID,StreamStateHandle> in method public getPrivateState() : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Attribute Type unregisteredSstFiles : Map<String,StreamStateHandle> to createdSharedState : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle |
From |
To |
|
Change Attribute Type baseSstFiles : Map<String,StreamStateHandle> to baseSstFiles : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation |
From |
To |
|
Change Attribute Type oldSstFiles : Map<String,StreamStateHandle> to oldSstFiles : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation |
From |
To |
|
Change Attribute Type newSstFiles : Map<String,StreamStateHandle> to newSstFiles : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation |
From |
To |
|
Change Attribute Type miscFiles : Map<String,StreamStateHandle> to miscFiles : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation |
From |
To |
|
Change Attribute Type materializedSstFiles : SortedMap<Long,Map<String,StreamStateHandle>> to materializedSstFiles : SortedMap<Long,Map<StateHandleID,StreamStateHandle>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |