|
Change Parameter Type windowStateDescriptor : StateDescriptor<? extends ListState<StreamRecord<IN>>> to windowStateDescriptor : StateDescriptor<? extends ListState<StreamRecord<IN>>,?> in method public EvictingWindowOperator(windowAssigner WindowAssigner<? super IN,W>, windowSerializer TypeSerializer<W>, keySelector KeySelector<IN,K>, keySerializer TypeSerializer<K>, windowStateDescriptor StateDescriptor<? extends ListState<StreamRecord<IN>>,?>, windowFunction WindowFunction<Iterable<IN>,OUT,K,W>, trigger Trigger<? super IN,? super W>, evictor Evictor<? super IN,? super W>) in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<S> to stateDescriptor : StateDescriptor<S,?> in method public getPartitionedState(namespace N, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<S> to stateDescriptor : StateDescriptor<S,?> in method protected getPartitionedState(stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<S> to stateDescriptor : StateDescriptor<S,?> in method public getPartitionedState(stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext |
From |
To |
|
Change Parameter Type windowStateDescriptor : StateDescriptor<? extends MergingState<IN,ACC>> to windowStateDescriptor : StateDescriptor<? extends MergingState<IN,ACC>,?> in method public WindowOperator(windowAssigner WindowAssigner<? super IN,W>, windowSerializer TypeSerializer<W>, keySelector KeySelector<IN,K>, keySerializer TypeSerializer<K>, windowStateDescriptor StateDescriptor<? extends MergingState<IN,ACC>,?>, windowFunction WindowFunction<ACC,OUT,K,W>, trigger Trigger<? super IN,? super W>) in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<S> to stateDescriptor : StateDescriptor<S,?> in method protected getPartitionedState(namespace N, namespaceSerializer TypeSerializer<N>, stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<S> to stateDescriptor : StateDescriptor<S,?> in method public getPartitionedState(stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.Context |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<S> to stateDescriptor : StateDescriptor<S,?> in method public getPartitionedState(stateDescriptor StateDescriptor<S,?>) : S in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context |
From |
To |
|
Move Method public equals(o Object) : boolean from class org.apache.flink.api.common.state.ReducingStateDescriptor to public equals(o Object) : boolean from class org.apache.flink.api.common.state.StateDescriptor |
From |
To |
|
Move Method private writeObject(out ObjectOutputStream) : void from class org.apache.flink.api.common.state.ValueStateDescriptor to private writeObject(out ObjectOutputStream) : void from class org.apache.flink.api.common.state.StateDescriptor |
From |
To |
|
Move Method public toString() : String from class org.apache.flink.api.common.state.ValueStateDescriptor to public toString() : String from class org.apache.flink.api.common.state.StateDescriptor |
From |
To |
|
Move Method public equals(o Object) : boolean from class org.apache.flink.api.common.state.ListStateDescriptor to public equals(o Object) : boolean from class org.apache.flink.api.common.state.StateDescriptor |
From |
To |
|
Move Method public equals(o Object) : boolean from class org.apache.flink.api.common.state.ValueStateDescriptor to public equals(o Object) : boolean from class org.apache.flink.api.common.state.StateDescriptor |
From |
To |
|
Move Method private readObject(in ObjectInputStream) : void from class org.apache.flink.api.common.state.ValueStateDescriptor to private readObject(in ObjectInputStream) : void from class org.apache.flink.api.common.state.StateDescriptor |
From |
To |
|
Move Method public getDefaultValue() : T from class org.apache.flink.api.common.state.ValueStateDescriptor to public getDefaultValue() : T from class org.apache.flink.api.common.state.StateDescriptor |
From |
To |