我一直在尝试使用hbase客户端库将记录列表插入hbase。它适用于表或htable(已弃用)中的单个put,但不识别list(put)错误:应为:util.list,但为list
无法理解此错误的含义。尝试转换为javalist,但没有成功。
任何快速的建议都会更高`
val quoteRecords = new ListBuffer[Put]()
val listQuotes = lines.foreachRDD(rdd => {
rdd.foreach(record => addPutToList(buildPut(record)))
})
table.put(quoteRecords.toList)
quoteRecords.foreach(table.put)
println(listQuotes)
`
1条答案
按热度按时间uqdfh47h1#
listQuotes.toList
返回一种scala.List
. 你必须把它转换成java.util.List
类型。这个软件线程将给你一些见解。