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
