|
Change Parameter Type type : InternalType to type : LogicalType in method private generateValues(type LogicalType) : Object[] in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Parameter Type internalTypes : InternalType[] to logicalTypes : LogicalType[] in method public BaseRowTypeInfo(logicalTypes LogicalType[], fieldNames String[]) in class org.apache.flink.table.typeutils.BaseRowTypeInfo |
From |
To |
|
Change Parameter Type rightType : TypeInformation<BaseRow> to rightType : BaseRowTypeInfo in method public ProcTimeBoundedStreamJoin(joinType FlinkJoinType, leftLowerBound long, leftUpperBound long, leftType BaseRowTypeInfo, rightType BaseRowTypeInfo, genJoinFunc GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>>) in class org.apache.flink.table.runtime.join.ProcTimeBoundedStreamJoin |
From |
To |
|
Change Parameter Type type : DecimalTypeInfo to type : DecimalType in method public DecimalSingleValueAggFunction(type DecimalType) in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.DecimalSingleValueAggFunction |
From |
To |
|
Change Parameter Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in method package WindowOperator(windowAggregator NamespaceAggsHandleFunction<W>, equaliser RecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type resultType : InternalType to resultType : LogicalType in method public ResolvedAggLocalReference(fieldTerm String, nullTerm String, resultType LogicalType) in class org.apache.flink.table.expressions.ResolvedAggLocalReference |
From |
To |
|
Change Parameter Type decimalType : DecimalTypeInfo to decimalType : DecimalType in method public DecimalSum0AggFunction(decimalType DecimalType) in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.DecimalSum0AggFunction |
From |
To |
|
Change Parameter Type type : InternalType to type : LogicalType in method private value2(type LogicalType, rnd Random) : Object in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public AbstractRowTimeUnboundedPrecedingOver(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], rowTimeIdx int) in class org.apache.flink.table.runtime.over.AbstractRowTimeUnboundedPrecedingOver |
From |
To |
|
Change Parameter Type type : GenericType<T> to serializer : TypeSerializer<T> in method package BinaryGenericSerializerSnapshot(serializer TypeSerializer<T>) in class org.apache.flink.table.typeutils.BinaryGenericSerializer.BinaryGenericSerializerSnapshot |
From |
To |
|
Change Parameter Type decimalType : DecimalTypeInfo to decimalType : DecimalType in method public DecimalSumAggFunction(decimalType DecimalType) in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.DecimalSumAggFunction |
From |
To |
|
Change Parameter Type leftType : TypeInformation<BaseRow> to leftType : BaseRowTypeInfo in method public RowTimeBoundedStreamJoin(joinType FlinkJoinType, leftLowerBound long, leftUpperBound long, allowedLateness long, leftType BaseRowTypeInfo, rightType BaseRowTypeInfo, genJoinFunc GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>>, leftTimeIdx int, rightTimeIdx int) in class org.apache.flink.table.runtime.join.RowTimeBoundedStreamJoin |
From |
To |
|
Change Parameter Type valueTypes : InternalType[] to valueTypes : LogicalType[] in method public BytesHashMap(owner Object, memoryManager MemoryManager, memorySize long, keyTypes LogicalType[], valueTypes LogicalType[], inferBucketMemory boolean) in class org.apache.flink.table.runtime.aggregate.BytesHashMap |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public MiniBatchGlobalGroupAggFunction(genLocalAggsHandler GeneratedAggsHandleFunction, genGlobalAggsHandler GeneratedAggsHandleFunction, genRecordEqualiser GeneratedRecordEqualiser, accTypes LogicalType[], indexOfCountStar int, generateRetraction boolean) in class org.apache.flink.table.runtime.aggregate.MiniBatchGlobalGroupAggFunction |
From |
To |
|
Change Parameter Type keyTypes : InternalType[] to keyTypes : LogicalType[] in method public BytesHashMap(owner Object, memoryManager MemoryManager, memorySize long, keyTypes LogicalType[], valueTypes LogicalType[], inferBucketMemory boolean) in class org.apache.flink.table.runtime.aggregate.BytesHashMap |
From |
To |
|
Change Parameter Type type : InternalType to type : LogicalType in method private convertExtract(range TimeUnitRange, ts long, type LogicalType, tz TimeZone) : long in class org.apache.flink.table.runtime.functions.SqlDateTimeUtils |
From |
To |
|
Change Parameter Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in method public aggregate(generatedAggregateFunction GeneratedNamespaceAggsHandleFunction<?>, generatedEqualiser GeneratedRecordEqualiser, accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in method package WindowOperator(generatedWindowAggregator GeneratedNamespaceAggsHandleFunction<W>, generatedEqualiser GeneratedRecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public RowTimeRangeBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingOffset long, rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public ProcTimeRangeBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingTimeBoundary long) in class org.apache.flink.table.runtime.over.ProcTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public GroupAggFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, genRecordEqualiser GeneratedRecordEqualiser, accTypes LogicalType[], indexOfCountStar int, generateRetraction boolean) in class org.apache.flink.table.runtime.aggregate.GroupAggFunction |
From |
To |
|
Change Parameter Type decimalType : DecimalTypeInfo to decimalType : DecimalType in method public DecimalMaxAggFunction(decimalType DecimalType) in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.DecimalMaxAggFunction |
From |
To |
|
Change Parameter Type decimalType : DecimalTypeInfo to decimalType : DecimalType in method public DecimalIncrSumWithRetractAggFunction(decimalType DecimalType) in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.DecimalIncrSumWithRetractAggFunction |
From |
To |
|
Change Parameter Type keyTypes : InternalType[] to keyTypes : LogicalType[] in method public BytesHashMap(owner Object, memoryManager MemoryManager, memorySize long, keyTypes LogicalType[], valueTypes LogicalType[]) in class org.apache.flink.table.runtime.aggregate.BytesHashMap |
From |
To |
|
Change Parameter Type valueTypes : InternalType[] to valueTypes : LogicalType[] in method public BytesHashMap(owner Object, memoryManager MemoryManager, memorySize long, keyTypes LogicalType[], valueTypes LogicalType[]) in class org.apache.flink.table.runtime.aggregate.BytesHashMap |
From |
To |
|
Change Parameter Type accumulatorTypes : InternalType[] to accumulatorTypes : LogicalType[] in method package WindowOperator(generatedWindowAggregator GeneratedNamespaceAggsHandleFunction<W>, generatedEqualiser GeneratedRecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type type : GenericType<T> to serializer : TypeSerializer<T> in method public BinaryGenericSerializer(serializer TypeSerializer<T>) in class org.apache.flink.table.typeutils.BinaryGenericSerializer |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public RowTimeRowsUnboundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRowsUnboundedPrecedingFunction |
From |
To |
|
Change Parameter Type accumulatorTypes : InternalType[] to accumulatorTypes : LogicalType[] in method public aggregate(aggregateFunction NamespaceAggsHandleFunction<?>, equaliser RecordEqualiser, accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type type : TypeInformation to type : DataType in method public nullOf(type DataType) : Expression in class org.apache.flink.table.expressions.ExpressionBuilder |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public ProcTimeRangeBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingTimeBoundary long) in class org.apache.flink.table.runtime.over.ProcTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in method public aggregate(aggregateFunction NamespaceAggsHandleFunction<?>, equaliser RecordEqualiser, accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type orderKeyTypes : InternalType[] to orderKeyTypes : LogicalType[] in method public RankAggFunction(orderKeyTypes LogicalType[]) in class org.apache.flink.table.functions.aggfunctions.RankAggFunction |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public BinaryRowKeySelector(keyFields int[], inputFieldTypes LogicalType[]) in class org.apache.flink.table.runtime.util.BinaryRowKeySelector |
From |
To |
|
Change Parameter Type types : InternalType[] to types : LogicalType[] in method public toOriginString(row BaseRow, types LogicalType[]) : String in class org.apache.flink.table.dataformat.BinaryRow |
From |
To |
|
Change Parameter Type decimalType : DecimalTypeInfo to decimalType : DecimalType in method public DecimalSumWithRetractAggFunction(decimalType DecimalType) in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.DecimalSumWithRetractAggFunction |
From |
To |
|
Change Parameter Type types : InternalType[] to types : List<LogicalType> in method public toGenericRowDeeply(baseRow BaseRow, types List<LogicalType>) : GenericRow in class org.apache.flink.table.util.BaseRowTestUtil |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public ProcTimeUnboundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[]) in class org.apache.flink.table.runtime.over.ProcTimeUnboundedPrecedingFunction |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method package WindowOperator(windowAggregator NamespaceAggsHandleFunction<W>, equaliser RecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type windowPropertyTypes : InternalType[] to windowPropertyTypes : LogicalType[] in method public aggregate(generatedAggregateFunction GeneratedNamespaceAggsHandleFunction<?>, generatedEqualiser GeneratedRecordEqualiser, accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public ProcTimeRowsBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingOffset long) in class org.apache.flink.table.runtime.over.ProcTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type decimalType : DecimalTypeInfo to decimalType : DecimalType in method public DecimalMinAggFunction(decimalType DecimalType) in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.DecimalMinAggFunction |
From |
To |
|
Change Parameter Type type : InternalType to type : LogicalType in method private value3(type LogicalType, rnd Random) : Object in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Parameter Type internalTypes : InternalType... to logicalTypes : LogicalType... in method public BaseRowTypeInfo(logicalTypes LogicalType...) in class org.apache.flink.table.typeutils.BaseRowTypeInfo |
From |
To |
|
Change Parameter Type valueTypeInfo : TypeInformation to valueTypeInfo : DataType in method public MapConverter(keyTypeInfo DataType, valueTypeInfo DataType) in class org.apache.flink.table.dataformat.DataFormatConverters.MapConverter |
From |
To |
|
Change Parameter Type elementType : InternalType to elementType : LogicalType in method private binaryArrayToJavaArray(value BinaryArray, elementType LogicalType, componentClass Class<T>, elementConverter DataFormatConverter<Object,T>) : T[] in class org.apache.flink.table.dataformat.DataFormatConverters |
From |
To |
|
Change Parameter Type orderKeyTypes : InternalType[] to orderKeyTypes : LogicalType[] in method public DenseRankAggFunction(orderKeyTypes LogicalType[]) in class org.apache.flink.table.functions.aggfunctions.DenseRankAggFunction |
From |
To |
|
Change Parameter Type types : InternalType[] to types : LogicalType[] in method package BaseRowSerializerSnapshot(types LogicalType[], serializers TypeSerializer[]) in class org.apache.flink.table.typeutils.BaseRowSerializer.BaseRowSerializerSnapshot |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public RowTimeRangeUnboundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRangeUnboundedPrecedingFunction |
From |
To |
|
Change Parameter Type sortKeyType : InternalType to sortKeyType : LogicalType in method public GenericRowRecordSortComparator(sortKeyIdx int, sortKeyType LogicalType) in class org.apache.flink.table.runtime.util.GenericRowRecordSortComparator |
From |
To |
|
Change Parameter Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in method package GenericRowEqualiser(aggResultTypes LogicalType[], windowTypes LogicalType[]) in class org.apache.flink.table.runtime.window.WindowOperatorTest.GenericRowEqualiser |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public RowTimeRangeUnboundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRangeUnboundedPrecedingFunction |
From |
To |
|
Change Parameter Type type : InternalType to type : LogicalType in method public write(writer BinaryWriter, pos int, o Object, type LogicalType) : void in class org.apache.flink.table.util.BaseRowTestUtil |
From |
To |
|
Change Parameter Type types : InternalType[] to types : LogicalType[] in method package getVariableLength(types LogicalType[]) : int in class org.apache.flink.table.runtime.aggregate.BytesHashMap |
From |
To |
|
Change Parameter Type orderType : InternalType to orderType : LogicalType in method protected generateInitLiteral(orderType LogicalType) : Expression in class org.apache.flink.table.functions.aggfunctions.RankLikeAggFunctionBase |
From |
To |
|
Change Parameter Type serializer : BaseRowSerializer to type : RowType in method public writeRow(pos int, input BaseRow, type RowType) : void in class org.apache.flink.table.dataformat.AbstractBinaryWriter |
From |
To |
|
Change Parameter Type decimalType : DecimalTypeInfo to decimalType : DecimalType in method public DecimalIncrSumAggFunction(decimalType DecimalType) in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.DecimalIncrSumAggFunction |
From |
To |
|
Change Parameter Type accumulatorTypes : InternalType[] to accumulatorTypes : LogicalType[] in method package WindowOperator(windowAggregator NamespaceAggsHandleFunction<W>, equaliser RecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type leftType : TypeInformation<BaseRow> to leftType : BaseRowTypeInfo in method public ProcTimeBoundedStreamJoin(joinType FlinkJoinType, leftLowerBound long, leftUpperBound long, leftType BaseRowTypeInfo, rightType BaseRowTypeInfo, genJoinFunc GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>>) in class org.apache.flink.table.runtime.join.ProcTimeBoundedStreamJoin |
From |
To |
|
Change Parameter Type keyTypeInfo : TypeInformation to keyTypeInfo : DataType in method public MapConverter(keyTypeInfo DataType, valueTypeInfo DataType) in class org.apache.flink.table.dataformat.DataFormatConverters.MapConverter |
From |
To |
|
Change Parameter Type t : RowTypeInfo to fieldTypes : DataType[] in method public RowConverter(fieldTypes DataType[]) in class org.apache.flink.table.dataformat.DataFormatConverters.RowConverter |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method package WindowOperator(generatedWindowAggregator GeneratedNamespaceAggsHandleFunction<W>, generatedEqualiser GeneratedRecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type keyTypes : InternalType[] to keyTypes : LogicalType[] in method public getSortBaseWithNulls(namePrefix String, keyTypes LogicalType[], keys int[], orders boolean[], nullsIsLast boolean[]) : Tuple2<NormalizedKeyComputer,RecordComparator> in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Parameter Type type : InternalType to type : LogicalType in method private value1(type LogicalType, rnd Random) : Object in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public MiniBatchGroupAggFunction(genAggsHandler GeneratedAggsHandleFunction, genRecordEqualiser GeneratedRecordEqualiser, accTypes LogicalType[], inputType RowType, indexOfCountStar int, generateRetraction boolean) in class org.apache.flink.table.runtime.aggregate.MiniBatchGroupAggFunction |
From |
To |
|
Change Parameter Type types : InternalType... to types : LogicalType... in method public BaseRowSerializer(config ExecutionConfig, types LogicalType...) in class org.apache.flink.table.typeutils.BaseRowSerializer |
From |
To |
|
Change Parameter Type windowPropertyTypes : InternalType[] to windowPropertyTypes : LogicalType[] in method package WindowOperator(generatedWindowAggregator GeneratedNamespaceAggsHandleFunction<W>, generatedEqualiser GeneratedRecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type accumulatorTypes : InternalType[] to accumulatorTypes : LogicalType[] in method public aggregate(generatedAggregateFunction GeneratedNamespaceAggsHandleFunction<?>, generatedEqualiser GeneratedRecordEqualiser, accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type windowTypes : InternalType[] to windowTypes : LogicalType[] in method package GenericRowEqualiser(aggResultTypes LogicalType[], windowTypes LogicalType[]) in class org.apache.flink.table.runtime.window.WindowOperatorTest.GenericRowEqualiser |
From |
To |
|
Change Parameter Type resultType : InternalType to resultType : LogicalType in method public ResolvedDistinctKeyReference(name String, resultType LogicalType) in class org.apache.flink.table.expressions.ResolvedDistinctKeyReference |
From |
To |
|
Change Parameter Type rightType : TypeInformation<BaseRow> to rightType : BaseRowTypeInfo in method public RowTimeBoundedStreamJoin(joinType FlinkJoinType, leftLowerBound long, leftUpperBound long, allowedLateness long, leftType BaseRowTypeInfo, rightType BaseRowTypeInfo, genJoinFunc GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>>, leftTimeIdx int, rightTimeIdx int) in class org.apache.flink.table.runtime.join.RowTimeBoundedStreamJoin |
From |
To |
|
Change Parameter Type type : InternalType to type : LogicalType in method public write(writer BinaryWriter, pos int, o Object, type LogicalType) : void in class org.apache.flink.table.dataformat.BinaryWriter |
From |
To |
|
Change Parameter Type windowPropertyTypes : InternalType[] to windowPropertyTypes : LogicalType[] in method package WindowOperator(windowAggregator NamespaceAggsHandleFunction<W>, equaliser RecordEqualiser, windowAssigner WindowAssigner<W>, trigger Trigger<W>, windowSerializer TypeSerializer<W>, inputFieldTypes LogicalType[], accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[], rowtimeIndex int, sendRetraction boolean, allowedLateness long) in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Parameter Type types : InternalType... to types : LogicalType... in method public toOriginString(types LogicalType...) : String in class org.apache.flink.table.dataformat.BinaryRow |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public AbstractRowTimeUnboundedPrecedingOver(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], rowTimeIdx int) in class org.apache.flink.table.runtime.over.AbstractRowTimeUnboundedPrecedingOver |
From |
To |
|
Change Parameter Type orderKeyTypes : InternalType[] to orderKeyTypes : LogicalType[] in method public RankLikeAggFunctionBase(orderKeyTypes LogicalType[]) in class org.apache.flink.table.functions.aggfunctions.RankLikeAggFunctionBase |
From |
To |
|
Change Parameter Type leftType : TypeInformation<BaseRow> to leftType : BaseRowTypeInfo in method package TimeBoundedStreamJoin(joinType FlinkJoinType, leftLowerBound long, leftUpperBound long, allowedLateness long, leftType BaseRowTypeInfo, rightType BaseRowTypeInfo, genJoinFunc GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>>) in class org.apache.flink.table.runtime.join.TimeBoundedStreamJoin |
From |
To |
|
Change Parameter Type types : InternalType[] to types : LogicalType[] in method public toGenericRow(baseRow BaseRow, types LogicalType[]) : GenericRow in class org.apache.flink.table.dataformat.util.BaseRowUtil |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public RowTimeRowsBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingOffset long, rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type accTypes : InternalType[] to accTypes : LogicalType[] in method public RowTimeRangeBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingOffset long, rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public RowTimeRowsBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingOffset long, rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public ProcTimeRowsBoundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], precedingOffset long) in class org.apache.flink.table.runtime.over.ProcTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Parameter Type type : TypeInformation<?> to type : DataType in method public throwException(msg String, type DataType) : Expression in class org.apache.flink.table.expressions.ExpressionBuilder |
From |
To |
|
Change Parameter Type windowPropertyTypes : InternalType[] to windowPropertyTypes : LogicalType[] in method public aggregate(aggregateFunction NamespaceAggsHandleFunction<?>, equaliser RecordEqualiser, accumulatorTypes LogicalType[], aggResultTypes LogicalType[], windowPropertyTypes LogicalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type rightType : TypeInformation<BaseRow> to rightType : BaseRowTypeInfo in method package TimeBoundedStreamJoin(joinType FlinkJoinType, leftLowerBound long, leftUpperBound long, allowedLateness long, leftType BaseRowTypeInfo, rightType BaseRowTypeInfo, genJoinFunc GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>>) in class org.apache.flink.table.runtime.join.TimeBoundedStreamJoin |
From |
To |
|
Change Parameter Type valueTypes : InternalType[] to valueTypes : LogicalType[] in method private calcNumBucketSegments(keyTypes LogicalType[], valueTypes LogicalType[]) : int in class org.apache.flink.table.runtime.aggregate.BytesHashMap |
From |
To |
|
Change Parameter Type keyTypes : InternalType[] to keyTypes : LogicalType[] in method private calcNumBucketSegments(keyTypes LogicalType[], valueTypes LogicalType[]) : int in class org.apache.flink.table.runtime.aggregate.BytesHashMap |
From |
To |
|
Change Parameter Type t : CompositeType to fieldTypes : DataType[] in method public AbstractBaseRowConverter(fieldTypes DataType[]) in class org.apache.flink.table.dataformat.DataFormatConverters.AbstractBaseRowConverter |
From |
To |
|
Change Parameter Type types : InternalType[] to types : LogicalType[] in method public BaseRowSerializer(types LogicalType[], fieldSerializers TypeSerializer[]) in class org.apache.flink.table.typeutils.BaseRowSerializer |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public withInputFields(inputFieldTypes LogicalType[]) : WindowOperatorBuilder in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Parameter Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in method public RowTimeRowsUnboundedPrecedingFunction(minRetentionTime long, maxRetentionTime long, genAggsHandler GeneratedAggsHandleFunction, accTypes LogicalType[], inputFieldTypes LogicalType[], rowTimeIdx int) in class org.apache.flink.table.runtime.over.RowTimeRowsUnboundedPrecedingFunction |
From |
To |
|
Change Parameter Type resultType : InternalType to resultType : LogicalType in method public ResolvedAggInputReference(name String, index int, resultType LogicalType) in class org.apache.flink.table.expressions.ResolvedAggInputReference |
From |
To |
|
Change Parameter Type serializer : BaseRowSerializer to type : RowType in method public writeRow(pos int, value BaseRow, type RowType) : void in class org.apache.flink.table.dataformat.BinaryWriter |
From |
To |
|
Change Parameter Type type : DecimalTypeInfo to type : DecimalType in method public DecimalAvgAggFunction(type DecimalType) in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.DecimalAvgAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.DecimalIncrSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.ShortIncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.IntMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.ShortMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.TimestampSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.DecimalIncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.LongSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.FloatIncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.DoubleSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.TimestampMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.DoubleIncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.StringLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.LongMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.ShortIncrSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.CountAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.IntMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.DecimalLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.DateMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.BooleanMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.LongSum0AggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.BooleanSingleValueAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getSumType() : DataType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.DoubleAvgAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.RankAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.DateLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.ShortSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public abstract getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.DeclarativeAggregateFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.FloatSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.IntIncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.Count1AggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.MinAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.CountAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.ShortSingleValueAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.FloatSum0AggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.ConcatAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.StringMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.TimeMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.StringMinAggFunction |
From |
To |
|
Change Return Type InternalType[] to LogicalType[] in method public getLogicalTypes() : LogicalType[] in class org.apache.flink.table.typeutils.BaseRowTypeInfo |
From |
To |
|
Change Return Type TypeInformation<BaseRow> to BaseRowTypeInfo in method public getProducedType() : BaseRowTypeInfo in class org.apache.flink.table.runtime.values.ValuesInputFormat |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.LongIncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.DecimalMinAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.LongMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.DecimalSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.DoubleSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.TimeLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.IntLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.ByteMinAggFunction |
From |
To |
|
Change Return Type InternalType to LogicalType in method public getResultType() : LogicalType in class org.apache.flink.table.expressions.ResolvedAggInputReference |
From |
To |
|
Change Return Type InternalType to LogicalType in method public getResultType() : LogicalType in class org.apache.flink.table.expressions.ResolvedDistinctKeyReference |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.TimestampLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.LongSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.DoubleSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.FloatLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.IntegralAvgAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.DecimalSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.ByteSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.RankLikeAggFunctionBase |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Count1AggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.LongIncrSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.ShortSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.TimestampMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.IntSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.BooleanLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.ByteSingleValueAggFunction |
From |
To |
|
Change Return Type InternalType[] to LogicalType[] in method private getFieldTypes() : LogicalType[] in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.ConcatAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.FloatMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.DoubleLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.DoubleMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.ByteIncrSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.TimeMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.DoubleMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.BooleanMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.ByteIncrSumAggFunction |
From |
To |
|
Change Return Type InternalType to LogicalType in method public getResultType() : LogicalType in class org.apache.flink.table.expressions.ResolvedAggLocalReference |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.TimeSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.IntIncrSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.DecimalSumWithRetractAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.IntSumWithRetractAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.DenseRankAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.DoubleSum0AggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.DecimalSum0AggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.RowNumberAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.FloatIncrSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.StringSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.FloatMaxAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.SumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.ByteMaxAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public abstract getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.DeclarativeAggregateFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.DecimalAvgAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.FloatSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.LongSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.DoubleAvgAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.RowNumberAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.DateSingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getSumType() : DataType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.DecimalAvgAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.ByteSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.ByteSum0AggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.LongLeadLagAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.IntSumAggFunction |
From |
To |
|
Change Return Type InternalType[] to LogicalType[] in method private getKeyTypes() : LogicalType[] in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.ShortSum0AggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.DateMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getSumType() : DataType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.IntegralAvgAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.IntSum0AggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.DecimalMaxAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.ByteLeadLagAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.FloatSumAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.DoubleIncrSumAggFunction |
From |
To |
|
Change Return Type InternalType[] to DataType[] in method public getAggBufferTypes() : DataType[] in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.ShortMinAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public abstract getSumType() : DataType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction |
From |
To |
|
Change Return Type TypeInformation to DataType in method public getResultType() : DataType in class org.apache.flink.table.functions.aggfunctions.LeadLagAggFunction.ShortLeadLagAggFunction |
From |
To |
|
Change Attribute Type previousTypes : InternalType[] to previousTypes : LogicalType[] in class org.apache.flink.table.typeutils.BaseRowSerializer.BaseRowSerializerSnapshot |
From |
To |
|
Change Attribute Type windowPropertyTypes : InternalType[] to windowPropertyTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Attribute Type t : TupleTypeInfo to clazz : Class<Tuple> in class org.apache.flink.table.dataformat.DataFormatConverters.TupleConverter |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.over.RowTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type decimalType : DecimalTypeInfo to decimalType : DecimalType in class org.apache.flink.table.functions.aggfunctions.IncrSumWithRetractAggFunction.DecimalIncrSumWithRetractAggFunction |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.aggregate.MiniBatchGlobalGroupAggFunction |
From |
To |
|
Change Attribute Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Attribute Type windowTypes : InternalType[] to windowTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Change Attribute Type windowPropertyTypes : InternalType[] to windowPropertyTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Attribute Type types : InternalType[] to types : LogicalType[] in class org.apache.flink.table.codegen.SortCodeGeneratorTest |
From |
To |
|
Change Attribute Type fieldTypes : InternalType[] to fieldTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorTest.GenericRowEqualiser |
From |
To |
|
Change Attribute Type decimalType : DecimalTypeInfo to decimalType : DecimalType in class org.apache.flink.table.functions.aggfunctions.IncrSumAggFunction.DecimalIncrSumAggFunction |
From |
To |
|
Change Attribute Type elementType : InternalType to elementType : LogicalType in class org.apache.flink.table.dataformat.DataFormatConverters.ObjectArrayConverter |
From |
To |
|
Change Attribute Type keyType : InternalType to keyType : LogicalType in class org.apache.flink.table.dataformat.DataFormatConverters.MapConverter |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.over.RowTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type decimalType : DecimalTypeInfo to decimalType : DecimalType in class org.apache.flink.table.functions.aggfunctions.MinAggFunction.DecimalMinAggFunction |
From |
To |
|
Change Attribute Type decimalType : DecimalTypeInfo to decimalType : DecimalType in class org.apache.flink.table.functions.aggfunctions.SumAggFunction.DecimalSumAggFunction |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.over.ProcTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type decimalType : DecimalTypeInfo to decimalType : DecimalType in class org.apache.flink.table.functions.aggfunctions.MaxAggFunction.DecimalMaxAggFunction |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.over.AbstractRowTimeUnboundedPrecedingOver |
From |
To |
|
Change Attribute Type previousType : GenericType<T> to previousSerializer : TypeSerializer<T> in class org.apache.flink.table.typeutils.BinaryGenericSerializer.BinaryGenericSerializerSnapshot |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.over.ProcTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type internalTypes : InternalType[] to logicalTypes : LogicalType[] in class org.apache.flink.table.typeutils.BaseRowTypeInfo |
From |
To |
|
Change Attribute Type valueTypes : InternalType[] to valueTypes : LogicalType[] in class org.apache.flink.table.runtime.aggregate.BytesHashMapTest |
From |
To |
|
Change Attribute Type accumulatorTypes : InternalType[] to accumulatorTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Attribute Type resultType : InternalType to resultType : LogicalType in class org.apache.flink.table.expressions.ResolvedAggInputReference |
From |
To |
|
Change Attribute Type keyTypes : InternalType[] to keyTypes : LogicalType[] in class org.apache.flink.table.runtime.aggregate.SumHashAggTestOperator |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.util.BinaryRowKeySelector |
From |
To |
|
Change Attribute Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Change Attribute Type aggResultTypes : InternalType[] to aggResultTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Change Attribute Type type : DecimalTypeInfo to type : DecimalType in class org.apache.flink.table.functions.aggfunctions.AvgAggFunction.DecimalAvgAggFunction |
From |
To |
|
Change Attribute Type sortKeyType : InternalType to sortKeyType : LogicalType in class org.apache.flink.table.runtime.util.GenericRowRecordSortComparator |
From |
To |
|
Change Attribute Type accumulatorTypes : InternalType[] to accumulatorTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Attribute Type type : DecimalTypeInfo to type : DecimalType in class org.apache.flink.table.functions.aggfunctions.SingleValueAggFunction.DecimalSingleValueAggFunction |
From |
To |
|
Change Attribute Type rightType : TypeInformation<BaseRow> to rightType : BaseRowTypeInfo in class org.apache.flink.table.runtime.join.TimeBoundedStreamJoin |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.over.ProcTimeUnboundedPrecedingFunction |
From |
To |
|
Change Attribute Type type : GenericType<T> to serializer : TypeSerializer<T> in class org.apache.flink.table.typeutils.BinaryGenericSerializer |
From |
To |
|
Change Attribute Type leftType : TypeInformation<BaseRow> to leftType : BaseRowTypeInfo in class org.apache.flink.table.runtime.join.TimeBoundedStreamJoin |
From |
To |
|
Change Attribute Type decimalType : DecimalTypeInfo to decimalType : DecimalType in class org.apache.flink.table.functions.aggfunctions.SumWithRetractAggFunction.DecimalSumWithRetractAggFunction |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.aggregate.MiniBatchGroupAggFunction |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorBuilder |
From |
To |
|
Change Attribute Type keyFieldTypes : InternalType[] to keyFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.util.BinaryRowKeySelector |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.over.RowTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.over.AbstractRowTimeUnboundedPrecedingOver |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.over.RowTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type keyTypes : InternalType[] to keyTypes : LogicalType[] in class org.apache.flink.table.runtime.aggregate.BytesHashMapTest |
From |
To |
|
Change Attribute Type valueType : InternalType to valueType : LogicalType in class org.apache.flink.table.dataformat.DataFormatConverters.MapConverter |
From |
To |
|
Change Attribute Type accTypes : InternalType[] to accTypes : LogicalType[] in class org.apache.flink.table.runtime.aggregate.GroupAggFunction |
From |
To |
|
Change Attribute Type decimalType : DecimalTypeInfo to decimalType : DecimalType in class org.apache.flink.table.functions.aggfunctions.Sum0AggFunction.DecimalSum0AggFunction |
From |
To |
|
Change Attribute Type types : InternalType[] to types : LogicalType[] in class org.apache.flink.table.typeutils.BaseRowSerializer |
From |
To |
|
Change Attribute Type typeList : InternalType[] to typeList : LogicalType[] in class org.apache.flink.table.typeutils.BinaryRowTypeInfoTest |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.over.ProcTimeRangeBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type aggBufferTypes : InternalType[] to aggBufferTypes : LogicalType[] in class org.apache.flink.table.runtime.aggregate.SumHashAggTestOperator |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.over.ProcTimeRowsBoundedPrecedingFunction |
From |
To |
|
Change Attribute Type resultType : InternalType to resultType : LogicalType in class org.apache.flink.table.expressions.ResolvedAggLocalReference |
From |
To |
|
Change Attribute Type orderKeyTypes : InternalType[] to orderKeyTypes : LogicalType[] in class org.apache.flink.table.functions.aggfunctions.RankLikeAggFunctionBase |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperator |
From |
To |
|
Change Attribute Type resultType : InternalType to resultType : LogicalType in class org.apache.flink.table.expressions.ResolvedDistinctKeyReference |
From |
To |
|
Change Attribute Type inputFieldTypes : InternalType[] to inputFieldTypes : LogicalType[] in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |