如何通过happybase将rdd放入hbase表

e5nqia27  于 2021-06-09  发布在  Hbase
关注(0)|答案(0)|浏览(278)

我想把rdd(在我的代码中由“words”定义)值放入表列值中。我正在使用happybase连接。

words = rdd.map(lambda line :line.split(" ")).collect()
spark = getSparkSessionInstance(rdd.context.getConf())

connection = happybase.Connection("master", port=9090)
connection.open()
print(connection.tables())

table = connection.table('locdata')
table.put(str(time),{'data:lat':str(words[0]),'data:lon':str(words[1])})

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题