fffd2e8c5c1eeaaae90eaef56cd577c631f2091b
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type inputStream : ByteArrayInputStreamWithPos to inputStream : ByteArrayDataInputView in method package RocksDBCachingPriorityQueueSet(keyGroupId int, keyGroupPrefixBytes int, db RocksDB, columnFamilyHandle ColumnFamilyHandle, byteOrderProducingSerializer TypeSerializer<E>, outputStream ByteArrayDataOutputView, inputStream ByteArrayDataInputView, batchWrapper RocksDBWriteBatchWrapper, orderedByteArraySetCache OrderedByteArraySetCache) in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet | From | To | |
| Change Parameter Type outputStream : ByteArrayOutputStreamWithPos to outputStream : ByteArrayDataOutputView in method package RocksDBCachingPriorityQueueSet(keyGroupId int, keyGroupPrefixBytes int, db RocksDB, columnFamilyHandle ColumnFamilyHandle, byteOrderProducingSerializer TypeSerializer<E>, outputStream ByteArrayDataOutputView, inputStream ByteArrayDataInputView, batchWrapper RocksDBWriteBatchWrapper, orderedByteArraySetCache OrderedByteArraySetCache) in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute elementSerializationInStream : ByteArrayInputStreamWithPos to sharedElementInView : ByteArrayDataInputView in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory | From | To | |
| Rename Attribute elementSerializationOutStream : ByteArrayOutputStreamWithPos to sharedElementOutView : ByteArrayDataOutputView in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type inputStreamWithPos : ByteArrayInputStreamWithPos to inputStreamWithPos : ByteArrayDataInputView in method private newFactory() : KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory<TestElement,RocksDBCachingPriorityQueueSet<TestElement>> in class org.apache.flink.contrib.streaming.state.KeyGroupPartitionedPriorityQueueWithRocksDBStoreTest | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type inputView : DataInputViewStreamWrapper to inputView : ByteArrayDataInputView in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet | From | To | |
| Change Attribute Type elementSerializationInStream : ByteArrayInputStreamWithPos to sharedElementInView : ByteArrayDataInputView in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory | From | To | |
| Change Attribute Type elementSerializationOutStream : ByteArrayOutputStreamWithPos to sharedElementOutView : ByteArrayDataOutputView in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory | From | To | |
| Change Attribute Type outputView : DataOutputViewStreamWrapper to outputView : ByteArrayDataOutputView in class org.apache.flink.contrib.streaming.state.RocksDBCachingPriorityQueueSet | From | To |