Ingo Bürk created FLINK-23917:
---------------------------------

             Summary: Project metadata columns to apply to sources which do not 
implement projection pushdown
                 Key: FLINK-23917
                 URL: https://issues.apache.org/jira/browse/FLINK-23917
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
            Reporter: Ingo Bürk


If a source implements SupportsReadingMetadata, but not 
SupportsProjectionPushDown, #applyReadableMetadata is always called with all 
metadata keys declared in the table's schema. If SupportsProjectionPushDown is 
implemented, this is filtered down to only the required metadata keys. This can 
be a problem since metadata could be expensive to calculate.

The root cause for this is that the projection happens in 
PushProjectIntoTableSourceScanRule which doesn't run for sources which do not 
implement projection pushdown. We should add a new separate rule which projects 
required metadata keys for the source in this case.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to