|
Change Parameter Type a : ArrayList<V> to a : List<V> in method protected mergeState(a List<V>, b List<V>) : List<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Parameter Type stateTable : StateTable<K,N,ArrayList<V>> to stateTable : StateTable<K,N,List<V>> in method public HeapListState(backend KeyedStateBackend<K>, stateDesc ListStateDescriptor<V>, stateTable StateTable<K,N,List<V>>, keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>) in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Parameter Type b : ArrayList<V> to b : List<V> in method protected mergeState(a List<V>, b List<V>) : List<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type stateTable : StateTable<String,VoidNamespace,ArrayList<Long>> to stateTable : StateTable<String,VoidNamespace,List<Long>> in method public testAddAndGet() : void in class org.apache.flink.runtime.state.heap.HeapListStateTest |
From |
To |
|
Change Variable Type list : ArrayList<V> to list : List<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,ArrayList<V>>> to namespaceMap : Map<N,Map<K,List<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,ArrayList<V>> to keyedMap : Map<K,List<V>> in method public getSerializedValue(key K, namespace N) : byte[] in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type stateTable : StateTable<String,Integer,ArrayList<Long>> to stateTable : StateTable<String,Integer,List<Long>> in method public testMerging() : void in class org.apache.flink.runtime.state.heap.HeapListStateTest |
From |
To |
|
Change Variable Type namespaceMap : Map<N,Map<K,ArrayList<V>>> to namespaceMap : Map<N,Map<K,List<V>>> in method public add(value V) : void in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type keyedMap : Map<K,ArrayList<V>> to keyedMap : Map<K,List<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,ArrayList<V>>> to namespaceMap : Map<N,Map<K,List<V>>> in method public get() : Iterable<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type descrIntercepted : StateDescriptor<?,?> to descrIntercepted : ListStateDescriptor<?> in method public testListStateInstantiation() : void in class org.apache.flink.streaming.api.operators.StreamingRuntimeContextTest |
From |
To |
|
Change Variable Type keyedMap : Map<K,ArrayList<V>> to keyedMap : Map<K,List<V>> in method public get() : Iterable<V> in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |
|
Change Variable Type result : ArrayList<V> to result : List<V> in method public getSerializedValue(key K, namespace N) : byte[] in class org.apache.flink.runtime.state.heap.HeapListState |
From |
To |