Hi,
This works for me
scala> val wSpec3 =
Window.partitionBy('priceInfo.getItem("ticker")).orderBy('priceInfo.getItem("timeissued").desc).rangeBetween(0,5)
wSpec3: org.apache.spark.sql.expressions.WindowSpec =
org.apache.spark.sql.expressions.WindowSpec@f308c09
HTH,
Is the date format correct.
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
