Вставьте Json в Hbase как JSON - Scala - PullRequest
0 голосов
/ 05 декабря 2018

Я хотел бы вставить объект json в scala с использованием ячейки 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()

1 Ответ

0 голосов
/ 05 декабря 2018

Вы можете закодировать ваш объект 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)
...