cris niu created FLINK-35588:
--------------------------------
Summary: flink sql redis connector
Key: FLINK-35588
URL: https://issues.apache.org/jira/browse/FLINK-35588
Project: Flink
Issue Type: New Feature
Reporter: cris niu
flink sql have not redis connector. I think we should develop a sql redis
connector for our easier development.
I have writen little code about sql redis connector and my thoughts are as
follows:
source：
1.writing a factory class implement DynamicTableSourceFactory
2.writing a class implement ScanTableSource and how to wrtie it's
schema
3.writing a class extends RichSourceFunction and ResultTypeQueryable
4.using JAVA SIP mode to use factory class and related code
Finally, redis sink has the same step like source ,but it extends source factory
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
