Re: Flink join with external source

2015-09-05 Thread Aljoscha Krettek
Hi Jerry, it should be possible to just use the Redis API inside a Flink operator, for example a map or flatMap. You can use RichFunctions ( https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming_guide.html#rich-functions) to setup the connection and close it after computation finish

Flink join with external source

2015-09-04 Thread Jerry Peng
Hello, Does a flink currently support operators to use redis? If I using the streaming api in Flink and I need to look up something in a redis database during the processing of the stream how can I do that?