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]
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 = new
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
>
