spark-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fritz Budiyanto <fbudi...@icloud.com>
Subject Flink event session window in Spark
Date Fri, 02 Dec 2016 19:20:40 GMT
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