Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19819

SourceReaderBase supports limit push down

    XMLWordPrintableJSON

    Details

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                lzljs3620320 Jingsong Lee
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated: