Custom Session Windowing in Spark using Scala/Python

Hi, I am new to Spark and looking for help regarding the session windowing in Spark. I want to create session windows on a user activity stream with a gap duration of `x` minutes and also have

[Spark Java] Longest Continuous Subsequence

Hi All, Any help in writing a code to find longest Continuous Subsequence between two columns Like :COL1:"sparkJava' col2:Java8 -->Result :Java Thanks in advance Regards Raviteja