|
Change Parameter Type mapState : InternalMapState<Long,VoidNamespace,Long,String,M> to mapState : InternalMapState<Long,VoidNamespace,Long,String> in method public testMapSerialization(key long, mapState InternalMapState<Long,VoidNamespace,Long,String>) : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Change Parameter Type safeValueSerializer : TypeSerializer<HashMap<UK,UV>> to safeValueSerializer : TypeSerializer<Map<UK,UV>> in method public getSerializedValue(serializedKeyAndNamespace byte[], safeKeySerializer TypeSerializer<K>, safeNamespaceSerializer TypeSerializer<N>, safeValueSerializer TypeSerializer<Map<UK,UV>>) : byte[] in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Parameter Type stateTable : StateTable<K,N,HashMap<UK,UV>> to stateTable : StateTable<K,N,Map<UK,UV>> in method public HeapMapState(stateDesc MapStateDescriptor<UK,UV>, stateTable StateTable<K,N,Map<UK,UV>>, keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>) in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Return Type TypeSerializer<HashMap<UK,UV>> to TypeSerializer<Map<UK,UV>> in method public getValueSerializer() : TypeSerializer<Map<UK,UV>> in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Return Type InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> to InternalMapState<K,N,UK,UV> in method protected abstract createMapState(namespaceSerializer TypeSerializer<N>, stateDesc MapStateDescriptor<UK,UV>) : InternalMapState<K,N,UK,UV> in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Return Type InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> to InternalMapState<K,N,UK,UV> in method protected createMapState(namespaceSerializer TypeSerializer<N>, stateDesc MapStateDescriptor<UK,UV>) : InternalMapState<K,N,UK,UV> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Return Type InternalMapState<K,N,UK,UV,? extends Map<UK,UV>> to InternalMapState<K,N,UK,UV> in method protected createMapState(namespaceSerializer TypeSerializer<N>, stateDesc MapStateDescriptor<UK,UV>) : InternalMapState<K,N,UK,UV> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type stateTable : StateTable<K,N,HashMap<UK,UV>> to stateTable : StateTable<K,N,Map<UK,UV>> in method protected createMapState(namespaceSerializer TypeSerializer<N>, stateDesc MapStateDescriptor<UK,UV>) : InternalMapState<K,N,UK,UV> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public get(userKey UK) : UV in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public values() : Iterable<UV> in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public keys() : Iterable<UK> in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type mapState : InternalMapState<Long,VoidNamespace,Long,String,Map<Long,String>> to mapState : InternalMapState<Long,VoidNamespace,Long,String> in method public testMapSerialization() : void in class org.apache.flink.queryablestate.network.KVStateRequestSerializerRocksDBTest |
From |
To |
|
Change Variable Type mapState : InternalMapState<Long,VoidNamespace,Long,String,HashMap<Long,String>> to mapState : InternalMapState<Long,VoidNamespace,Long,String> in method public testMapSerialization() : void in class org.apache.flink.queryablestate.network.KvStateRequestSerializerTest |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public putAll(value Map<UK,UV>) : void in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public put(userKey UK, userValue UV) : void in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public entries() : Iterable<Map.Entry<UK,UV>> in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public iterator() : Iterator<Map.Entry<UK,UV>> in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public contains(userKey UK) : boolean in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type serializer : HashMapSerializer<UK,UV> to serializer : MapSerializer<UK,UV> in method public getSerializedValue(serializedKeyAndNamespace byte[], safeKeySerializer TypeSerializer<K>, safeNamespaceSerializer TypeSerializer<N>, safeValueSerializer TypeSerializer<Map<UK,UV>>) : byte[] in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |
|
Change Variable Type userMap : HashMap<UK,UV> to userMap : Map<UK,UV> in method public remove(userKey UK) : void in class org.apache.flink.runtime.state.heap.HeapMapState |
From |
To |