flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: How to perform multiple stream join functionality
Date Thu, 29 Jun 2017 15:36:51 GMT
What is the case that you’re trying to implement? For joining two streams you can use a CoProcessFunction,

stream1.connect(stream2).process(new MyCoProcessFunction())

For more than one streams you can tag each of the incoming streams with a tag that specifies
the stream that they’re coming from. Then union them and process in a single ProcessFunction
and tweeze the elements from the different streams apart based on their tag.

In both cases you would keep the data for joining within Flink state.


> On 28. Jun 2017, at 04:53, yunfan123 <yunfanfighting@foxmail.com> wrote:
> Flink 1.3? I'm use flink 1.3, how can I do to implement this?
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-perform-multiple-stream-join-functionality-tp7184p14031.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

View raw message