This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6248ceda1d9 [FLINK-37882][table] Add tests for queries where
LITERAL_AGG will appear after upgrade to Calcite 1.35
add cf55d306f57 [FLIP-516][FLINK-37481] Add new multi way join operator
(#26313)
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
...ition.java => GeneratedMultiJoinCondition.java} | 18 +-
...{JoinCondition.java => MultiJoinCondition.java} | 14 +-
.../join/stream/StreamingMultiJoinOperator.java | 945 +++++++++++++++
.../AttributeBasedJoinKeyExtractor.java | 562 +++++++++
.../join/stream/keyselector/JoinKeyExtractor.java | 95 ++
.../join/stream/state/MultiJoinStateView.java | 22 +-
.../join/stream/state/MultiJoinStateViews.java | 493 ++++++++
...StreamingFourWayMixedInnerJoinOperatorTest.java | 610 ++++++++++
...StreamingFourWayMixedOuterJoinOperatorTest.java | 1224 ++++++++++++++++++++
.../StreamingMultiConditionJoinOperatorTest.java | 218 ++++
.../StreamingMultiJoinOperatorTestBase.java | 796 +++++++++++++
.../StreamingThreeWayJoinOperatorTest.java | 248 ++++
...reeWayOuterJoinCustomConditionOperatorTest.java | 167 +++
.../StreamingThreeWayOuterJoinOperatorTest.java | 664 +++++++++++
.../StreamingTwoWayInnerMultiJoinOperatorTest.java | 118 ++
...StreamingTwoWayJoinNoUniqueKeyOperatorTest.java | 150 +++
.../StreamingTwoWayNonEquiJoinOperatorTest.java | 429 +++++++
.../StreamingTwoWayOuterMultiJoinOperatorTest.java | 188 +++
.../table/runtime/util/RowDataHarnessAssertor.java | 7 +
.../util/StateParameterizedHarnessTestBase.java | 102 ++
21 files changed, 7049 insertions(+), 22 deletions(-)
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/generated/{GeneratedFilterCondition.java
=> GeneratedMultiJoinCondition.java} (69%)
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/generated/{JoinCondition.java
=> MultiJoinCondition.java} (67%)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/StreamingMultiJoinOperator.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/keyselector/AttributeBasedJoinKeyExtractor.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/keyselector/JoinKeyExtractor.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/shuffle/ShuffleTestUtils.java
=>
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/MultiJoinStateView.java
(58%)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/MultiJoinStateViews.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingFourWayMixedInnerJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingFourWayMixedOuterJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingMultiConditionJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingMultiJoinOperatorTestBase.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingThreeWayJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingThreeWayOuterJoinCustomConditionOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingThreeWayOuterJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingTwoWayInnerMultiJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingTwoWayJoinNoUniqueKeyOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingTwoWayNonEquiJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/multijoin/StreamingTwoWayOuterMultiJoinOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/util/StateParameterizedHarnessTestBase.java
