|
Change Parameter Type acc : GenericRow to acc : ConcatWithRetractAccumulator in method public resetAccumulator(acc ConcatWithRetractAccumulator) : void in class org.apache.flink.table.functions.aggfunctions.ConcatWithRetractAggFunction |
From |
To |
|
Change Parameter Type ctx : ExecutionContext to store : StateDataViewStore in method public open(store StateDataViewStore) : void in class org.apache.flink.table.runtime.window.WindowOperatorTest.SumAndCountAgg |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString, order Long) : void in class org.apache.flink.table.functions.aggfunctions.LastValueAggFunction.StringLastValueAggFunction |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString) : void in class org.apache.flink.table.functions.aggfunctions.FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction |
From |
To |
|
Change Parameter Type generatedWindowAggregator : GeneratedNamespaceAggsHandleFunction to generatedWindowAggregator : GeneratedNamespaceAggsHandleFunction<W> in method package WindowOperator(generatedWindowAggregator GeneratedNamespaceAggsHandleFunction<W>, generatedEqualiser GeneratedRecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes InternalType[], accumulatorTypes InternalType[], aggResultTypes InternalType[], windowPropertyTypes InternalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type generatedAggregateFunction : GeneratedNamespaceAggsHandleFunction to generatedAggregateFunction : GeneratedNamespaceAggsHandleFunction<?> in method public aggregate(generatedAggregateFunction GeneratedNamespaceAggsHandleFunction<?>, generatedEqualiser GeneratedRecordEqualiser, accumulatorTypes InternalType[], aggResultTypes InternalType[], windowPropertyTypes InternalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type acc : GenericRow to acc : ConcatWithRetractAccumulator in method public accumulate(acc ConcatWithRetractAccumulator, value BinaryString) : void in class org.apache.flink.table.functions.aggfunctions.ConcatWithRetractAggFunction |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString, order Long) : void in class org.apache.flink.table.functions.aggfunctions.FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction |
From |
To |
|
Change Parameter Type acc : GenericRow to acc : ConcatWsWithRetractAccumulator in method public getValue(acc ConcatWsWithRetractAccumulator) : BinaryString in class org.apache.flink.table.functions.aggfunctions.ConcatWsWithRetractAggFunction |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString) : void in class org.apache.flink.table.functions.aggfunctions.LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction |
From |
To |
|
Change Parameter Type acc : GenericRow to acc : ConcatWithRetractAccumulator in method public retract(acc ConcatWithRetractAccumulator, value BinaryString) : void in class org.apache.flink.table.functions.aggfunctions.ConcatWithRetractAggFunction |
From |
To |
|
Change Parameter Type acc : GenericRow to acc : ConcatWithRetractAccumulator in method public getValue(acc ConcatWithRetractAccumulator) : BinaryString in class org.apache.flink.table.functions.aggfunctions.ConcatWithRetractAggFunction |
From |
To |
|
Change Parameter Type accumulator : GenericRow to accumulator : ConcatWsWithRetractAccumulator in method protected retractValues(accumulator ConcatWsWithRetractAccumulator, values List<BinaryString>) : void in class org.apache.flink.table.functions.aggfunctions.ConcatWsWithRetractAggFunctionTest |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString, order Long) : void in class org.apache.flink.table.functions.aggfunctions.LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString) : void in class org.apache.flink.table.functions.aggfunctions.FirstValueAggFunction.StringFirstValueAggFunction |
From |
To |
|
Change Parameter Type ctx : ExecutionContext to store : StateDataViewStore in method public open(store StateDataViewStore) : void in class org.apache.flink.table.generated.NamespaceAggsHandleFunction |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString, order Long) : void in class org.apache.flink.table.functions.aggfunctions.FirstValueAggFunction.StringFirstValueAggFunction |
From |
To |
|
Change Parameter Type ctx : ExecutionContext to store : StateDataViewStore in method public open(store StateDataViewStore) : void in class org.apache.flink.table.generated.AggsHandleFunction |
From |
To |
|
Change Parameter Type value : Object to value : BinaryString in method public accumulate(acc GenericRow, value BinaryString) : void in class org.apache.flink.table.functions.aggfunctions.LastValueAggFunction.StringLastValueAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Integer> in method protected getValueTypeInfo() : TypeInformation<Integer> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.IntMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Long> in method protected getValueTypeInfo() : TypeInformation<Long> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.LongMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Boolean> in method protected getValueTypeInfo() : TypeInformation<Boolean> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.BooleanMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Decimal> in method protected getValueTypeInfo() : TypeInformation<Decimal> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction |
From |
To |
|
Change Return Type GenericRow to ConcatWsWithRetractAccumulator in method protected accumulateValues(values List<BinaryString>) : ConcatWsWithRetractAccumulator in class org.apache.flink.table.functions.aggfunctions.ConcatWsWithRetractAggFunctionTest |
From |
To |
|
Change Return Type AggregateFunction<BinaryString,GenericRow> to AggregateFunction<BinaryString,ConcatWithRetractAccumulator> in method protected getAggregator() : AggregateFunction<BinaryString,ConcatWithRetractAccumulator> in class org.apache.flink.table.functions.aggfunctions.ConcatWithRetractAggFunctionTest |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Timestamp> in method protected getValueTypeInfo() : TypeInformation<Timestamp> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.TimestampMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Byte> in method protected getValueTypeInfo() : TypeInformation<Byte> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.ByteMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<BinaryString> in method protected getValueTypeInfo() : TypeInformation<BinaryString> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.StringMaxWithRetractAggFunction |
From |
To |
|
Change Return Type GenericRow to ConcatWithRetractAccumulator in method public createAccumulator() : ConcatWithRetractAccumulator in class org.apache.flink.table.functions.aggfunctions.ConcatWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Boolean> in method protected getValueTypeInfo() : TypeInformation<Boolean> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.BooleanMinWithRetractAggFunction |
From |
To |
|
Change Return Type GenericRow to ConcatWsWithRetractAccumulator in method public createAccumulator() : ConcatWsWithRetractAccumulator in class org.apache.flink.table.functions.aggfunctions.ConcatWsWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Date> in method protected getValueTypeInfo() : TypeInformation<Date> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.DateMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Double> in method protected getValueTypeInfo() : TypeInformation<Double> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.DoubleMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Decimal> in method protected getValueTypeInfo() : TypeInformation<Decimal> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.DecimalMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Byte> in method protected getValueTypeInfo() : TypeInformation<Byte> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.ByteMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Float> in method protected getValueTypeInfo() : TypeInformation<Float> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.FloatMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Short> in method protected getValueTypeInfo() : TypeInformation<Short> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.ShortMaxWithRetractAggFunction |
From |
To |
|
Change Return Type AggregateFunction<BinaryString,GenericRow> to AggregateFunction<BinaryString,ConcatWsWithRetractAccumulator> in method protected getAggregator() : AggregateFunction<BinaryString,ConcatWsWithRetractAccumulator> in class org.apache.flink.table.functions.aggfunctions.ConcatWsWithRetractAggFunctionTest |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Date> in method protected getValueTypeInfo() : TypeInformation<Date> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.DateMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Float> in method protected getValueTypeInfo() : TypeInformation<Float> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.FloatMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Short> in method protected getValueTypeInfo() : TypeInformation<Short> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.ShortMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Time> in method protected getValueTypeInfo() : TypeInformation<Time> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.TimeMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Timestamp> in method protected getValueTypeInfo() : TypeInformation<Timestamp> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.TimestampMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<T> in method protected abstract getValueTypeInfo() : TypeInformation<T> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<BinaryString> in method protected getValueTypeInfo() : TypeInformation<BinaryString> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.StringMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Integer> in method protected getValueTypeInfo() : TypeInformation<Integer> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.IntMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Time> in method protected getValueTypeInfo() : TypeInformation<Time> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.TimeMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Long> in method protected getValueTypeInfo() : TypeInformation<Long> in class org.apache.flink.table.functions.aggfunctions.MaxWithRetractAggFunction.LongMaxWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<Double> in method protected getValueTypeInfo() : TypeInformation<Double> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction.DoubleMinWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation<?> to TypeInformation<T> in method protected abstract getValueTypeInfo() : TypeInformation<T> in class org.apache.flink.table.functions.aggfunctions.MinWithRetractAggFunction |
From |
To |