как сделать зацикливание и вычисление, чтобы найти расстояние нескольких поездок в фрейме Spark Scala - PullRequest
0 голосов
/ 10 октября 2018

мой фрейм данных выглядит следующим образом enter image description here

здесь, что я хочу

  1. всякий раз, когда первое вхождение значения в столбце - "location2_distance_from_lat_long"<= 1,0 км, </li>

он начнет вычислять расстояние / (получить значение метки времени), пока не достигнет первого вхождения значения в другом столбце, то есть «location2_distance_from_lat_long», который равен <= 100 * 1012.* <p>Аналогичным образом цикл продолжается для второго вхождения

Например, при отметке времени 1529321201000 значение столбца location2_distance_frm_lat_long равно 1 км, поэтому начнется расчет отключения.и предположим, что при отметке времени 155352242000 в другом столбце «location1_distance_frm_lat_long» значение также достигает 1 км, а затем до этой точки необходимо извлечь все записи и вычислить расстояние.и снова следующая поездка начнется после этой отметки времени.

  code

введите описание изображения здесь

enter image description here

enter image description here

enter image description here

выше, если как написать цикл для случаев, когда расстояние достигает <=. 100 км </p>

...