[
https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856420#comment-17856420
]
cris niu commented on FLINK-35588:
----------------------------------
I have upload the related code to github, please try it. If you have and
question or encounter bug when use connector, please contact with me
Github url: https://github.com/niuhu3/flink_sql_redis_connector.git
> 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
> Priority: Major
> Labels: pull-request-available
> Attachments: Snipaste_2024-06-20_16-03-54.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)
