我想把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])})
暂无答案!
目前还没有任何答案,快来回答吧!