[
https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870071#comment-17870071
]
cris niu edited comment on FLINK-35588 at 8/1/24 3:19 AM:
----------------------------------------------------------
update new version 0.1.0 for Flink 1.19 :
# use SinkWriter interface to implements redis sink function
# use Source interface to implements redis source function
# batch and streaming use one api
was (Author: JIRAUSER305782):
update new version 0.1.0 :
# use SinkWriter interface to implements redis sink function
# use Source interface to implements redis source function
# batch and streaming use one api
> 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: 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)
