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/31 10:59:36 UTC
[flink] branch master updated (b8be547 -> 3ab1a1c)

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 b8be547  [hotfix][csv][docs] Fix 'csv.quote-character' format option documentation (#13035)
     add 3ab1a1c  [FLINK-17426][table-planner-blink] Support the SupportsLimitPushDown interface for ScanTableSource

No new revisions were added by this update.

Summary of changes:
 .../logical/PushFilterIntoTableSourceScanRule.java |  13 +-
 .../logical/PushLimitIntoTableSourceScanRule.java  | 118 ++++
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   1 +
 .../planner/plan/schema/CatalogSourceTable.scala   |   1 -
 .../planner/factories/TestValuesTableFactory.java  |  26 +-
 ...a => PushLimitIntoTableSourceScanRuleTest.java} |  56 +-
 .../org.apache.flink.table.factories.TableFactory  |   2 +-
 .../sql/{LimitTest.xml => LegacyLimitTest.xml}     | 598 ++++++++++-----------
 .../table/planner/plan/batch/sql/LimitTest.xml     |  45 +-
 .../PushLimitIntoLegacyTableSourceScanRuleTest.xml | 152 ++++++
 .../PushLimitIntoTableSourceScanRuleTest.xml       | 152 ++++++
 .../sql/{LimitTest.scala => LegacyLimitTest.scala} |  42 +-
 .../table/planner/plan/batch/sql/LimitTest.scala   | 138 ++---
 ...ushLimitIntoLegacyTableSourceScanRuleTest.scala | 116 ++++
 .../{LimitITCase.scala => LegacyLimitITCase.scala} |   8 +-
 .../planner/runtime/batch/sql/LimitITCase.scala    | 107 +---
 .../{LimitITCase.scala => LegacyLimitITCase.scala} |   6 +-
 .../planner/runtime/batch/table/LimitITCase.scala  |  50 +-
 ....scala => TestLegacyLimitableTableSource.scala} |  10 +-
 19 files changed, 1004 insertions(+), 637 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoTableSourceScanRule.java
 copy flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/{PushFilterIntoTableSourceScanRuleTest.java => PushLimitIntoTableSourceScanRuleTest.java} (60%)
 copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/{LimitTest.xml => LegacyLimitTest.xml} (97%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoLegacyTableSourceScanRuleTest.xml
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoTableSourceScanRuleTest.xml
 copy flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/{LimitTest.scala => LegacyLimitTest.scala} (81%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoLegacyTableSourceScanRuleTest.scala
 copy flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/{LimitITCase.scala => LegacyLimitITCase.scala} (92%)
 copy flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/table/{LimitITCase.scala => LegacyLimitITCase.scala} (90%)
 rename flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/utils/{TestLimitableTableSource.scala => TestLegacyLimitableTableSource.scala} (94%)