Как найти разницу между двумя RDD, имеющими один и тот же ключ в искровом потоке - PullRequest
0 голосов
/ 10 сентября 2018

У меня есть два потока искровых данных, содержащих следующие значения

Запас Средняя цена открытия за последние 5 минут

(GOOGL, 1176.762) (ADBE, 261.621) (FB, 163.191) (MSFT, 108.518005)

и

Средняя цена закрытия биржи за последние 5 минут

(GOOGL, 1177.198) (ADBE, 261.65802) (FB, 163.224) (MSFT, 108.525)

Я хочу найти акцию, которая имеет максимальный прирост за этот период, для которого я должен вычесть среднюю цену открытия из средней цены закрытия, и результат должен быть примерно таким, как ниже

(GOOGL, 0,436)(ADBE, 0,03702) (FB, 0,033) (MSFT, 0,006995)

Может кто-нибудь сообщить мне, как это сделать?

...