Spark scala Date Usage

2019-03-13 Thread anbu
Hi sir, Could you please help me to implement the below scenario using spark scala: how to convert the string date type to date type to check the agg_start_date is less than the data_date.I want to take 2019-01-09 data alone for my aggregations data_date:2019-01-10 (Currently it is the

Windowing LAG function Usage in Spark2.2 Dataset scala

2019-03-13 Thread anbu
Hi, To calculate LAG functions difference for the two data_date(current date and previous date) on the same column Could you please help me to implement the below scenario using scala spark Dataset. uniq_im - LAG(uniq_im,1,0) OVER PARTITION BY(name,sit,plc,country,state) order by (data_date) as

SUBSCRIBE

2019-03-13 Thread Anbazhagan Muthuramalingam

[no subject]

2019-03-13 Thread Anbazhagan Muthuramalingam
SUBSCRIBE

subscribe

2019-03-13 Thread Anbazhagan Muthuramalingam

subscribe

2019-03-13 Thread Anbazhagan Muthuramalingam
subscribe