|
Change Parameter Type stateDesc : AggregatingStateDescriptor<Tuple2<Integer,Long>,MutableString,String> to stateDesc : AggregatingStateDescriptor<Tuple2<Integer,Long>,String,String> in method package AggregatingTestOperator(stateDesc AggregatingStateDescriptor<Tuple2<Integer,Long>,String,String>) in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateTestBase.AggregatingTestOperator |
From |
To |
|
Change Parameter Type accumulator : MutableString to accumulator : String in method public add(value Long, accumulator String) : String in class org.apache.flink.queryablestate.state.ImmutableAggregatingStateTest.SumAggr |
From |
To |
|
Change Parameter Type accumulator : MutableString to accumulator : String in method public add(value Tuple2<Integer,Long>, accumulator String) : String in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateTestBase.SumAggr |
From |
To |
|
Change Return Type void to String in method public add(value Long, accumulator String) : String in class org.apache.flink.queryablestate.state.ImmutableAggregatingStateTest.SumAggr |
From |
To |
|
Change Return Type void to String in method public add(value Tuple2<Integer,Long>, accumulator String) : String in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateTestBase.SumAggr |
From |
To |
|
Change Return Type void to Tuple2<String,Integer> in method public add(value Tuple3<String,String,Integer>, accumulator Tuple2<String,Integer>) : Tuple2<String,Integer> in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest.DummyAggregationFunction |
From |
To |
|
Change Return Type void to ACC in method public add(value IN, accumulator ACC) : ACC in class org.apache.flink.api.common.functions.AggregateFunction |
From |
To |
|
Change Return Type MutableString to String in method public createAccumulator() : String in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateTestBase.SumAggr |
From |
To |
|
Change Return Type void to ACC in method public abstract add(value IN, accumulator ACC) : ACC in class org.apache.flink.api.common.functions.RichAggregateFunction |
From |
To |
|
Change Return Type void to Tuple2<String,Integer> in method public add(value Tuple2<String,Integer>, accumulator Tuple2<String,Integer>) : Tuple2<String,Integer> in class org.apache.flink.streaming.runtime.operators.windowing.AllWindowTranslationTest.DummyAggregationFunction |
From |
To |
|
Change Return Type MutableString to String in method public createAccumulator() : String in class org.apache.flink.queryablestate.state.ImmutableAggregatingStateTest.SumAggr |
From |
To |
|
Change Return Type void to MutableLong in method public add(value Long, accumulator MutableLong) : MutableLong in class org.apache.flink.runtime.state.StateBackendTestBase.MutableAggregatingAddingFunction |
From |
To |