DTStack / DTStack/flinkStreamSQL

[feature request] Redis sink & side connector

Open
#328 2 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
2k
Forks
913
PR merge metrics
No merged PRs in 30d

Description

正在找一个RedisSink connector就找到了你们的项目,感谢开源!可以提一个需求吗?

Redis key现在是`tableName:privateKey:privateKeyValue:columnName`. 可不可以支持customize PrimaryKey and Value 的格式,可以更灵活地支持各种use case. e.g. key is `tableName:privateKeyValue`; value is a serialized form of multiple columns. Like a stringify JSON format of `{column1: column1Value; column2: column2Value...}`

同时想问一下[Sink](https://github.com/DTStack/flinkStreamSQL/blob/5c176c85e1e013244557c76fd605df3b375177a5/docs/plugin/redisSink.md) 和 [Side](https://github.com/DTStack/flinkStreamSQL/blob/5c176c85e1e013244557c76fd605df3b375177a5/docs/plugin/redisSide.md)有什么区别? 我懂Sink,但不懂side啥意思?谢谢!

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.