What is the case that you’re trying to implement? For joining two streams you can use a CoProcessFunction, i.e.
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. Best, Aljoscha > On 28. Jun 2017, at 04:53, yunfan123 <yunfanfight...@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.
