public HBaseWALEdit deserialize()

in hbase-endpoint/src/main/java/com/amazonaws/hbase/serde/HBaseWALEditDeserializer.java [39:79]

32 lines of code
5 McCabe index (conditional complexity)


	public HBaseWALEdit<HBaseWALEdit> deserialize(JsonParser p, DeserializationContext ctxt) throws IOException, JsonProcessingException {
		ArrayList<HBaseCell> cells = new ArrayList<HBaseCell>();
		Set<byte[]> families = new HashSet<byte[]>();
		byte[] METAFAMILY;
		boolean replay;
		
		JsonNode jsonNode = p.getCodec().readTree(p);
		
		final JsonNode cellsNode = jsonNode.get("cells");
		if (cellsNode.isArray()) {
		    for (final JsonNode objNode : cellsNode) {
		    	        cells.add(p.getCodec().treeToValue(objNode, HBaseCell.class));
		    }
		}
		
		
		final JsonNode familiesNode = jsonNode.get("families");
		if (familiesNode.isArray()) {
			familiesNode.elements().forEachRemaining((JsonNode node) -> {
				try {
					families.add(node.binaryValue());
				} catch (IOException e) {
					LOG.warn("Unable to deserialize all the family names from array.",e);
					e.printStackTrace();
				}
			});					

		}
		
		METAFAMILY=jsonNode.get("metafamily").binaryValue();
		
		replay = jsonNode.get("replay").asBoolean();
		
		HBaseWALEdit<HBaseWALEdit> hBaseEdit = new HBaseWALEdit<HBaseWALEdit>();
		hBaseEdit.setCells(cells);
		hBaseEdit.setFamilies(families);
		hBaseEdit.setMETAFAMILY(METAFAMILY);
		hBaseEdit.setReplay(replay);
		
		return hBaseEdit;
	}