如何通过happybase将rdd放入hbase表

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

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

  1. words = rdd.map(lambda line :line.split(" ")).collect()
  2. spark = getSparkSessionInstance(rdd.context.getConf())
  3. connection = happybase.Connection("master", port=9090)
  4. connection.open()
  5. print(connection.tables())
  6. table = connection.table('locdata')
  7. table.put(str(time),{'data:lat':str(words[0]),'data:lon':str(words[1])})

暂无答案!

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

相关问题