Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-16987 FLIP-95: Add new table source and sink interfaces
  3. FLINK-19639

Support nested push down for SupportsProjectionPushDown interface in planner

    XMLWordPrintableJSON

Details

    Description

      Support to push nested projection into TableSourceScan. But it may cause name conflicts in some situaion. For example, we create the table with ddl

      CREATE TABLE NestedTable (
           nest1 ROW<a INT>,
           nest2 ROW<a INT>
      )
      

      and with query

      SELECT nest1.a, nest2.a from NestedTable
      

      and we will get 2 `a` in the new schema when pushing projection.
      Here we useĀ '_' to concatenate the names of all levels as the name of the nested fields. In this example, we will get fields nest1_a, nest2_a in the new schema.

      Attachments

        Issue Links

          Activity

            People

              fsk119 Shengkai Fang
              fsk119 Shengkai Fang
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: