|
Change Variable Type result : Object to result : T in method private mergeReducingState(stateDescriptor ReducingStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type state : ListState<Object> to state : ListState<T> in method private mergeListState(listStateDescriptor ListStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type kvState : KvState to kvState : KvState<N> in method private mergeListState(listStateDescriptor ListStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type o : Object to o : T in method private mergeListState(listStateDescriptor ListStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type kvState : KvState to kvState : KvState<N> in method private mergeReducingState(stateDescriptor ReducingStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type state : ReducingState to state : ReducingState<T> in method private mergeReducingState(stateDescriptor ReducingStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type reducingStateDescriptor : ReducingStateDescriptor to reducingStateDescriptor : ReducingStateDescriptor<T> in method private mergeReducingState(stateDescriptor ReducingStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type result : List<Object> to result : List<T> in method private mergeListState(listStateDescriptor ListStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type sourceValue : Iterable<Object> to sourceValue : Iterable<T> in method private mergeListState(listStateDescriptor ListStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type sourceValue : Object to sourceValue : T in method private mergeReducingState(stateDescriptor ReducingStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |
|
Change Variable Type reduceFn : ReduceFunction to reduceFn : ReduceFunction<T> in method private mergeReducingState(stateDescriptor ReducingStateDescriptor<?>, namespaceSerializer TypeSerializer<N>, target N, sources Collection<N>) : void in class org.apache.flink.runtime.state.AbstractKeyedStateBackend |
From |
To |