função da janela spark sql lag

Eu estou olhando para a função de slide da janela para um Spark DataFrame no Spark SQL, Scala.

Eu tenho um dataframe com colunas Col1, Col1, Col1, data.

Col1    Col2    Col3    date     volume new_col
                        201601  100.5   
                        201602  120.6   100.5
                        201603  450.2   120.6
                        201604  200.7   450.2
                        201605  121.4   200.7`

Agora, quero adicionar uma nova coluna com o nome (new_col) com uma linha deslizada para baixo, como mostrado acima.

Eu tentei abaixo opção para usar a função de janela.

val windSldBrdrxNrx_df = df.withColumn("Prev_brand_rx", lag("Prev_brand_rx",1))

Alguém por favor pode me ajudar a como fazer isso.

questionAnswers(2)

yourAnswerToTheQuestion