|
Change Parameter Type operatorId : int to stateId : String in method public createKvState(stateId String, stateName String, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) : FsHeapKvState<K,V> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Change Parameter Type operatorId : int to stateId : String in method public createKvState(stateId String, stateName String, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) : MemHeapKvState<K,V> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Change Parameter Type operatorId : int to stateId : String in method public createKvState(stateId String, stateName String, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) : LazyDbKvState<K,V> in class org.apache.flink.contrib.streaming.state.DbStateBackend |
From |
To |
|
Rename Parameter operatorId : int to stateId : String in method public createKvState(stateId String, stateName String, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) : MemHeapKvState<K,V> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Rename Parameter operatorId : int to stateId : String in method public createKvState(stateId String, stateName String, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) : LazyDbKvState<K,V> in class org.apache.flink.contrib.streaming.state.DbStateBackend |
From |
To |
|
Rename Parameter operatorId : int to stateId : String in method public createKvState(stateId String, stateName String, keySerializer TypeSerializer<K>, valueSerializer TypeSerializer<V>, defaultValue V) : FsHeapKvState<K,V> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |