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 9463c9b155e [FLINK-32695] [Tests] Removed SourceFunction Dependency
from YarnTestCacheJob.
add 17bedd4bc61 [FLINK-37844][table-planner] Add new
ProjectMultiJoinTransposeRule
No new revisions were added by this update.
Summary of changes:
.../logical/ProjectMultiJoinTransposeRule.java | 495 +++++++++++++++++++++
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +
.../planner/plan/stream/sql/MultiJoinTest.xml | 217 ++++-----
...our-way-complex-updating-join-with-restore.json | 53 ++-
.../savepoint/_metadata | Bin 35162 -> 34659 bytes
...r-way-join-no-common-join-key-with-restore.json | 154 +++++--
.../savepoint/_metadata | Bin 41248 -> 37246 bytes
.../plan/three-way-inner-join-with-restore.json | 4 +-
.../savepoint/_metadata | Bin 21326 -> 21336 bytes
...way-join-with-time-attributes-with-restore.json | 93 ++--
.../savepoint/_metadata | Bin 24946 -> 23768 bytes
.../three-way-left-outer-join-with-restore.json | 4 +-
.../savepoint/_metadata | Bin 21759 -> 21588 bytes
13 files changed, 781 insertions(+), 241 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/ProjectMultiJoinTransposeRule.java
