search

allwefantasy / spark-binlog

A library for querying Binlog with Apache Spark structure streaming, for Spark SQL , DataFrames and [MLSQL](https://www.mlsql.tech).
Apache License 2.0
154 stars 54 forks source link

[HBase] 关于解析数据的Bug #23

Closed xiazhuchang closed 4 years ago

xiazhuchang commented 4 years ago

解析后的数据，cf、col和value不正确，代码Bug，具体如下：

PutWriter->writeEvent

String f = Bytes.toString(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); String col = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()); String dataValue = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); jsonGenerator.writeObjectField(f + ":" + col, dataValue);