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)
