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 3dd938d [FLINK-21602] Track asynchronous background tasks in the
AdaptiveScheduler
add 6540cb6 [FLINK-21816][table-planner-blink] Support StreamExecMatch
json serialization/deserialization
No new revisions were added by this update.
Summary of changes:
.../nodes/exec/serde/RexNodeJsonDeserializer.java | 32 ++
.../nodes/exec/serde/RexNodeJsonSerializer.java | 16 +
.../planner/plan/nodes/exec/spec/MatchSpec.java | 77 +++-
.../plan/nodes/exec/stream/StreamExecMatch.java | 31 +-
.../plan/nodes/exec/serde/RexNodeSerdeTest.java | 4 +-
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 1 -
...anTest.java => MatchRecognizeJsonPlanTest.java} | 42 +-
.../jsonplan/MatchRecognizeJsonPlanITCase.java | 109 +++++
.../testMatch.out | 501 +++++++++++++++++++++
9 files changed, 776 insertions(+), 37 deletions(-)
copy
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{RankJsonPlanTest.java
=> MatchRecognizeJsonPlanTest.java} (63%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/MatchRecognizeJsonPlanITCase.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeJsonPlanTest_jsonplan/testMatch.out
