Re: Re: Use Flink to process request with list of queries and aggregate

2021-01-15 Thread Arvid Heise
stream/operators/process_function.html#the-keyedprocessfunction > > -- > Sender:Li Wang > Date:2021/01/11 07:10:27 > Recipient: > Theme:Re: Use Flink to process request with list of queries and aggregate > > Can I get any suggestion? Thanks

Re: Re: Use Flink to process request with list of queries and aggregate

2021-01-11 Thread Yun Gao
:10:27 Recipient: Theme:Re: Use Flink to process request with list of queries and aggregate Can I get any suggestion? Thanks a lot. - Li -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Use Flink to process request with list of queries and aggregate

2021-01-10 Thread Li Wang
Can I get any suggestion? Thanks a lot. - Li -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Use Flink to process request with list of queries and aggregate

2021-01-08 Thread Li Wang
Hi Team, I have a Flink application reading from Kafka. Each payload is a request sent by a user containing a list of queries. What I would like to do is use Flink to process the queries parallelly and aggregate results and send back to the user. For example, let's say we have two messages in Kaf