Como usar funções analíticas / de janela no Spark Java?

Estou tentando usar a função analítica / janela last_value no Spark Java. Consulta do Netezza: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 rows ...