|
Push Down Method public getSharedState() : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getSharedState() : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public IncrementalKeyedStateHandle(backendIdentifier UUID, keyGroupRange KeyGroupRange, checkpointId long, sharedState Map<StateHandleID,StreamStateHandle>, privateState Map<StateHandleID,StreamStateHandle>, metaStateHandle StreamStateHandle) from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public IncrementalRemoteKeyedStateHandle(backendIdentifier UUID, keyGroupRange KeyGroupRange, checkpointId long, sharedState Map<StateHandleID,StreamStateHandle>, privateState Map<StateHandleID,StreamStateHandle>, metaStateHandle StreamStateHandle) from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getPrivateState() : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getPrivateState() : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getKeyGroupRange() : KeyGroupRange from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getKeyGroupRange() : KeyGroupRange from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getMetaStateHandle() : StreamStateHandle from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getMetaStateHandle() : StreamStateHandle from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public registerSharedStates(stateRegistry SharedStateRegistry) : void from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public registerSharedStates(stateRegistry SharedStateRegistry) : void from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public createSharedStateRegistryKeyFromFileName(shId StateHandleID) : SharedStateRegistryKey from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public createSharedStateRegistryKeyFromFileName(shId StateHandleID) : SharedStateRegistryKey from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getSharedStateRegistry() : SharedStateRegistry from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getSharedStateRegistry() : SharedStateRegistry from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public hashCode() : int from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public hashCode() : int from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getStateSize() : long from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getStateSize() : long from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getCheckpointId() : long from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getCheckpointId() : long from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public toString() : String from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public toString() : String from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public equals(o Object) : boolean from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public equals(o Object) : boolean from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getBackendIdentifier() : UUID from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getBackendIdentifier() : UUID from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public getIntersection(keyGroupRange KeyGroupRange) : KeyedStateHandle from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public getIntersection(keyGroupRange KeyGroupRange) : KeyedStateHandle from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Method public discardState() : void from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to public discardState() : void from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Change Parameter Type remove : IncrementalKeyedStateHandle to remove : IncrementalRemoteKeyedStateHandle in method private checkRemove(remove IncrementalRemoteKeyedStateHandle, registry SharedStateRegistry) : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Parameter Type stateHandle : IncrementalKeyedStateHandle to stateHandle : IncrementalRemoteKeyedStateHandle in method private restoreFromRemoteState(stateHandle IncrementalRemoteKeyedStateHandle) : void in class org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Parameter Type restoreStateHandle : IncrementalKeyedStateHandle to restoreStateHandle : IncrementalRemoteKeyedStateHandle in method private transferRemoteStateToLocalDirectory(temporaryRestoreInstancePath Path, restoreStateHandle IncrementalRemoteKeyedStateHandle) : IncrementalLocalKeyedStateHandle in class org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Parameter Type restoreStateHandle : IncrementalKeyedStateHandle to restoreStateHandle : IncrementalRemoteKeyedStateHandle in method private restoreDBInstanceFromStateHandle(restoreStateHandle IncrementalRemoteKeyedStateHandle, temporaryRestoreInstancePath Path) : RestoredDBInstance in class org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Parameter Type restoreStateHandle : IncrementalKeyedStateHandle to restoreStateHandle : IncrementalRemoteKeyedStateHandle in method public transferAllStateDataToDirectory(restoreStateHandle IncrementalRemoteKeyedStateHandle, dest Path, closeableRegistry CloseableRegistry) : void in class org.apache.flink.contrib.streaming.state.RocksDBStateDownloader |
From |
To |
|
Push Down Attribute private sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private LOG : Logger from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private LOG : Logger from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private metaStateHandle : StreamStateHandle from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private metaStateHandle : StreamStateHandle from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private checkpointId : long from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private checkpointId : long from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private serialVersionUID : long from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private serialVersionUID : long from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private privateState : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private privateState : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private keyGroupRange : KeyGroupRange from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private keyGroupRange : KeyGroupRange from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private backendIdentifier : UUID from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private backendIdentifier : UUID from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Push Down Attribute private sharedState : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalKeyedStateHandle to private sharedState : Map<StateHandleID,StreamStateHandle> from class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle |
From |
To |
|
Change Variable Type incrementalKeyedStateHandle : IncrementalKeyedStateHandle to incrementalKeyedStateHandle : IncrementalRemoteKeyedStateHandle in method public testSharedStateRegistrationOnRestore() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type stateHandle : IncrementalKeyedStateHandle to stateHandle : IncrementalRemoteKeyedStateHandle in method public testSharedIncrementalStateDeRegistration() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type incrementalKeyedStateHandle : IncrementalKeyedStateHandle to incrementalKeyedStateHandle : IncrementalRemoteKeyedStateHandle in method public serializeKeyedStateHandle(stateHandle KeyedStateHandle, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type stateHandle : IncrementalKeyedStateHandle to stateHandle : IncrementalRemoteKeyedStateHandle in method public testUnregisteredDiscarding() : void in class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest |
From |
To |
|
Change Variable Type incrementalKeyedStateHandle : IncrementalKeyedStateHandle to incrementalRemoteKeyedStateHandle : IncrementalRemoteKeyedStateHandle in method private restoreWithoutRescaling(keyedStateHandle KeyedStateHandle) : void in class org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type incrementalKeyedStateHandle : IncrementalKeyedStateHandle to incrementalKeyedStateHandle : IncrementalRemoteKeyedStateHandle in method public testMultiThreadRestoreThreadPoolExceptionRethrow() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateDownloaderTest |
From |
To |
|
Change Variable Type previousStateHandles : Queue<IncrementalKeyedStateHandle> to previousStateHandles : Queue<IncrementalRemoteKeyedStateHandle> in method public testSharedIncrementalStateDeRegistration() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest |
From |
To |
|
Change Variable Type stateHandleZ : IncrementalKeyedStateHandle to stateHandleZ : IncrementalRemoteKeyedStateHandle in method public testSharedStateReRegistration() : void in class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest |
From |
To |
|
Change Variable Type managedState : IncrementalKeyedStateHandle to managedState : IncrementalRemoteKeyedStateHandle in method private performIncrementalCheckpoint(jid JobID, coord CheckpointCoordinator, jobVertex1 ExecutionJobVertex, keyGroupPartitions1 List<KeyGroupRange>, timestamp long, cpSequenceNumber int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type stateHandle2 : IncrementalKeyedStateHandle to stateHandle2 : IncrementalRemoteKeyedStateHandle in method public testSharedStateDeRegistration() : void in class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest |
From |
To |
|
Change Variable Type stateHandleY : IncrementalKeyedStateHandle to stateHandleY : IncrementalRemoteKeyedStateHandle in method public testSharedStateReRegistration() : void in class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest |
From |
To |
|
Change Variable Type stateHandle1 : IncrementalKeyedStateHandle to stateHandle1 : IncrementalRemoteKeyedStateHandle in method public testSharedStateDeRegistration() : void in class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest |
From |
To |
|
Change Variable Type stateHandleX : IncrementalKeyedStateHandle to stateHandleX : IncrementalRemoteKeyedStateHandle in method public testSharedStateReRegistration() : void in class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest |
From |
To |
|
Change Variable Type incrementalKeyedStateHandle : IncrementalKeyedStateHandle to incrementalKeyedStateHandle : IncrementalRemoteKeyedStateHandle in method public testMultiThreadRestoreCorrectly() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateDownloaderTest |
From |
To |
|
Change Variable Type jmIncrementalKeyedStateHandle : IncrementalKeyedStateHandle to jmIncrementalKeyedStateHandle : IncrementalRemoteKeyedStateHandle in method protected callInternal() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.RocksDBIncrementalSnapshotOperation |
From |
To |