Wie verwende ich Analytic / Window-Funktionen in Spark Java?

Ich versuche, die Analyse- / Fensterfunktion last_value in Spark Java zu verwenden. Netezza Query:select sno, name, addr1, addr2, run_dt, last_value(addr1 ignore nulls) over (partition by sno, name, addr1, addr2, run_dt order by beg_ts , end_ts ...