// 3. transform
out.collect(inputString + " - " + tmpValue);
}
}
-邮件原件-
发件人: Ramya Ramamurthy [mailto:hair...@gmail.com]
发送时间: 2020年7月21日 星期二 18:42
收件人: dev@flink.apache.org
主题: Flink Redis connectivity
Hi,
As per the understanding we have from the documentation, I
r obtain some insights.
> >
> > [1] http://bahir.apache.org/docs/flink/current/flink-streaming-redis/
> > [2] https://github.com/apache/bahir-flink
> >
> > Best
> > Yun Tang
> >
> > ____
> > From: Yangze Guo
>
use it or obtain some insights.
>
> [1] http://bahir.apache.org/docs/flink/current/flink-streaming-redis/
> [2] https://github.com/apache/bahir-flink
>
> Best
> Yun Tang
>
>
> From: Yangze Guo
> Sent: Tuesday, July 21, 2020 18:50
> T
apache/bahir-flink
Best
Yun Tang
From: Yangze Guo
Sent: Tuesday, July 21, 2020 18:50
To: dev
Subject: Re: Flink Redis connectivity
Hi,
I think you could implement `RichMapFunction` and create `redisClient`
in the `open` method.
Best,
Yangze Guo
On Tue, Jul 21
Hi,
I think you could implement `RichMapFunction` and create `redisClient`
in the `open` method.
Best,
Yangze Guo
On Tue, Jul 21, 2020 at 6:43 PM Ramya Ramamurthy wrote:
>
> Hi,
>
> As per the understanding we have from the documentation, I guess its not
> possible to take the redis connection
Hi,
As per the understanding we have from the documentation, I guess its not
possible to take the redis connection within the Data Stream. In that case,
how should i proceed ? How can i access a DB client object within the
stream ??
I am using Flink 1.7. any help here would be appreciated.
