|
Change Parameter Type iterator : RocksIterator to iterator : RocksIteratorWrapper in method package MergeIterator(iterator RocksIteratorWrapper, kvStateId int) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.MergeIterator |
From |
To |
|
Change Parameter Type iterator : RocksIterator to iterator : RocksIteratorWrapper in method package RocksIteratorForKeysWrapper(iterator RocksIteratorWrapper, state String, keySerializer TypeSerializer<K>, keyGroupPrefixBytes int, ambiguousKeyPossible boolean, namespaceBytes byte[]) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksIteratorForKeysWrapper |
From |
To |
|
Change Parameter Type kvStateIterators : List<Tuple2<RocksIterator,Integer>> to kvStateIterators : List<Tuple2<RocksIteratorWrapper,Integer>> in method package RocksDBMergeIterator(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>, keyGroupPrefixByteCount int) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBMergeIterator |
From |
To |
|
Change Variable Type kvStateIterator : Tuple2<RocksIterator,Integer> to kvStateIterator : Tuple2<RocksIteratorWrapper,Integer> in method public releaseSnapshotResources() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation |
From |
To |
|
Change Variable Type rocksIterator : RocksIterator to rocksIterator : RocksIteratorWrapper in method public next() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBMergeIterator |
From |
To |
|
Change Variable Type rocksIteratorsWithKVStateId : List<Tuple2<RocksIterator,Integer>> to rocksIteratorsWithKVStateId : List<Tuple2<RocksIteratorWrapper,Integer>> in method public testMergeIterator(maxParallelism int) : void in class org.apache.flink.contrib.streaming.state.RocksDBMergeIteratorTest |
From |
To |
|
Change Variable Type rocksIterator : RocksIterator to rocksIterator : RocksIteratorWrapper in method package RocksDBMergeIterator(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>, keyGroupPrefixByteCount int) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBMergeIterator |
From |
To |
|
Change Variable Type iterator : RocksIterator to iterator : RocksIteratorWrapper in method package testIteratorHelper(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer, maxKeyGroupNumber int, getKeyFunc Function<Integer,K>) : void in class org.apache.flink.contrib.streaming.state.RocksDBRocksIteratorForKeysWrapperTest |
From |
To |
|
Change Variable Type rocksIteratorWithKVStateId : Tuple2<RocksIterator,Integer> to rocksIteratorWithKVStateId : Tuple2<RocksIteratorWrapper,Integer> in method package RocksDBMergeIterator(kvStateIterators List<Tuple2<RocksIteratorWrapper,Integer>>, keyGroupPrefixByteCount int) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBMergeIterator |
From |
To |