как поместить RDD в таблицу Hbase от Happybase - PullRequest
0 голосов
/ 17 декабря 2018

Я хочу поместить значение RDD (определяемое словами в моем коде) в значение столбца таблицы.Я использую соединение 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])})
...