@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { Version.Builder builder = Version.newBuilder(); ProtobufUtil.mergeFrom(builder, message); if (builder.hasRestVersion()) { restVersion = builder.getRestVersion(); } if (builder.hasJvmVersion()) { jvmVersion = builder.getJvmVersion(); } if (builder.hasOsVersion()) { osVersion = builder.getOsVersion(); } if (builder.hasServerVersion()) { serverVersion = builder.getServerVersion(); } if (builder.hasJerseyVersion()) { jerseyVersion = builder.getJerseyVersion(); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { CellSet.Builder builder = CellSet.newBuilder(); ProtobufUtil.mergeFrom(builder, message); for (CellSet.Row row: builder.getRowsList()) { RowModel rowModel = new RowModel(row.getKey().toByteArray()); for (Cell cell: row.getValuesList()) { long timestamp = HConstants.LATEST_TIMESTAMP; if (cell.hasTimestamp()) { timestamp = cell.getTimestamp(); } rowModel.addCell( new CellModel(cell.getColumn().toByteArray(), timestamp, cell.getData().toByteArray())); } addRow(rowModel); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { Version.Builder builder = Version.newBuilder(); builder.mergeFrom(message); if (builder.hasRestVersion()) { restVersion = builder.getRestVersion(); } if (builder.hasJvmVersion()) { jvmVersion = builder.getJvmVersion(); } if (builder.hasOsVersion()) { osVersion = builder.getOsVersion(); } if (builder.hasServerVersion()) { serverVersion = builder.getServerVersion(); } if (builder.hasJerseyVersion()) { jerseyVersion = builder.getJerseyVersion(); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { CellSet.Builder builder = CellSet.newBuilder(); builder.mergeFrom(message); for (CellSet.Row row: builder.getRowsList()) { RowModel rowModel = new RowModel(row.getKey().toByteArray()); for (Cell cell: row.getValuesList()) { long timestamp = HConstants.LATEST_TIMESTAMP; if (cell.hasTimestamp()) { timestamp = cell.getTimestamp(); } rowModel.addCell( new CellModel(cell.getColumn().toByteArray(), timestamp, cell.getData().toByteArray())); } addRow(rowModel); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { NamespaceProperties.Builder builder = NamespaceProperties.newBuilder(); builder.mergeFrom(message); List<NamespaceProperties.Property> properties = builder.getPropsList(); for(NamespaceProperties.Property property: properties){ addProperty(property.getKey(), property.getValue()); } return this; }
@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 ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { Namespaces.Builder builder = Namespaces.newBuilder(); builder.mergeFrom(message); namespaces = builder.getNamespaceList(); return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { Cell.Builder builder = Cell.newBuilder(); ProtobufUtil.mergeFrom(builder, message); setColumn(builder.getColumn().toByteArray()); setValue(builder.getData().toByteArray()); if (builder.hasTimestamp()) { setTimestamp(builder.getTimestamp()); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { TableList.Builder builder = TableList.newBuilder(); ProtobufUtil.mergeFrom(builder, message); for (String table: builder.getNameList()) { this.add(new TableModel(table)); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { // there is no standalone row protobuf message throw new UnsupportedOperationException( "no protobuf equivalent to RowModel"); }
@Override public long getSize(ProtobufMessageHandler m, Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType) { ByteArrayOutputStream baos = new ByteArrayOutputStream(); try { baos.write(m.createProtobufOutput()); } catch (IOException e) { return -1; } byte[] bytes = baos.toByteArray(); buffer.set(bytes); return bytes.length; }
public void writeTo(ProtobufMessageHandler m, Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType, MultivaluedMap<String, Object> httpHeaders, OutputStream entityStream) throws IOException, WebApplicationException { byte[] bytes = buffer.get(); entityStream.write(bytes); buffer.remove(); }
@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 ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { Scanner.Builder builder = Scanner.newBuilder(); builder.mergeFrom(message); if (builder.hasStartRow()) { startRow = builder.getStartRow().toByteArray(); } if (builder.hasEndRow()) { endRow = builder.getEndRow().toByteArray(); } for (ByteString column: builder.getColumnsList()) { addColumn(column.toByteArray()); } if (builder.hasBatch()) { batch = builder.getBatch(); } if (builder.hasStartTime()) { startTime = builder.getStartTime(); } if (builder.hasEndTime()) { endTime = builder.getEndTime(); } if (builder.hasMaxVersions()) { maxVersions = builder.getMaxVersions(); } if (builder.hasFilter()) { filter = builder.getFilter(); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { Cell.Builder builder = Cell.newBuilder(); builder.mergeFrom(message); setColumn(builder.getColumn().toByteArray()); setValue(builder.getData().toByteArray()); if (builder.hasTimestamp()) { setTimestamp(builder.getTimestamp()); } return this; }
@Override public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException { TableList.Builder builder = TableList.newBuilder(); builder.mergeFrom(message); for (String table: builder.getNameList()) { this.add(new TableModel(table)); } return this; }