You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/07/22 02:30:29 UTC
[flink] branch master updated (7ea9bb9 -> fe0d001)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 7ea9bb9  [hotfix][table-common] Remove unused InternalTypeInfo
     add fe0d001  [FLINK-17425][table-planner-blink] Support SupportsFilterPushDown on ScanTableSource in planner

No new revisions were added by this update.

Summary of changes:
 .../logical/PushFilterIntoTableSourceScanRule.java | 208 +++++++++++
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   2 +
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   2 +
 .../planner/plan/schema/CatalogSourceTable.scala   |   1 -
 .../planner/plan/schema/TableSourceTable.scala     |  23 ++
 .../planner/factories/TestValuesTableFactory.java  | 195 +++++++++--
 .../PushFilterIntoTableSourceScanRuleTest.java     |  94 +++++
 .../org.apache.flink.table.factories.TableFactory  |   2 +-
 .../table/planner/plan/batch/sql/TableScanTest.xml |   2 +-
 ...l => PushFilterIntoTableSourceScanRuleTest.xml} | 390 ++++++++++-----------
 .../planner/plan/stream/sql/TableScanTest.xml      |   6 +-
 .../plan/batch/sql/LegacyTableSourceTest.scala     |   6 +-
 ...shFilterIntoLegacyTableSourceScanRuleTest.scala |  10 +-
 .../plan/stream/sql/LegacyTableSourceTest.scala    |   6 +-
 .../planner/plan/stream/sql/TableScanTest.scala    |  21 +-
 .../batch/sql/LegacyTableSourceITCase.scala        |  10 +-
 .../runtime/batch/sql/TableSourceITCase.scala      |  18 +-
 .../stream/sql/LegacyTableSourceITCase.scala       |   6 +-
 .../runtime/stream/sql/TableSourceITCase.scala     |  18 +-
 .../table/planner/utils/testTableSourceSinks.scala |  16 +-
 20 files changed, 750 insertions(+), 286 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRuleTest.java
 copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/{PushFilterIntoLegacyTableSourceScanRuleTest.xml => PushFilterIntoTableSourceScanRuleTest.xml} (52%)