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/08/19 03:55:44 UTC
[flink] branch master updated (060ca99 -> f5be4df)

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 060ca99  [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese
     add f5be4df  [FLINK-17427][table-planner-blink] Support SupportsPartitionPushDown in planner

No new revisions were added by this update.

Summary of changes:
 .../logical/PushLimitIntoTableSourceScanRule.java  |   4 +-
 .../PushPartitionIntoTableSourceScanRule.java      | 340 ++++++++++++
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   4 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   4 +-
 .../planner/plan/schema/CatalogSourceTable.scala   |   1 -
 .../table/planner/factories/TestValuesCatalog.java | 116 ++++
 .../planner/factories/TestValuesTableFactory.java  | 310 ++++++-----
 .../PushPartitionIntoTableSourceScanRuleTest.java  | 140 +++++
 .../flink/table/planner/utils/FilterUtils.java     | 162 ++++++
 .../plan/batch/sql/PartitionableSourceTest.xml     | 247 +++++++++
 ...hPartitionIntoLegacyTableSourceScanRuleTest.xml | 424 +++++++++++++--
 ...> PushPartitionIntoTableSourceScanRuleTest.xml} | 600 +++++++++++++++++----
 .../plan/stream/sql/PartitionableSourceTest.xml    | 247 +++++++++
 .../plan/batch/sql/PartitionableSourceTest.scala   | 115 ++++
 ...artitionIntoLegacyTableSourceScanRuleTest.scala |  24 +-
 .../plan/stream/sql/PartitionableSourceTest.scala  | 115 ++++
 .../batch/sql/PartitionableSourceITCase.scala      | 134 +++++
 .../stream/sql/PartitionableSourceITCase.scala     | 153 ++++++
 18 files changed, 2853 insertions(+), 287 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushPartitionIntoTableSourceScanRule.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesCatalog.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushPartitionIntoTableSourceScanRuleTest.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/utils/FilterUtils.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/PartitionableSourceTest.xml
 copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/{PushPartitionIntoLegacyTableSourceScanRuleTest.xml => PushPartitionIntoTableSourceScanRuleTest.xml} (50%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/PartitionableSourceTest.xml
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/PartitionableSourceTest.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/PartitionableSourceTest.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/PartitionableSourceITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/PartitionableSourceITCase.scala