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
