This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5dadbf3 [FLINK-18888][python] Support execute_async for StreamExecutionEnvironment. (#13126) add 3a66824 [hotfix][table] Enable TypeInformationRawType for data structure converters add 415a023 [hotfix][table-common] Enable hashCode/equals for materialized raw value data add fa76232 [hotfix][table-common] Make BinaryRowData and NestedRowData comparable add f02114d [FLINK-18809][table-planner-blink] Introduce interface for InternalAggregateFunction add 21d153d [FLINK-18809][table-planner-blink] Update MaxWithRetractAggFunction add 86e4ab2 [FLINK-18809][table-planner-blink] Update MinWithRetractAggFunction add ab1e3ba [FLINK-18809][table-planner-blink] Update CollectAggFunction add 2267d23 [FLINK-18809][table-planner-blink] Update ListAggFunctions add 9bbc156 [FLINK-18809][table-planner-blink] Update First/LastValueAggFunction add b5e17ad [FLINK-18809][table-planner-blink] Ensure that all internal agg functions have been updated add 2d024ae [FLINK-18809][table-planner-blink] Update distinct aggregates to the new type system No new revisions were added by this update. Summary of changes: .../table/data/binary/BinaryRawValueData.java | 17 +- .../flink/table/data/binary/BinaryRowData.java | 14 + .../flink/table/data/binary/BinarySection.java | 13 +- .../flink/table/data/binary/NestedRowData.java | 14 + .../types/logical/utils/LogicalTypeChecks.java | 2 +- .../functions/aggfunctions/CollectAggFunction.java | 99 +++-- .../aggfunctions/FirstValueAggFunction.java | 205 +++------- .../FirstValueWithRetractAggFunction.java | 450 +++++++-------------- .../aggfunctions/InternalAggregateFunction.java | 53 +++ .../aggfunctions/LastValueAggFunction.java | 205 +++------- .../LastValueWithRetractAggFunction.java | 444 ++++++-------------- .../ListAggWithRetractAggFunction.java | 113 +++--- .../ListAggWsWithRetractAggFunction.java | 101 ++--- .../aggfunctions/MaxWithRetractAggFunction.java | 337 ++++----------- .../aggfunctions/MinWithRetractAggFunction.java | 337 ++++----------- .../table/planner/typeutils/DataViewUtils.java | 43 ++ .../planner/codegen/agg/DistinctAggCodeGen.scala | 63 +-- .../planner/codegen/calls/ScalarOperatorGens.scala | 41 +- .../planner/plan/utils/AggFunctionFactory.scala | 184 ++------- .../table/planner/plan/utils/AggregateUtil.scala | 185 ++++----- .../table/planner/plan/utils/aggregation.scala | 4 +- .../aggfunctions/AggFunctionTestBase.java | 81 +--- ...FirstLastValueAggFunctionWithOrderTestBase.java | 43 +- .../FirstValueAggFunctionWithOrderTest.java | 81 ++-- .../FirstValueAggFunctionWithoutOrderTest.java | 80 ++-- ...stValueWithRetractAggFunctionWithOrderTest.java | 101 ++--- ...alueWithRetractAggFunctionWithoutOrderTest.java | 99 ++--- .../LastValueAggFunctionWithOrderTest.java | 79 ++-- .../LastValueAggFunctionWithoutOrderTest.java | 75 ++-- ...stValueWithRetractAggFunctionWithOrderTest.java | 92 +++-- ...alueWithRetractAggFunctionWithoutOrderTest.java | 101 ++--- .../ListAggWsWithRetractAggFunctionTest.java | 15 - .../MaxWithRetractAggFunctionTest.java | 156 +++---- .../MinWithRetractAggFunctionTest.java | 146 ++++--- .../planner/plan/batch/sql/SubplanReuseTest.scala | 19 +- .../planner/plan/stream/sql/SubplanReuseTest.scala | 20 +- .../runtime/stream/sql/AggregateITCase.scala | 14 +- .../utils/UserDefinedFunctionTestUtils.scala | 12 +- .../data/conversion/RawByteArrayConverter.java | 14 +- .../table/data/conversion/RawObjectConverter.java | 14 +- .../table/runtime/typeutils/TypeCheckUtils.java | 7 +- .../apache/flink/table/data/BinaryRowDataTest.java | 28 ++ 42 files changed, 1683 insertions(+), 2518 deletions(-) create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/InternalAggregateFunction.java