Sure, my pleasure!
Aljoscha
On 19.11.20 16:12, Simone Cavallarin wrote:
Many thanks for the Help!!
Simone
From: Aljoscha Krettek
Sent: 19 November 2020 11:46
To: user@flink.apache.org
Subject: Re: How to use EventTimeSessionWindows.withDynamicGap()
On
Many thanks for the Help!!
Simone
From: Aljoscha Krettek
Sent: 19 November 2020 11:46
To: user@flink.apache.org
Subject: Re: How to use EventTimeSessionWindows.withDynamicGap()
On 17.11.20 17:37, Simone Cavallarin wrote:
> Hi,
>
> I have been worki
On 17.11.20 17:37, Simone Cavallarin wrote:
Hi,
I have been working on the suggestion that you gave me, thanks! The first part is to add to the
message the gap. 1)I receive the event, 2)I take that event and I map it using
StatefulsessionCalculator, that is where I put together "The message",
be easier at
this point to just use a stateful ProcessFunction", you meant a completely
different approach, would be better?
many thanks for the help.
s
From: Aljoscha Krettek
Sent: 16 November 2020 16:22
To: user@flink.apache.org
Subject: Re: How to use Ev
(m.. okay now complitely lost...)
Thanks
s
From: Simone Cavallarin
Sent: 13 November 2020 16:55
To: Aljoscha Krettek
Cc: user
Subject: Re: How to use EventTimeSessionWindows.withDynamicGap()
+user@
From: Simone Cavallarin
Sent: 13 November 2020 16:4
back on point 1 and be used on the windowing
process)
* (m.. okay now complitely lost...)
Thanks
s
From: Simone Cavallarin
Sent: 13 November 2020 16:55
To: Aljoscha Krettek
Cc: user
Subject: Re: How to use EventTimeSessionWindows.
+user@
From: Simone Cavallarin
Sent: 13 November 2020 16:46
To: Aljoscha Krettek
Subject: Re: How to use EventTimeSessionWindows.withDynamicGap()
Hi Aljoscha,
When you said: You could use a stateful operation (like a ProcessFunction) to
put a dynamic &quo
Many thanks for the help!
Best
Simon
From: Aljoscha Krettek
Sent: 12 November 2020 16:34
To: user@flink.apache.org
Subject: Re: How to use EventTimeSessionWindows.withDynamicGap()
Hi,
I'm not sure that what you want is possible. You say you want more
windows
1 min?
Many thanks for the help!
Best
Simon
From: Aljoscha Krettek
Sent: 12 November 2020 16:34
To: user@flink.apache.org
Subject: Re: How to use EventTimeSessionWindows.withDynamicGap()
Hi,
I'm not sure that what you want is possible. You say you want mo
Hi,
I'm not sure that what you want is possible. You say you want more
windows when there are more events for a given time frame? That is when
the events are more dense in time?
Also, using the event timestamp as the gap doesn't look correct. The gap
basically specifies the timeout for a ses
Hi All,
I'm trying to use EventTimeSessionWindows.withDynamicGap in my application. I
have understood that the gap is computed dynamically by a function on each
element. What I should be able to obtain is a Flink application that can
automatically manage the windows based on the frequency of th
11 matches
Mail list logo
