FlatMap可遍历整数错误

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