great, thanks for the pointers everyone.
i'm going to pursue rolling my own built around lettuce since it seems more
feature-full wrt async semantics.
On Mon, Aug 16, 2021 at 7:21 PM Yik San Chan
wrote:
> By the way, this post in Chinese showed how we do it exactly with code.
>
> https://yiksan
By the way, this post in Chinese showed how we do it exactly with code.
https://yiksanchan.com/posts/flink-bulk-insert-redis
And yes it had buffered writes support by leveraging Flink operator state,
and Redis Pipelining. Feel free to let you know if you have any questions.
On Tue, Aug 17, 2021
Hi Jin,
I was in the same shoes. I tried bahir redis connector at first, then I
felt it was very limited, so I rolled out my own. It was actually quite
straightforward.
All you need to do is to extend RichSinkFunction, then put your logic
inside. Regarding Redis clients, Jedis (https://github.com
Hi, Jin
IIUC, the DataStream connector `RedisSink` can still be used. However,
the Table API connector `RedisTableSink` might not work (at least in
the future) because it is implemented based on the deprecated Table
connector abstraction. You can still give it a try, though.
Best,
Yangze Guo
On
