|
Change Return Type KvStateSnapshot<K,N,S,SD,Backend> to AbstractRocksDBSnapshot<K,N,S,SD> in method public snapshot(checkpointId long, timestamp long) : AbstractRocksDBSnapshot<K,N,S,SD> in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Return Type KvState<K,N,S,SD,Backend> to KvState<K,N,S,SD,RocksDBStateBackend> in method public restoreState(stateBackend RocksDBStateBackend, keySerializer TypeSerializer<K>, classLoader ClassLoader, recoveryTimestamp long) : KvState<K,N,S,SD,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot |
From |
To |
|
Change Return Type KvStateSnapshot<K,N,S,SD,Backend> to AbstractRocksDBSnapshot<K,N,S,SD> in method protected abstract createRocksDBSnapshot(backupUri URI, checkpointId long) : AbstractRocksDBSnapshot<K,N,S,SD> in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState |
From |
To |
|
Change Return Type KvStateSnapshot<K,N,ValueState<V>,ValueStateDescriptor<V>,Backend> to AbstractRocksDBSnapshot<K,N,ValueState<V>,ValueStateDescriptor<V>> in method protected createRocksDBSnapshot(backupUri URI, checkpointId long) : AbstractRocksDBSnapshot<K,N,ValueState<V>,ValueStateDescriptor<V>> in class org.apache.flink.contrib.streaming.state.RocksDBValueState |
From |
To |
|
Change Return Type KvStateSnapshot<K,N,ListState<V>,ListStateDescriptor<V>,Backend> to AbstractRocksDBSnapshot<K,N,ListState<V>,ListStateDescriptor<V>> in method protected createRocksDBSnapshot(backupUri URI, checkpointId long) : AbstractRocksDBSnapshot<K,N,ListState<V>,ListStateDescriptor<V>> in class org.apache.flink.contrib.streaming.state.RocksDBListState |
From |
To |
|
Change Return Type KvState<K,N,ListState<V>,ListStateDescriptor<V>,Backend> to KvState<K,N,ListState<V>,ListStateDescriptor<V>,RocksDBStateBackend> in method protected createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<V>, dbPath File, backupPath String, restorePath String, options Options) : KvState<K,N,ListState<V>,ListStateDescriptor<V>,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.RocksDBListState.Snapshot |
From |
To |
|
Change Return Type KvState<K,N,ReducingState<V>,ReducingStateDescriptor<V>,Backend> to KvState<K,N,ReducingState<V>,ReducingStateDescriptor<V>,RocksDBStateBackend> in method protected createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<V>, dbPath File, backupPath String, restorePath String, options Options) : KvState<K,N,ReducingState<V>,ReducingStateDescriptor<V>,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.RocksDBReducingState.Snapshot |
From |
To |
|
Change Return Type KvStateSnapshot<K,N,ReducingState<V>,ReducingStateDescriptor<V>,Backend> to AbstractRocksDBSnapshot<K,N,ReducingState<V>,ReducingStateDescriptor<V>> in method protected createRocksDBSnapshot(backupUri URI, checkpointId long) : AbstractRocksDBSnapshot<K,N,ReducingState<V>,ReducingStateDescriptor<V>> in class org.apache.flink.contrib.streaming.state.RocksDBReducingState |
From |
To |
|
Change Return Type KvState<K,N,ValueState<V>,ValueStateDescriptor<V>,Backend> to KvState<K,N,ValueState<V>,ValueStateDescriptor<V>,RocksDBStateBackend> in method protected createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>, dbPath File, backupPath String, restorePath String, options Options) : KvState<K,N,ValueState<V>,ValueStateDescriptor<V>,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.RocksDBValueState.Snapshot |
From |
To |