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)