[
https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18037967#comment-18037967
]
liting liu commented on FLINK-35588:
------------------------------------
(y) This is an excellent feature!
> flink sql redis connector
> -------------------------
>
> Key: FLINK-35588
> URL: https://issues.apache.org/jira/browse/FLINK-35588
> Project: Flink
> Issue Type: New Feature
> Affects Versions: 1.19.1
> Reporter: cris niu
> Priority: Major
> Labels: newbie
> Attachments: 1.png
>
> Original Estimate: 1m
> Remaining Estimate: 1m
>
> 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)
