Re: Flink event session window in Spark

2016-12-02 Thread Miguel Morales
Fri, Dec 2, 2016 at 12:13 PM, Michael Armbrust wrote: > 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 > wrote: >> >> Hi All, >> >> I need help on how to

Re: Flink event session window in Spark

2016-12-02 Thread Michael Armbrust
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 wrote: > Hi All, > > I need help on how to implement Flink event session window in Spark. Is > this possible? > > For instance, I

Flink event session window in Spark

2016-12-02 Thread Fritz Budiyanto
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