This is an automated email from the ASF dual-hosted git repository.
wanglijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from a0a66d70398 [FLINK-32279][table-runtime] Add plan test for
MulitpleInput support one-input node as root when operator fusion codegen
enabled
add 8659dd788d0 [FLINK-32492][table-planner] Introduce configuration
options for runtime filter.
add ad20b19fff8 [FLINK-32492][table-planner] Introduce ExecNode for
runtime filter
add 72bee90ccb4 [FLINK-32492][table-planner] Introduce
FlinkRuntimeFilterProgram
add 9f73d3d81a5 [FLINK-32492][table-planner] Add ITCase for runtime filter
No new revisions were added by this update.
Summary of changes:
.../generated/optimizer_config_configuration.html | 24 +
.../table/api/config/OptimizerConfigOptions.java | 60 ++
.../BatchExecGlobalRuntimeFilterBuilder.java | 85 ++
.../BatchExecLocalRuntimeFilterBuilder.java | 107 +++
.../runtimefilter/BatchExecRuntimeFilter.java | 94 ++
.../BatchPhysicalGlobalRuntimeFilterBuilder.java | 101 ++
.../BatchPhysicalLocalRuntimeFilterBuilder.java | 109 +++
.../runtimefilter/BatchPhysicalRuntimeFilter.java | 125 +++
.../program/FlinkRuntimeFilterProgram.java | 678 +++++++++++++
.../plan/optimize/program/FlinkBatchProgram.scala | 4 +
.../physical/batch/BatchPhysicalJoinRuleBase.scala | 24 +-
.../flink/table/planner/plan/utils/JoinUtil.scala | 11 +
.../program/FlinkRuntimeFilterProgramTest.java | 412 ++++++++
.../runtime/batch/sql/DynamicFilteringITCase.java | 31 +-
.../runtime/batch/sql/RuntimeFilterITCase.java | 207 ++++
.../program/FlinkRuntimeFilterProgramTest.xml | 1016 ++++++++++++++++++++
.../planner/runtime/utils/BatchTestBase.scala | 12 +-
17 files changed, 3058 insertions(+), 42 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/runtimefilter/BatchExecGlobalRuntimeFilterBuilder.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/runtimefilter/BatchExecLocalRuntimeFilterBuilder.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/runtimefilter/BatchExecRuntimeFilter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/batch/runtimefilter/BatchPhysicalGlobalRuntimeFilterBuilder.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/batch/runtimefilter/BatchPhysicalLocalRuntimeFilterBuilder.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/batch/runtimefilter/BatchPhysicalRuntimeFilter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRuntimeFilterProgram.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRuntimeFilterProgramTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/RuntimeFilterITCase.java
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/optimize/program/FlinkRuntimeFilterProgramTest.xml
