2016-02-16 2 views
0

Я пытаюсь преобразовать RDD, у которого есть строковые списки строк (результат разбора CSV-файла) и RDD строк. Это значит, что я могу превратить его в фреймворк данных, потому что мне нужно его в dataframe для записи в паркет. Во всяком случае, единственной частью, с которой мне нужна помощь, является преобразование Rdd из списка строк в строку.RDD из списка String convert to Row

Имя переменной РДД является РДД

+3

А что вы пробовали до сих пор? – eliasah

+0

Ok Я преобразовал в строку Я использовал val RowRDD = RDD.map (r => Row.fromSeq (r)) –

+0

Это что-то меняет? –

ответ

3

Я использовал:

import org.apache.spark.sql._ 
val RowRDD = RDD.map(r => Row.fromSeq(r))