Преобразование типов данных в Hbase - PullRequest
Новая
       24

Преобразование типов данных в Hbase

0 голосов
/ 03 сентября 2018

A с использованием коннектора Hbase StreamReactor Kafka с этой конфигурацией 

name=person-hbase 
connector.class=com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector 
tasks.max=1 
topics=hbase-topic
connect.hbase.column.family=d
connect.hbase.kcql=INSERT INTO person SELECT * FROM hbase-topic PK firstName, lastName

Почему значения, отправленные из Kafka в HBase, представлены таким образом? value=@\xB56\x00\x00\x00\x00\x00

Как изменить его на обычный читаемый способ? 

hbase(main):004:0* scan 'person'
ROW                                                  COLUMN+CELL
 Anna\x0AJones                                       column=d:age, timestamp=1463056888641, value=\x00\x00\x00\x1C
 Anna\x0AJones                                       column=d:firstName, timestamp=1463056888641, value=Anna
 Anna\x0AJones                                       column=d:income, timestamp=1463056888641, value=@\xB56\x00\x00\x00\x00\x00
 Anna\x0AJones                                       column=d:lastName, timestamp=1463056888641, value=Jones
 John\x0ASmith                                       column=d:age, timestamp=1463056693877, value=\x00\x00\x00\x1E
 John\x0ASmith                                       column=d:firstName, timestamp=1463056693877, value=John
 John\x0ASmith                                       column=d:income, timestamp=1463056693877, value=@\xB2\xDE\x00\x00\x00\x00\x00
 John\x0ASmith                                       column=d:lastName, timestamp=1463056693877, value=Smith
2 row(s) in 0.0260 seconds
...