инкрементное обновление с использованием spark sql с последней датой - PullRequest
0 голосов
/ 21 ноября 2018

ID транзакции | Сумма | Дата | КОММЕНТАРИЙ

1 | 200 | 14/11/18 | Доставлено

2 | 300 | 14/11/18 | В ожидании

3 | 500 | 14/11/18 | Отклонено

Идентификатор транзакции | Сумма | Дата | КОММЕНТАРИЙ

1 | 200 | 15/11/18 | Доставлено

2| 300 | 15/11/18 | Ожидание

4 | 500 | 15/11/18 | Отклонено

вывод должен быть таблицей, которая содержит последние данные для всех идентификаторов транзакций (например,-для идентификатора транзакции 1 должны быть от 15/11/2018, а не данные от 14/11/2018

идентификатор транзакции | сумма | дата | КОММЕНТАРИЙ

1 | 200 | 15 /11/18 | Доставлено

2 | 300 | 15/11/18 | Ожидается

3 | 500 | 14/11/18 | Отклонено

4 | 500 | 15/ 11/18 | Отклонено

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