Hi all

This is the sample set of data that I used for this task

,[image: image.png]

My need is to pass count as the offset of lag() function. *[ lag(col(),
lag(count)).over(windowspec) ]* But as the lag function expects lag(Column,
Int) above code does not work.

So can you guys suggest a method to achieve this scenario. I am using spark
3.3.0 with scala


<https://www.avast.com/sig-email?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=webmail>
Virus-free.www.avast.com
<https://www.avast.com/sig-email?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=webmail>
<#DAB4FAD8-2DD7-40BB-A1B8-4E2AA1F9FDF2>

Reply via email to