static public AResult resultToAResult(Result result) { AResult aresult = new AResult(); byte[] row = result.getRow(); aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]); Schema s = Schema.createArray(AResultEntry.SCHEMA$); GenericData.Array<AResultEntry> entries = null; List<KeyValue> resultKeyValues = result.list(); if (resultKeyValues != null && resultKeyValues.size() > 0) { entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s); for (KeyValue resultKeyValue : resultKeyValues) { AResultEntry entry = new AResultEntry(); entry.family = ByteBuffer.wrap(resultKeyValue.getFamily()); entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier()); entry.value = ByteBuffer.wrap(resultKeyValue.getValue()); entry.timestamp = resultKeyValue.getTimestamp(); entries.add(entry); } } else { entries = new GenericData.Array<AResultEntry>(0, s); } aresult.entries = entries; return aresult; }