9d67afbb84736ee8c28ec1bd69eef8ddff4754f0
Files Diff
- Added: 6
- Removed: 2
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 2 | ||
| Rename Variable key : byte[] to keyBytes : byte[] in method public hasNext() : boolean in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator | From | To | |
| Rename Variable value : K to currentKey : K in method public hasNext() : boolean in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator | From | To | |
| Rename Class | 2 | ||
| Rename Class org.apache.flink.contrib.streaming.state.RocksDBMergeIteratorTest renamed to org.apache.flink.contrib.streaming.state.RocksKeyGroupsRocksSingleStateIteratorTest | From | To | |
| Rename Class org.apache.flink.contrib.streaming.state.RocksDBRocksIteratorForKeysWrapperTest renamed to org.apache.flink.contrib.streaming.state.RocksDBRocksStateKeysIteratorTest | From | To | |
| Move And Rename Class | 4 | ||
| Move And Rename Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.MergeIterator moved and renamed to org.apache.flink.contrib.streaming.state.iterator.RocksSingleStateIterator | From | To | |
| Move And Rename Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksIteratorForKeysWrapper moved and renamed to org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator | From | To | |
| Move And Rename Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.TransformingRocksIteratorWrapper moved and renamed to org.apache.flink.contrib.streaming.state.iterator.RocksTransformingIteratorWrapper | From | To | |
| Move And Rename Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBMergeIterator moved and renamed to org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute inputStream : ByteArrayInputStreamWithPos to byteArrayDataInputView : ByteArrayDataInputView in method public hasNext() : boolean in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator | From | To | |
| Change Variable Type | 9 | ||
| Change Variable Type mergeIterator : RocksDBKeyedStateBackend.RocksDBMergeIterator to mergeIterator : RocksStatesPerKeyGroupMergeIterator in method public testMergeIterator(maxParallelism int) : void in class org.apache.flink.contrib.streaming.state.RocksKeyGroupsRocksSingleStateIteratorTest | From | To | |
| Change Variable Type emptyIterator : RocksDBKeyedStateBackend.RocksDBMergeIterator to emptyIterator : RocksStatesPerKeyGroupMergeIterator in method public testEmptyMergeIterator() : void in class org.apache.flink.contrib.streaming.state.RocksKeyGroupsRocksSingleStateIteratorTest | From | To | |
| Change Variable Type mergeIterator : RocksDBMergeIterator to mergeIterator : RocksStatesPerKeyGroupMergeIterator in method private writeKVStateData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation | From | To | |
| Change Variable Type inputStream : ByteArrayInputStreamWithPos to byteArrayDataInputView : ByteArrayDataInputView in method public hasNext() : boolean in class org.apache.flink.contrib.streaming.state.iterator.RocksStateKeysIterator | From | To | |
| Change Variable Type iteratorWrapper : RocksDBKeyedStateBackend.RocksIteratorForKeysWrapper<K> to iteratorWrapper : RocksStateKeysIterator<K> in method package testIteratorHelper(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer, maxKeyGroupNumber int, getKeyFunc Function<Integer,K>) : void in class org.apache.flink.contrib.streaming.state.RocksDBRocksStateKeysIteratorTest | From | To | |
| Change Variable Type iteratorComparator : Comparator<MergeIterator> to iteratorComparator : Comparator<RocksSingleStateIterator> in method private buildIteratorHeap(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>) : PriorityQueue<RocksSingleStateIterator> in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator | From | To | |
| Change Variable Type iteratorPriorityQueue : PriorityQueue<MergeIterator> to iteratorPriorityQueue : PriorityQueue<RocksSingleStateIterator> in method private buildIteratorHeap(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>) : PriorityQueue<RocksSingleStateIterator> in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator | From | To | |
| Change Variable Type iteratorWrapper : RocksIteratorForKeysWrapper<K> to iteratorWrapper : RocksStateKeysIterator<K> in method public getKeys(state String, namespace N) : Stream<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Variable Type outputStream : ByteArrayOutputStreamWithPos to outputStream : ByteArrayDataOutputView in method package testIteratorHelper(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer, maxKeyGroupNumber int, getKeyFunc Function<Integer,K>) : void in class org.apache.flink.contrib.streaming.state.RocksDBRocksStateKeysIteratorTest | From | To | |
| Extract Method | 1 | ||
| Extract Method private buildIteratorHeap(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>) : PriorityQueue<RocksSingleStateIterator> extracted from package RocksDBMergeIterator(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>, keyGroupPrefixByteCount int) in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type COMPARATORS : List<Comparator<MergeIterator>> to COMPARATORS : List<Comparator<RocksSingleStateIterator>> in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator | From | To | |
| Change Attribute Type currentSubIterator : MergeIterator to currentSubIterator : RocksSingleStateIterator in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator | From | To | |
| Change Attribute Type heap : PriorityQueue<RocksDBKeyedStateBackend.MergeIterator> to heap : PriorityQueue<RocksSingleStateIterator> in class org.apache.flink.contrib.streaming.state.iterator.RocksStatesPerKeyGroupMergeIterator | From | To |