|
Change Parameter Type newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to stateName : String in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type stateTable : StateTable<K,N,List<V>> to stateTable : StateTable<K,N,ArrayList<V>> in method public HeapListState(backend KeyedStateBackend<K>, stateDesc ListStateDescriptor<V>, stateTable StateTable<K,N,ArrayList<V>>, keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>) in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Parameter Type newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to stateType : StateDescriptor.Type in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type b : List<V> to b : ArrayList<V> in method protected mergeState(a ArrayList<V>, b ArrayList<V>) : ArrayList<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Parameter Type newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to valueSerializer : TypeSerializer<V> in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type a : List<V> to a : ArrayList<V> in method protected mergeState(a ArrayList<V>, b ArrayList<V>) : ArrayList<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Parameter Type newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to namespaceSerializer : TypeSerializer<N> in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type stateTable : StateTable<String,VoidNamespace,List<Long>> to stateTable : StateTable<String,VoidNamespace,ArrayList<Long>> in method public testAddAndGet() : void in class org.apache.flink.runtime.state.heap.HeapListStateTest |
From |
To |
|
Change Variable Type namespaceMap : Map<N,Map<K,List<V>>> to namespaceMap : Map<N,Map<K,ArrayList<V>>> in method public getSerializedValue(key K, namespace N) : byte[] in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type keyedMap : Map<K,List<V>> to keyedMap : Map<K,ArrayList<V>> in method public getSerializedValue(key K, namespace N) : byte[] in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type list : List<V> to list : ArrayList<V> in method public add(value V) : void in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type namespaceMap : Map<N,Map<K,List<V>>> to namespaceMap : Map<N,Map<K,ArrayList<V>>> in method public add(value V) : void in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type result : List<V> to result : ArrayList<V> in method public getSerializedValue(key K, namespace N) : byte[] in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type namespaceMap : Map<N,Map<K,List<V>>> to namespaceMap : Map<N,Map<K,ArrayList<V>>> in method public get() : Iterable<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type stateTable : StateTable<K,N,List<T>> to stateTable : StateTable<K,N,ArrayList<T>> in method public createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : InternalListState<N,T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type keyedMap : Map<K,List<V>> to keyedMap : Map<K,ArrayList<V>> in method public add(value V) : void in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type stateTable : StateTable<String,Integer,List<Long>> to stateTable : StateTable<String,Integer,ArrayList<Long>> in method public testMerging() : void in class org.apache.flink.runtime.state.heap.HeapListStateTest |
From |
To |
|
Change Variable Type keyedMap : Map<K,List<V>> to keyedMap : Map<K,ArrayList<V>> in method public get() : Iterable<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Rename Parameter newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to stateName : String in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Parameter newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to valueSerializer : TypeSerializer<V> in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Parameter newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to stateType : StateDescriptor.Type in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Parameter newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to namespaceSerializer : TypeSerializer<N> in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |