54ef382439b1687a645a377a5f6a095746423109
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method protected writeCurrentKeyWithGroupAndNamespace() : void renamed to package serializeCurrentKeyWithGroupAndNamespace() : byte[] in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
| Pull Up Method | 1 | ||
| Pull Up Method private getPreMergedValue(values List<V>, elementSerializer TypeSerializer<V>, keySerializationStream DataOutputSerializer) : byte[] from class org.apache.flink.contrib.streaming.state.RocksDBListState to package serializeValueList(valueList List<T>, elementSerializer TypeSerializer<T>, delimiter byte) : byte[] from class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type elementSerializer : TypeSerializer<V> to elementSerializer : TypeSerializer<T> in method package serializeValueList(valueList List<T>, elementSerializer TypeSerializer<T>, delimiter byte) : byte[] in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
| Change Return Type | 1 | ||
| Change Return Type void to byte[] in method package serializeCurrentKeyWithGroupAndNamespace() : byte[] in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute inputView : DataInputDeserializer to dataInputView : DataInputDeserializer in method public getSerializedValue(serializedKeyAndNamespace byte[], safeKeySerializer TypeSerializer<K>, safeNamespaceSerializer TypeSerializer<N>, safeValueSerializer TypeSerializer<Map<UK,UV>>) : byte[] in class org.apache.flink.contrib.streaming.state.RocksDBMapState | From | To |