|
Change Return Type KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,Backend> to KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,RocksDBStateBackend> in method protected createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc FoldingStateDescriptor<T,ACC>, dbPath File, backupPath String, restorePath String, options Options) : KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState.Snapshot |
From |
To |
|
Change Return Type KvStateSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,Backend> to AbstractRocksDBSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>> in method protected createRocksDBSnapshot(backupUri URI, checkpointId long) : AbstractRocksDBSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>> in class org.apache.flink.contrib.streaming.state.RocksDBFoldingState |
From |
To |