Hi,

I am trying to use range between window function but i am keep on getting
below error

main" org.apache.spark.sql.AnalysisException: Window Frame
specifiedwindowframe(RangeFrame, currentrow$(), 5) must match the required
frame specified

I need to check next consecutive 5 seconds interval records. Below is my
window definition

val window = Window.orderBy("date").rangeBetween(0,5)

Request to help if i am missing some thing here.


Regards,

Kumar

Reply via email to