in hbase-endpoint/src/main/java/com/amazonaws/hbase/serde/HBaseWALKeyDeserializer.java [37:74]
public HBaseWALKey deserialize(JsonParser p, DeserializationContext ctxt)
throws IOException, JsonProcessingException {
ObjectMapper objectMapper = new ObjectMapper();
HBaseWALKey res = new HBaseWALKey();
Long writeTime;
Long sequenceId;
String tablename;
Long nonce;
Long nonceGroup;
Long origLogSeqNum;
byte[] encodedRegionName;
MVCCWALEntry writeEntry;
JsonNode jsonNode = p.getCodec().readTree(p);
encodedRegionName = jsonNode.get("encodedRegionName").binaryValue();
nonce = jsonNode.get("nonce").asLong();
nonceGroup =jsonNode.get("nonceGroup").asLong();
writeTime = jsonNode.get("writeTime").asLong();
sequenceId = jsonNode.get("sequenceId").asLong();
tablename = jsonNode.get("tablename").asText();
writeEntry = objectMapper.readValue(jsonNode.get("writeEntry").asText(), MVCCWALEntry.class);
origLogSeqNum = jsonNode.get("origLogSeqNum").asLong();
res.setEncodedRegionName(encodedRegionName);
res.setNonce(nonce);
res.setNonceGroup(nonceGroup);
res.setOrigLogSeqNum(origLogSeqNum);
res.setSequenceId(sequenceId);
res.setTableName(tablename);
res.setWriteEntry(writeEntry);
res.setWriteTime(writeTime);
return res;
}