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 2019/10/29 07:12:13 UTC

[flink] branch master updated (e18320b -> 4bf46c5)

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 e18320b  [FLINK-14397][hive] Failed to run Hive UDTF with array arguments
     add 7420bdb  [FLINK-14134][table-common] Introduce LimitableTableSource for optimizing limit
     add 4bf46c5  [FLINK-14134][table-planner-blink] Introduce PushLimitIntoTableSourceScanRule to apply LimitableTableSource

No new revisions were added by this update.

Summary of changes:
 .../LimitableTableSource.java}                     |  24 ++--
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   7 +-
 .../logical/PushLimitIntoTableSourceScanRule.scala | 121 +++++++++++++++++++++
 .../table/planner/plan/batch/sql/LimitTest.xml     | 105 ++++++++++++++++++
 .../table/planner/plan/batch/sql/LimitTest.scala   |  38 ++++++-
 .../planner/runtime/batch/sql/LimitITCase.scala    |  22 ++--
 .../planner/utils/TestLimitableTableSource.scala   |  78 +++++++++++++
 7 files changed, 377 insertions(+), 18 deletions(-)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/{sinks/OverwritableTableSink.java => sources/LimitableTableSource.java} (51%)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PushLimitIntoTableSourceScanRule.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/utils/TestLimitableTableSource.scala