FlatMap проходимой Ones ошибок

Question

У меня есть этот код ниже:

//TABLE FROM HIve 
val df = hiveContext.sql("select * from test_table where date ='20160721' LIMIT 300") 
//ERROR ON THE LINE BELOW 
val row = df.flatMap(row => ((row.get(0), row.get(1), row.get(2)), 1)) 

я получаю эту ошибку в коде, гласящая:

Type mismatch, expected: (Row) => Traversable[NotInferedU], actual : (Row) => ((Any, Any, Any), Int) 

Может кто-то проверить, чтобы посмотреть, что случилось в моей функции flatMap. Я не могу понять, что говорит эта ошибка.

Answer 1

Вы, вероятно, должны использовать вместо этого map. ((row.get(0), row.get(1), row.get(2)), 1) не является Traversable, как указано в сообщении об ошибке.