Flink event session window in Spark

[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, 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