public HBaseWALKey deserialize()

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;
	}