Jingsong Lee created FLINK-19819:
------------------------------------
Summary: SourceReaderBase supports limit push down
Key: FLINK-19819
URL:
https://issues.apache.org/jira/browse/FLINK-19819 Project: Flink
Issue Type: Improvement
Components: Connectors / Common
Reporter: Jingsong Lee
Fix For: 1.12.0
User requirement:
Users need to look at a few random pieces of data in a table to see what the data looks like. So users often use the SQL:
"select * from table limit 10"
For a large table, expect to end soon because only a few pieces of data are queried.
For DataStream or BoundedStream, they are push based execution models, so the downstream cannot control the end of source operator.
We need push down limit to source operator, so that source operator can end early.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
