This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 72240726a93 [FLINK-36575][runtime] ExecutionVertexInputInfo supports
consuming subpartition groups
new acf39139a8a [FLINK-36634][table] Move the PlannerModule to the
flink-table-api-java module so that the planner code can be accessed by the
runtime.
new 56ba88bf0b4 [FLINK-36634][table] Introduce AdaptiveJoin to support
dynamic generate join operator at runtime.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/table/planner/loader/PlannerModule.java | 8 +-
.../adaptive/AdaptiveJoinOperatorGenerator.java | 158 ++++++++++
.../planner/plan/utils/HashJoinOperatorUtil.java | 195 ++++++++++++
.../plan/utils/SorMergeJoinOperatorUtil.java | 43 ++-
.../flink/table/planner/plan/utils/SortUtil.scala | 4 +-
.../AdaptiveJoinOperatorGeneratorTest.java | 333 +++++++++++++++++++++
.../operators/join/adaptive/AdaptiveJoin.java | 56 ++++
.../join/adaptive/AdaptiveJoinOperatorFactory.java | 134 +++++++++
.../join/Int2HashJoinOperatorTestBase.java | 2 +-
9 files changed, 927 insertions(+), 6 deletions(-)
rename flink-table/{flink-table-planner-loader =>
flink-table-api-java}/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
(97%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/adaptive/AdaptiveJoinOperatorGenerator.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/HashJoinOperatorUtil.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/adaptive/AdaptiveJoinOperatorGeneratorTest.java
create mode 100755
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/adaptive/AdaptiveJoin.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/adaptive/AdaptiveJoinOperatorFactory.java
