This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b2e65a4 [FLINK-21923][table-planner-blink] Fix ClassCastException in
SplitAggregateRule when a query contains both sum/count and avg function
add 362f4ae [FLINK-19449][doc] Fix wrong document for lead and lag
add 9b9d4f0 [FLINK-19449][table] Introduce LinkedListSerializer
add bf8f998 [FLINK-19449][table] Pass isBounded to AggFunctionFactory
add 075b0b2 [FLINK-19449][table-planner] LEAD/LAG cannot work correctly
in streaming mode
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 6 +-
.../functions/aggfunctions/LagAggFunction.java | 163 +++++++++++++++++++++
.../stream/StreamExecGlobalWindowAggregate.java | 4 +-
.../stream/StreamExecLocalWindowAggregate.java | 2 +-
.../exec/stream/StreamExecWindowAggregate.java | 2 +-
.../plan/metadata/FlinkRelMdColumnInterval.scala | 25 ++--
.../StreamPhysicalGlobalWindowAggregate.scala | 2 +-
.../StreamPhysicalLocalWindowAggregate.scala | 2 +-
.../stream/StreamPhysicalWindowAggregate.scala | 2 +-
.../planner/plan/utils/AggFunctionFactory.scala | 35 ++++-
.../table/planner/plan/utils/AggregateUtil.scala | 27 +++-
.../functions/aggfunctions/LagAggFunctionTest.java | 62 ++++++++
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 9 +-
.../runtime/stream/sql/OverAggregateITCase.scala | 68 +++++++++
.../runtime/typeutils/LinkedListSerializer.java | 97 +++++++-----
.../typeutils/LinkedListSerializerTest.java | 44 +++---
16 files changed, 449 insertions(+), 101 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/LagAggFunction.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/functions/aggfunctions/LagAggFunctionTest.java
copy
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java
=>
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/LinkedListSerializer.java
(59%)
copy
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/ListSerializerTest.java
=>
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/LinkedListSerializerTest.java
(52%)
