This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 73993fc55e3 [FLINK-38885][table] Migrate `StreamPhysicalJoinRuleBase`
and its children
add 2a3d701c59a [FLINK-36986][table] Migrate
`SplitRemoteConditionFromJoinRule` to java
No new revisions were added by this update.
Summary of changes:
.../plan/rules/logical/AsyncCalcSplitRule.java | 9 +-
.../logical/SplitPythonConditionFromJoinRule.java} | 21 ++-
.../logical/SplitRemoteConditionFromJoinRule.java | 169 +++++++++++++++++++++
.../logical/SplitPythonConditionFromJoinRule.scala | 25 ---
.../logical/SplitRemoteConditionFromJoinRule.scala | 102 -------------
5 files changed, 183 insertions(+), 143 deletions(-)
copy
flink-table/{flink-table-common/src/main/java/org/apache/flink/table/annotation/UnknownSerializer.java
=>
flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/SplitPythonConditionFromJoinRule.java}
(63%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/SplitRemoteConditionFromJoinRule.java
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/SplitPythonConditionFromJoinRule.scala
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/SplitRemoteConditionFromJoinRule.scala
