addd0842f9d74b05fc44374c6682b6e697603939
Files Diff
- Added: 7
- Removed: 1
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 5 | ||
| Change Parameter Type backend : RocksDBKeyedStateBackend to backend : RocksDBKeyedStateBackend<K> in method public RocksDBListState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<V>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBListState | From | To | |
| Change Parameter Type backend : RocksDBKeyedStateBackend to backend : RocksDBKeyedStateBackend<K> in method public RocksDBFoldingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState | From | To | |
| Change Parameter Type backend : RocksDBKeyedStateBackend to backend : RocksDBKeyedStateBackend<K> in method protected AbstractRocksDBState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc SD, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
| Change Parameter Type backend : RocksDBKeyedStateBackend to backend : RocksDBKeyedStateBackend<K> in method public RocksDBReducingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<V>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBReducingState | From | To | |
| Change Parameter Type backend : RocksDBKeyedStateBackend to backend : RocksDBKeyedStateBackend<K> in method public RocksDBValueState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBValueState | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Future<KeyGroupsStateHandle> to RunnableFuture<KeyGroupsStateHandle> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyGroupsStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Move Class | 2 | ||
| Move Class org.apache.flink.contrib.streaming.state.RocksDBAsyncKVSnapshotTest.AsyncCheckpointOperator moved to org.apache.flink.contrib.streaming.state.RocksDBAsyncSnapshotTest.AsyncCheckpointOperator | From | To | |
| Move Class org.apache.flink.contrib.streaming.state.RocksDBAsyncKVSnapshotTest.DummyMapFunction moved to org.apache.flink.contrib.streaming.state.RocksDBAsyncSnapshotTest.DummyMapFunction | From | To | |
| Replace Variable With Attribute | 2 | ||
| Replace Variable With Attribute baos : ByteArrayOutputStream to keySerializationStream : ByteArrayOutputStreamWithPos in method public clear() : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
| Replace Variable With Attribute baos : ByteArrayOutputStream to keySerializationStream : ByteArrayOutputStreamWithPos in method public get() : ACC in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute dbCleanupLock : SerializableObject to dbDisposeLock : SerializableObject in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract Variable | 1 | ||
| Extract Variable cleanupRockDBReference : RocksDB in method public close() : void from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type baos : ByteArrayOutputStream to keySerializationStream : ByteArrayOutputStreamWithPos in method public clear() : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type backend : RocksDBKeyedStateBackend to backend : RocksDBKeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To |