Hi Sagar,
have you had a look at CoProcessFunction [1]? CoProcessFunction enables you
to join two streams into one and also provide context to use SideOutput [2].
Best,
Matthias
[1]
https://github.com/apache/flink/blob/c6997c97c575d334679915c328792b8a3067cfb5/flink-streaming-java/src/main/java/or
Hi Team, any answer for my below question?
On Wed, Jan 20, 2021 at 9:20 PM sagar wrote:
> Hi Team,
>
>
> I am creating a flink job with DataStream API and batch mode.
>
> It is having 5 different bounded sources and I need to perform some
> business operations on it like joining , aggregating et
Hi Team,
I am creating a flink job with DataStream API and batch mode.
It is having 5 different bounded sources and I need to perform some
business operations on it like joining , aggregating etc.
I am using a CoGroup operator to join two streams as it serves as a left
join. So when keys are
