4445464748495051525354
} public Message getReply(Message originalMessage) throws IOException { DataOutputBuffer dob = new DataOutputBuffer(); dob.writeBoolean(rangeCompletedLocally); dob.writeInt(rows.size()); for (Row row : rows) { Row.serializer().serialize(row, dob); }
4041424344454647484950
} public Message getReply(Message originalMessage) throws IOException { DataOutputBuffer dob = new DataOutputBuffer(); dob.writeBoolean(rangeCompletedLocally); for (String key : keys) { dob.writeUTF(key); }
184185186187188189190191192193194
digest.update(value); DataOutputBuffer buffer = new DataOutputBuffer(); try { buffer.writeLong(timestamp); buffer.writeBoolean(isMarkedForDelete); } catch (IOException e) { throw new RuntimeException(e); }
181182183184185186187188189190191