This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e78d355 [FLINK-23267][table-planner] Enable Java code splitting for
all generated classes
add 5cc769d [FLINK-23023][table-planner] Support offset in window TVF
No new revisions were added by this update.
Summary of changes:
.../functions/sql/SqlCumulateTableFunction.java | 5 +-
.../planner/functions/sql/SqlHopTableFunction.java | 5 +-
.../functions/sql/SqlTumbleTableFunction.java | 7 +-
.../planner/plan/logical/CumulativeWindowSpec.java | 52 ++++-
.../planner/plan/logical/HoppingWindowSpec.java | 52 ++++-
.../planner/plan/logical/TumblingWindowSpec.java | 38 +++-
.../exec/stream/StreamExecWindowAggregateBase.java | 27 ++-
.../table/planner/plan/utils/WindowUtil.scala | 21 +-
.../exec/stream/WindowAggregateJsonPlanTest.java | 85 ++++++++
...t => testEventTimeCumulateWindowWithOffset.out} | 10 +-
...ow.out => testEventTimeHopWindowWithOffset.out} | 10 +-
...out => testEventTimeTumbleWindowWithOffset.out} | 10 +-
.../plan/stream/sql/WindowTableFunctionTest.xml | 196 ++++++++++++++++-
.../plan/stream/sql/WindowTableFunctionTest.scala | 62 ++++--
.../runtime/stream/sql/WindowAggregateITCase.scala | 241 +++++++++++++++++++++
15 files changed, 745 insertions(+), 76 deletions(-)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/{testEventTimeCumulateWindow.out
=> testEventTimeCumulateWindowWithOffset.out} (97%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/{testEventTimeHopWindow.out
=> testEventTimeHopWindowWithOffset.out} (97%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/{testEventTimeTumbleWindow.out
=> testEventTimeTumbleWindowWithOffset.out} (98%)
