Hi Sudan,
it seems to be unsupported directly.
You can have a hacky workaround by replicating apply[1] in your code and
adjust the last line to call your CoGroupWindowFunction.
[1]
https://github.com/apache/flink/blob/aedb4068408cfcad6f258526b00fcbff7f40fb82/flink-streaming-java/src/main/java/or
object you
can fetch the information of window, start time, end time etc.
From: Jaswin Shah
Sent: 04 June 2020 13:45
To: Dawid Wysakowicz ; user@flink.apache.org
Cc: Aljoscha Krettek
Subject: Re: Getting Window information from coGroup functin
I think here apply
information from coGroup functin
I am afraid there is no way to do that. At least I could not think of a way to
do it.
Maybe @aljoscha cc'ed could help here.
On 29/05/2020 13:25, Sudan S wrote:
Hi,
I have a usecase where i want to join two streams. I am using coGroup for this
KeyBuilder leftKey
I am afraid there is no way to do that. At least I could not think of a
way to do it.
Maybe @aljoscha cc'ed could help here.
On 29/05/2020 13:25, Sudan S wrote:
> Hi,
>
> I have a usecase where i want to join two streams. I am using coGroup
> for this
>
> KeyBuilder leftKey = new
> KeyBuilder(job
Hi,
I have a usecase where i want to join two streams. I am using coGroup for
this
KeyBuilder leftKey = new
KeyBuilder(jobConfiguration.getConnectStream().getLeftKey());
KeyBuilder rightKey = new
KeyBuilder(jobConfiguration.getConnectStream().getRightKey());
leftSource.coGroup(rightSource).where(
