flink 237d07c76b51c171f0f41f9f82d777df26da1dd4

237d07c76b51c171f0f41f9f82d777df26da1dd4

Files Diff

Added: 10
Removed: 0
Renamed: 0
Modified: 18

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Pull Up Method	1
	Pull Up Method public getCompressionDecorator(executionConfig ExecutionConfig) : StreamCompressionDecorator from class org.apache.flink.contrib.streaming.state.RocksDBStateBackend to public getCompressionDecorator(executionConfig ExecutionConfig) : StreamCompressionDecorator from class org.apache.flink.runtime.state.AbstractStateBackend	From	To
	Move Method	4
	Move Method private readStateHandleStateData(fsDataInputStream FSDataInputStream, inView DataInputViewStreamWrapper, keyGroupOffsets KeyGroupRangeOffsets, kvStatesById Map<Integer,StateMetaInfoSnapshot>, numStates int, readVersion int, isCompressed boolean) : void from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend to private readStateHandleStateData(fsDataInputStream FSDataInputStream, inView DataInputViewStreamWrapper, keyGroupOffsets KeyGroupRangeOffsets, kvStatesById Map<Integer,StateMetaInfoSnapshot>, numStates int, readVersion int, isCompressed boolean) : void from class org.apache.flink.runtime.state.heap.HeapRestoreOperation	From	To
	Move Method private hasRegisteredState() : boolean from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend to private hasRegisteredState() : boolean from class org.apache.flink.runtime.state.heap.HeapSnapshotStrategy	From	To
	Move Method private readKeyGroupStateData(inputStream InputStream, kvStatesById Map<Integer,StateMetaInfoSnapshot>, keyGroupIndex int, numStates int, readVersion int) : void from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend to private readKeyGroupStateData(inputStream InputStream, kvStatesById Map<Integer,StateMetaInfoSnapshot>, keyGroupIndex int, numStates int, readVersion int) : void from class org.apache.flink.runtime.state.heap.HeapRestoreOperation	From	To
	Move Method private createOrCheckStateForMetaInfo(restoredMetaInfo List<StateMetaInfoSnapshot>, kvStatesById Map<Integer,StateMetaInfoSnapshot>) : void from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend to private createOrCheckStateForMetaInfo(restoredMetaInfo List<StateMetaInfoSnapshot>, kvStatesById Map<Integer,StateMetaInfoSnapshot>) : void from class org.apache.flink.runtime.state.heap.HeapRestoreOperation	From	To
	Extract Class	1
	Extract Class org.apache.flink.runtime.state.heap.HeapRestoreOperation from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
	Move Class	2
	Move Class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.SnapshotStrategySynchronicityBehavior moved to org.apache.flink.runtime.state.heap.SnapshotStrategySynchronicityBehavior	From	To
	Move Class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.StateUID moved to org.apache.flink.runtime.state.heap.StateUID	From	To
	Change Attribute Type	1
	Change Attribute Type snapshotStrategy : HeapSnapshotStrategy to snapshotStrategy : HeapSnapshotStrategy<K> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend	From	To
	Extract Method	2
	Extract Method private getLongHeapKeyedStateBackend(key long) : HeapKeyedStateBackend<Long> extracted from public testMapSerialization() : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest	From	To
	Extract Method private getLongHeapKeyedStateBackend(key long) : HeapKeyedStateBackend<Long> extracted from public testListSerialization() : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest	From	To