|
Change Parameter Type keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBValueState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBValueState |
From |
To |
|
Change Parameter Type keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBListState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Change Parameter Type keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBReducingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBReducingState |
From |
To |
|
Change Parameter Type keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBFoldingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState |
From |
To |
|
Merge Parameter [dbPath : File, backupPath : String, options : Options] to backend : RocksDBStateBackend in method package RocksDBReducingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBReducingState |
From |
To |
|
Merge Parameter [dbPath : File, backupPath : String, options : Options] to backend : RocksDBStateBackend in method package RocksDBFoldingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState |
From |
To |
|
Merge Parameter [dbPath : File, backupPath : String, options : Options] to backend : RocksDBStateBackend in method package RocksDBValueState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBValueState |
From |
To |
|
Merge Parameter [dbPath : File, backupPath : String, options : Options] to backend : RocksDBStateBackend in method package RocksDBListState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Change Variable Type fakeIntSerializer : TypeSerializer<Integer> to fakeStringSerializer : TypeSerializer<String> in method public testReducingStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type fakeIntSerializer : TypeSerializer<Integer> to fakeStringSerializer : TypeSerializer<String> in method public testValueStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type currentOptions : Options to currentOptions : DBOptions in method public testOptionsFactory() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendConfigTest |
From |
To |
|
Change Variable Type opt : Options to opt : DBOptions in method public getDbOptions() : DBOptions in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Variable Type fakeIntSerializer : TypeSerializer<Integer> to fakeStringSerializer : TypeSerializer<String> in method public testListStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Variable Type currentOptions : Options to currentOptions : DBOptions in method public testPredefinedAndOptionsFactory() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendConfigTest |
From |
To |
|
Change Variable Type opt2 : Options to opt2 : DBOptions in method public testPredefinedOptions() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendConfigTest |
From |
To |
|
Change Variable Type opt : Options to opt : DBOptions in method public testPredefinedOptionsEnum() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendConfigTest |
From |
To |
|
Change Variable Type opt1 : Options to opt1 : DBOptions in method public testPredefinedOptions() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendConfigTest |
From |
To |
|
Rename Variable restored2State : ListState<String> to restored2 : ListState<String> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable restored2State : FoldingState<Integer,String> to restored2 : FoldingState<Integer,String> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable fakeIntSerializer : TypeSerializer<Integer> to fakeStringSerializer : TypeSerializer<String> in method public testReducingStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable fakeIntSerializer : TypeSerializer<Integer> to fakeStringSerializer : TypeSerializer<String> in method public testValueStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable restored1State : FoldingState<Integer,String> to restored1 : FoldingState<Integer,String> in method public testFoldingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable fakeIntSerializer : TypeSerializer<Integer> to fakeStringSerializer : TypeSerializer<String> in method public testListStateRestoreWithWrongSerializers() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable restored1State : ValueState<String> to restored1 : ValueState<String> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable restored1State : ReducingState<String> to restored1 : ReducingState<String> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable restored1State : ListState<String> to restored1 : ListState<String> in method public testListState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable restored2State : ValueState<String> to restored2 : ValueState<String> in method public testValueState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Variable restored2State : ReducingState<String> to restored2 : ReducingState<String> in method public testReducingState() : void in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Parameter keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBValueState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBValueState |
From |
To |
|
Rename Parameter keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBListState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Rename Parameter currentKey : K to key : K in method public setCurrentKey(key K) : void in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Rename Parameter keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBReducingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<V>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBReducingState |
From |
To |
|
Rename Parameter keySerializer : TypeSerializer<K> to columnFamily : ColumnFamilyHandle in method package RocksDBFoldingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>, backend RocksDBStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState |
From |
To |