scala插入hbase

kmbjn2e3 于 2021-06-09 发布在 Hbase

关注(0)|答案(1)|浏览(493)

我想使用scala将json对象插入hbase单元，目前我可以使用下面的代码插入值，但我想知道如何将整个json对象插入hbase单元。

import org.apache.hadoop.hbase.util.Bytes.toBytes
val hTable:HTable = new HTable(configuration, "tablename")
val p = new Put(Bytes.toBytes("row1"))
p.add(Bytes.toBytes("info"),Bytes.toBytes("firstname)",Bytes.toBytes("Jim"))
hTable.put(p)
hTable.close()

hbase scala JSON apache-spark

来源：https://stackoverflow.com/questions/53638809/insert-json-into-hbase-as-json-scala

1条答案

按热度按时间

2guxujil1#

可以将json对象编码为字符串。然后将这个字符串编码为字节数组。然后把这个字节数组放到hbase中。伪代码如下：

json = createYourJson()
jsonString = json.toString
jsonBytyes = Bytes.toBytes(jsonString)
put.add(yourColumnFamily, yourQualifier, jsonBytes)

当从hbase加载值时，必须反转此顺序。伪代码如下：

jsonBytes = hbase.get(table, columnFamily, qualifier)
jsonString = Bytes.toString(jsonBytes)
json = Json.parse(jsonString)

赞(0）回复(0）举报 2021-06-09

我来回答

scala插入hbase

1条答案

相关问题

热门标签

最新问答