flink f2af1a9f916bd9b941a48a1da577d19fc07badde

f2af1a9f916bd9b941a48a1da577d19fc07badde

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 4

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	5
	Change Parameter Type stateBackend : RocksDBKeyedStateBackend<?> to stateBackend : RocksDBKeyedStateBackend<T> in method private RocksDBIncrementalRestoreOperation(stateBackend RocksDBKeyedStateBackend<T>) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation	From	To
	Change Parameter Type rocksDBKeyedStateBackend : RocksDBKeyedStateBackend<?> to rocksDBKeyedStateBackend : RocksDBKeyedStateBackend<K> in method public RocksDBFullRestoreOperation(rocksDBKeyedStateBackend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation	From	To
	Change Parameter Type keySerializer : TypeSerializer<?> to keySerializer : TypeSerializer<K> in method public KeyedBackendSerializationProxy(keySerializer TypeSerializer<K>, stateMetaInfoSnapshots List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>>) in class org.apache.flink.runtime.state.KeyedBackendSerializationProxy	From	To
	Change Parameter Type stateBackend : RocksDBKeyedStateBackend<?> to stateBackend : RocksDBKeyedStateBackend<K> in method private RocksDBIncrementalSnapshotOperation(stateBackend RocksDBKeyedStateBackend<K>, checkpointStreamFactory CheckpointStreamFactory, checkpointId long, checkpointTimestamp long) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation	From	To
	Change Parameter Type stateBackend : RocksDBKeyedStateBackend<?> to stateBackend : RocksDBKeyedStateBackend<K> in method package RocksDBFullSnapshotOperation(stateBackend RocksDBKeyedStateBackend<K>, checkpointStreamFactory CheckpointStreamFactory) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation	From	To
	Change Return Type	1
	Change Return Type TypeSerializer<?> to TypeSerializer<K> in method public getKeySerializer() : TypeSerializer<K> in class org.apache.flink.runtime.state.KeyedBackendSerializationProxy	From	To
	Change Variable Type	3
	Change Variable Type keySerializerProxy : TypeSerializerSerializationProxy<?> to keySerializerProxy : TypeSerializerSerializationProxy<K> in method public read(in DataInputView) : void in class org.apache.flink.runtime.state.KeyedBackendSerializationProxy	From	To
	Change Variable Type namespaceCompatibility : CompatibilityResult<N> to namespaceCompatibility : CompatibilityResult<?> in method protected getColumnFamily(descriptor StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
	Change Variable Type stateDescriptor : StateDescriptor to stateDescriptor : StateDescriptor<?,?> in method private restoreOldSavepointKeyedState(restoreState Collection<KeyedStateHandle>) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
	Change Attribute Type	6
	Change Attribute Type keySerializer : TypeSerializer<?> to keySerializer : TypeSerializer<K> in class org.apache.flink.runtime.state.KeyedBackendSerializationProxy	From	To
	Change Attribute Type restoredKvStateMetaInfos : Map<String,RegisteredKeyedBackendStateMetaInfo.Snapshot> to restoredKvStateMetaInfos : Map<String,RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend	From	To
	Change Attribute Type stateBackend : RocksDBKeyedStateBackend<?> to stateBackend : RocksDBKeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation	From	To
	Change Attribute Type rocksDBKeyedStateBackend : RocksDBKeyedStateBackend<?> to rocksDBKeyedStateBackend : RocksDBKeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation	From	To
	Change Attribute Type stateBackend : RocksDBKeyedStateBackend<?> to stateBackend : RocksDBKeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation	From	To
	Change Attribute Type stateBackend : RocksDBKeyedStateBackend<?> to stateBackend : RocksDBKeyedStateBackend<T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation	From	To