This is an automated email from the ASF dual-hosted git repository.
xuyangzhong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from f843c121065 [FLINK-33391][runtime] Support tasks balancing at TM level
for Adaptive Scheduler.
add 5b61b1cda99 [FLINK-38556][table] Support filter and project between
source and delta join (#27159)
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/spec/DeltaJoinSpec.java | 31 +-
.../nodes/exec/stream/StreamExecDeltaJoin.java | 30 +-
.../table/planner/plan/utils/DeltaJoinUtil.java | 338 +++++++++--
.../planner/codegen/LookupJoinCodeGenerator.scala | 28 +-
.../physical/batch/BatchPhysicalLookupJoin.scala | 3 +-
.../physical/stream/StreamPhysicalLookupJoin.scala | 3 +-
.../table/planner/plan/utils/FlinkRexUtil.scala | 4 +-
.../planner/plan/utils/TemporalJoinUtil.scala | 8 +-
.../planner/plan/stream/sql/DeltaJoinTest.xml | 625 ++++++++++++++++++---
.../planner/plan/stream/sql/DeltaJoinTest.scala | 348 ++++++++++--
.../runtime/stream/sql/DeltaJoinITCase.scala | 517 ++++++++++++++++-
.../join/deltajoin/AsyncDeltaJoinRunner.java | 72 ++-
.../join/lookup/AsyncLookupJoinWithCalcRunner.java | 26 +-
.../CalcCollectionCollector.java} | 37 +-
.../deltajoin/StreamingDeltaJoinOperatorTest.java | 318 ++++++++++-
15 files changed, 2116 insertions(+), 272 deletions(-)
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/{interval/EmitAwareCollector.java
=> lookup/CalcCollectionCollector.java} (54%)
