I think this is also related to my question about CEP in Statefun.
@Annemarie Burger <annemarie.bur...@campus.tu-berlin.de> , I was looking
into using Siddhi library within the Function's context.
--
[image: MotaWord]
Oytun Tez
M O T A W O R D | CTO & Co-Founder
oy...@motaword.com
<https://www.motaword.com/blog>
On Wed, May 6, 2020 at 4:13 PM Annemarie Burger <
annemarie.bur...@campus.tu-berlin.de> wrote:
> Hi,
>
> I want to do windowed processing in each function when using Stateful
> Functions. Is this possible? Some pseudo code would be very helpful!
>
> Some more context: I'm having a stream of edges as input. I want to window
> these and save the graph representation (either as edge list, adjacency
> list, or CSR) in a distributed way using state. Since doing this for the
> entire edge stream would cost far too much memory, I want to only save the
> state of the graph within the window. How could I achieve this?
>
> Thanks!
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>
