[jira] [Created] (FLINK-31367) Support filter's function push down

["tanjialiang (Jira)" <ji...@apache.org>]

tanjialiang created FLINK-31367:
-----------------------------------

             Summary: Support filter's function push down
                 Key: FLINK-31367
                 URL: https://issues.apache.org/jira/browse/FLINK-31367
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / JDBC, Table SQL / API
    Affects Versions: 1.16.1
            Reporter: tanjialiang


Hi teams, as far as i known, source ability support simply filter push down, it may be just push down constant value like this:
{code:java}
CREATE TABLE student (
   id int,
   brithday string
) WITH (
   ...
);

# it can support push down its filter if connector implements SupportsFilterPushDown
# id and birthday will be push down
SELECT * FROM student WHERE id = 1 AND birthday = '1997-04-13';{code}
But it will not push down like this:
{code:java}
CREATE TABLE student (
   id int,
   brithday string
) WITH (
   ...
);

# it will not support push down its filter though connector implements SupportsFilterPushDown
# id and birthday will not push down, so it will be filter in flink task
SELECT * FROM student WHERE id = 1 AND birthday = TO_DATE('1997-04-13 00:00:00');{code}
 

Can we get the flink function in SupportsFilterPushDown, so we can adapt the flink function in every connector?

For example, I can adapt the Flink function TO_DATE to mysql's function STR_TO_DATE.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)