[FLINK-35588] flink sql redis connector

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.19.1
• Labels: newbie

Language

Java

• Assignee: Unassigned
• Reporter: cris niu
• Created: 13/Jun/24 07:00
• Updated: 01/Aug/24 05:20

Description

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