You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by hx...@apache.org on 2021/05/17 14:00:19 UTC
[flink] branch master updated (d09745a -> 5eebab4)
This is an automated email from the ASF dual-hosted git repository.
hxb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d09745a [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization
add 5eebab4 [FLINK-22652][python][table-planner-blink] Support StreamExecPythonGroupWindowAggregate json serialization/deserialization
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/table/tests/test_udaf.py | 67 ++++++
.../StreamExecPythonGroupWindowAggregate.java | 74 +++++-
.../StreamPhysicalPythonGroupWindowAggregate.scala | 1 -
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 1 -
...=> PythonGroupWindowAggregateJsonPlanTest.java} | 43 ++--
.../testEventTimeHopWindow.out} | 169 +++++++-------
.../testEventTimeSessionWindow.out} | 167 +++++++------
.../testEventTimeTumbleWindow.out | 258 ++++++++++-----------
.../testProcTimeHopWindow.out | 74 ++++--
.../testProcTimeSessionWindow.out | 74 ++++--
.../testProcTimeTumbleWindow.out | 171 +++++++++-----
11 files changed, 649 insertions(+), 450 deletions(-)
copy flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest.java => PythonGroupWindowAggregateJsonPlanTest.java} (81%)
copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out => PythonGroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out} (76%)
copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindow.out => PythonGroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeSessionWindow.out} (76%)
copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan => PythonGroupWindowAggregateJsonPlanTest_jsonplan}/testEventTimeTumbleWindow.out (78%)
copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan => PythonGroupWindowAggregateJsonPlanTest_jsonplan}/testProcTimeHopWindow.out (82%)
copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan => PythonGroupWindowAggregateJsonPlanTest_jsonplan}/testProcTimeSessionWindow.out (82%)
copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan => PythonGroupWindowAggregateJsonPlanTest_jsonplan}/testProcTimeTumbleWindow.out (80%)