@Override public byte[] createProtobufOutput() { TableInfo.Builder builder = TableInfo.newBuilder(); builder.setName(name); for (TableRegionModel aRegion: regions) { TableInfo.Region.Builder regionBuilder = TableInfo.Region.newBuilder(); regionBuilder.setName(aRegion.getName()); regionBuilder.setId(aRegion.getId()); regionBuilder.setStartKey(ByteStringer.wrap(aRegion.getStartKey())); regionBuilder.setEndKey(ByteStringer.wrap(aRegion.getEndKey())); regionBuilder.setLocation(aRegion.getLocation()); builder.addRegions(regionBuilder); } return builder.build().toByteArray(); }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { TableInfo.Builder builder = TableInfo.newBuilder(); ProtobufUtil.mergeFrom(builder, message); setName(builder.getName()); for (TableInfo.Region region: builder.getRegionsList()) { add(new TableRegionModel(builder.getName(), region.getId(), region.getStartKey().toByteArray(), region.getEndKey().toByteArray(), region.getLocation())); } return this; }
@Override public byte[] createProtobufOutput() { TableInfo.Builder builder = TableInfo.newBuilder(); builder.setName(name); for (TableRegionModel aRegion: regions) { TableInfo.Region.Builder regionBuilder = TableInfo.Region.newBuilder(); regionBuilder.setName(aRegion.getName()); regionBuilder.setId(aRegion.getId()); regionBuilder.setStartKey(ByteString.copyFrom(aRegion.getStartKey())); regionBuilder.setEndKey(ByteString.copyFrom(aRegion.getEndKey())); regionBuilder.setLocation(aRegion.getLocation()); builder.addRegions(regionBuilder); } return builder.build().toByteArray(); }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { TableInfo.Builder builder = TableInfo.newBuilder(); builder.mergeFrom(message); setName(builder.getName()); for (TableInfo.Region region: builder.getRegionsList()) { add(new TableRegionModel(builder.getName(), region.getId(), region.getStartKey().toByteArray(), region.getEndKey().toByteArray(), region.getLocation())); } return this; }
@Override public byte[] createProtobufOutput() { TableInfo.Builder builder = TableInfo.newBuilder(); builder.setName(name); for (TableRegionModel aRegion: regions) { TableInfo.Region.Builder regionBuilder = TableInfo.Region.newBuilder(); regionBuilder.setName(aRegion.getName()); regionBuilder.setId(aRegion.getId()); regionBuilder.setStartKey(HBaseZeroCopyByteString.wrap(aRegion.getStartKey())); regionBuilder.setEndKey(HBaseZeroCopyByteString.wrap(aRegion.getEndKey())); regionBuilder.setLocation(aRegion.getLocation()); builder.addRegions(regionBuilder); } return builder.build().toByteArray(); }
@Override public byte[] createProtobufOutput() { TableInfo.Builder builder = TableInfo.newBuilder(); builder.setName(name); for (TableRegionModel aRegion: regions) { TableInfo.Region.Builder regionBuilder = TableInfo.Region.newBuilder(); regionBuilder.setName(aRegion.getName()); regionBuilder.setId(aRegion.getId()); regionBuilder.setStartKey(ZeroCopyLiteralByteString.wrap(aRegion.getStartKey())); regionBuilder.setEndKey(ZeroCopyLiteralByteString.wrap(aRegion.getEndKey())); regionBuilder.setLocation(aRegion.getLocation()); builder.addRegions(regionBuilder); } return builder.build().toByteArray(); }