|
Change Parameter Type stateDesc : ListStateDescriptor<V> to valueSerializer : TypeSerializer<List<V>> in method public RocksDBListState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<List<V>>, defaultValue List<V>, elementSerializer TypeSerializer<V>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Change Parameter Type stateDesc : FoldingStateDescriptor<T,ACC> to foldFunction : FoldFunction<T,ACC> in method package FoldTransformation(foldFunction FoldFunction<T,ACC>) in class org.apache.flink.runtime.state.heap.HeapFoldingState.FoldTransformation |
From |
To |
|
Change Parameter Type stateDesc : ReducingStateDescriptor<V> to valueSerializer : TypeSerializer<V> in method public RocksDBReducingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>, defaultValue V, reduceFunction ReduceFunction<V>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBReducingState |
From |
To |
|
Change Parameter Type stateDesc : ValueStateDescriptor<V> to valueSerializer : TypeSerializer<V> in method public RocksDBValueState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>, defaultValue V, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBValueState |
From |
To |
|
Change Parameter Type stateDesc : FoldingStateDescriptor<T,ACC> to valueSerializer : TypeSerializer<ACC> in method public RocksDBFoldingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<ACC>, defaultValue ACC, foldFunction FoldFunction<T,ACC>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState |
From |
To |
|
Change Parameter Type stateDesc : AggregatingStateDescriptor<T,ACC,R> to valueSerializer : TypeSerializer<ACC> in method public RocksDBAggregatingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<ACC>, defaultValue ACC, aggFunction AggregateFunction<T,ACC,R>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState |
From |
To |
|
Rename Parameter stateDesc : ListStateDescriptor<V> to valueSerializer : TypeSerializer<List<V>> in method public RocksDBListState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<List<V>>, defaultValue List<V>, elementSerializer TypeSerializer<V>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Rename Parameter stateDesc : FoldingStateDescriptor<T,ACC> to foldFunction : FoldFunction<T,ACC> in method package FoldTransformation(foldFunction FoldFunction<T,ACC>) in class org.apache.flink.runtime.state.heap.HeapFoldingState.FoldTransformation |
From |
To |
|
Rename Parameter stateDesc : ReducingStateDescriptor<V> to valueSerializer : TypeSerializer<V> in method public RocksDBReducingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>, defaultValue V, reduceFunction ReduceFunction<V>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBReducingState |
From |
To |
|
Rename Parameter stateDesc : ValueStateDescriptor<V> to valueSerializer : TypeSerializer<V> in method public RocksDBValueState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>, defaultValue V, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBValueState |
From |
To |
|
Rename Parameter stateDesc : FoldingStateDescriptor<T,ACC> to valueSerializer : TypeSerializer<ACC> in method public RocksDBFoldingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<ACC>, defaultValue ACC, foldFunction FoldFunction<T,ACC>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState |
From |
To |
|
Rename Parameter stateDesc : AggregatingStateDescriptor<T,ACC,R> to valueSerializer : TypeSerializer<ACC> in method public RocksDBAggregatingState(columnFamily ColumnFamilyHandle, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<ACC>, defaultValue ACC, aggFunction AggregateFunction<T,ACC,R>, backend RocksDBKeyedStateBackend<K>) in class org.apache.flink.contrib.streaming.state.RocksDBAggregatingState |
From |
To |