Thanks Fabian for the explanation. Let me do some more reading so what you said
can sync-in little more.
From: Fabian Hueske
Date: Monday, February 4, 2019 at 10:22 AM
To: "Aggarwal, Ajay"
Cc: Congxian Qiu , "user@flink.apache.org"
Subject: Re: Reverse of KeyBy
Hi,
Subp
bove
> will automatically join the partitioned sub-streams from first KeyBy into a
> single stream?
>
>
>
> Ajay
>
>
>
>
>
> *From: *Fabian Hueske
> *Date: *Monday, February 4, 2019 at 9:17 AM
> *To: *"Aggarwal, Ajay"
> *Cc: *Congxian Qiu , &quo
rst KeyBy into a single
stream?
Ajay
From: Fabian Hueske
Date: Monday, February 4, 2019 at 9:17 AM
To: "Aggarwal, Ajay"
Cc: Congxian Qiu , "user@flink.apache.org"
Subject: Re: Reverse of KeyBy
Hi,
Calling keyBy twice will not work, because the second call overrides the fi
;
>
> *From: *Congxian Qiu
> *Date: *Sunday, February 3, 2019 at 6:40 AM
> *To: *"Aggarwal, Ajay"
> *Cc: *"user@flink.apache.org"
> *Subject: *Re: Reverse of KeyBy
>
> Hi Aggarwal
>How about keyBy(LargeMessageID) first, then assemble these f
, 2019 at 6:40 AM
To: "Aggarwal, Ajay"
Cc: "user@flink.apache.org"
Subject: Re: Reverse of KeyBy
Hi Aggarwal
How about keyBy(LargeMessageID) first, then assemble these fragments back
into LargeMessages, then keyBy(MeyKey)?
Best,
Congxian
Aggarwal, Ajay mailto:ajay.aggar...@ne
Hi Aggarwal How about keyBy(LargeMessageID) first, then assemble these
fragments back into LargeMessages, then keyBy(MeyKey)?
Best,
Congxian
Aggarwal, Ajay 于2019年2月2日周六 上午5:42写道：
> I am new to Flink. I am trying to figure out if there is an operator that
> provides reverse functionality of K
I am new to Flink. I am trying to figure out if there is an operator that
provides reverse functionality of KeyBy. Using KeyBy you can split a stream
into disjoint partitions. Is there a way to bring those partitions back into a
single stream?
Let me explain using my use case below.
My In
