java - MapToPair function in SPARK -
java - MapToPair function in SPARK -
i have file contining attribute :
id_client, date, time, url
and want calculate probability go url url b. want : first : find client journey. decided cut down key (id_cleint) wich should give me result : (client1, (date1,url1), (date2, url2),(date3, url3) ......(date n, url n )) (client2, (date5,url5), (date6, url6),(date7, url7) ......(date n, url n )) : key client1, , value string :(date1,url1), (date2, url2),(date3, url3) ......(date n, url n )
secondely : after, want create javapairrdd returns pair of url of clients, this (url1, url2) (url2, url3) (url3, url5) (url5, url6) (url6, url7) can please show me how pass first step second. give thanks in advance.
java apache-spark
Comments
Post a Comment