Как лучше всего преобразовать PairRDD в RDD с объединением K и V (в java)? Например, PairRDD содержит K как некоторую строку и V как JSON. Я хочу добавить этот K к значению JSON и создать RDD. Входная параRDD ("abc", {"x:"100",...

JavaPairRdd имеет функцию saveAsTextfile , с помощью которой вы можете сохранять данные в текстовом формате. Однако мне нужно сохранить данные в виде файла CSV, чтобы я мог использовать его позже с Neo4j. Мой вопрос: Как сохранить данные...

Итак, я новичок в Scala и только начинаю работать с RDD и функциональными операциями Scala. Я пытаюсь перебрать значения моих парных RDD и вернуть Var1 со средним значением значений, хранящихся в Var2 , применяя определенную функцию average ,...