Есть ли способ сравнить значение столбца следующей строки с текущей строкой в ​​наборе данных <Row>в Spark, используя Java - PullRequest
0 голосов
/ 10 октября 2019

Я пытаюсь преобразовать существующий набор данных со схемой, приведенной ниже, в новую схему, используя Java

текущая схема

 id roll_no student 
 1   1232    john 
 2   1234    anna 
 3   1233    mike
 4   1235    dave

должна преобразоваться в новую схему ниже на основеroll_no и добавьте столбец next_student, если roll_no находится рядом с текущим студентом

id roll_no student next_student 
1   1232    john     mike 
2   1234    anna     dave 
3   1233    mike     anna 
4   1235    dave     null

Есть ли способ сравнить значение столбца разных строк в наборе данных, чтобы сделать это. Буду признателен за любые решения этой проблемы.

В Scala и PySpark я вижу методы задержки и отведения объектов Window, но я хочу знать, есть ли способ в Java

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...