spark-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Michael Armbrust <mich...@databricks.com>
Subject Re: Flink event session window in Spark
Date Fri, 02 Dec 2016 20:13:15 GMT
Here is the JIRA for adding this feature:
https://issues.apache.org/jira/browse/SPARK-10816

On Fri, Dec 2, 2016 at 11:20 AM, Fritz Budiyanto <fbudiyan@icloud.com>
wrote:

> Hi All,
>
> I need help on how to implement Flink event session window in Spark. Is
> this possible?
>
> For instance, I wanted to create a session window with a timeout of 10
> minutes (see Flink snippet below)
> Continues event will make the session window alive. If there are no
> activity for 10 minutes, the session window shall close and forward the
> data to a sink function.
>
> // event-time session windows
> input
>
>     .keyBy(<key selector>)
>
>     .window(EventTimeSessionWindows.withGap(Time.minutes(10)))
>
>     .<windowed transformation>(<window function>);
>
>
>
>
> Any idea ?
>
> Thanks,
> Fritz
>

Mime
View raw message