1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.rest.ProtobufMessageHandler

Java 类org.apache.hadoop.hbase.rest.ProtobufMessageHandler 实例源码

项目：ditb    文件：VersionModel.java    
@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;
}
项目：ditb    文件：CellSetModel.java    
@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;
}
项目：LCIndex-HBase-0.94.16    文件：VersionModel.java    
@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;
}
项目：LCIndex-HBase-0.94.16    文件：CellSetModel.java    
@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;
}
项目：HIndex    文件：VersionModel.java    
@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;
}
项目：HIndex    文件：CellSetModel.java    
@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;
}
项目：IRIndex    文件：VersionModel.java    
@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;
}
项目：IRIndex    文件：CellSetModel.java    
@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;
}
项目：hbase    文件：VersionModel.java    
@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;
}
项目：hbase    文件：CellSetModel.java    
@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;
}
项目：RStore    文件：VersionModel.java    
@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;
}
项目：RStore    文件：CellSetModel.java    
@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;
}
项目：PyroDB    文件：VersionModel.java    
@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;
}
项目：PyroDB    文件：CellSetModel.java    
@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;
}
项目：c5    文件：VersionModel.java    
@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;
}
项目：c5    文件：CellSetModel.java    
@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;
}
项目：HBase-Research    文件：VersionModel.java    
@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;
}
项目：HBase-Research    文件：CellSetModel.java    
@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;
}
项目：hbase-0.94.8-qod    文件：VersionModel.java    
@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;
}
项目：hbase-0.94.8-qod    文件：CellSetModel.java    
@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;
}
项目：hbase-0.94.8-qod    文件：VersionModel.java    
@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;
}
项目：hbase-0.94.8-qod    文件：CellSetModel.java    
@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;
}
项目：DominoHBase    文件：VersionModel.java    
@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;
}
项目：DominoHBase    文件：CellSetModel.java    
@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;
}
项目：hindex    文件：VersionModel.java    
@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;
}
项目：hindex    文件：CellSetModel.java    
@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;
}
项目：ditb    文件：NamespacesInstanceModel.java    
@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;
}
项目：ditb    文件：TableInfoModel.java    
@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;
}
项目：ditb    文件：NamespacesModel.java    
@Override
public ProtobufMessageHandler getObjectFromMessage(byte[] message) throws IOException {
  Namespaces.Builder builder = Namespaces.newBuilder();
  builder.mergeFrom(message);
  namespaces = builder.getNamespaceList();
  return this;
}
项目：ditb    文件：CellModel.java    
@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;
}
项目：ditb    文件：TableListModel.java    
@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;
}
项目：ditb    文件：RowModel.java    
@Override
public ProtobufMessageHandler getObjectFromMessage(byte[] message)
    throws IOException {
  // there is no standalone row protobuf message
  throw new UnsupportedOperationException(
      "no protobuf equivalent to RowModel");
}
项目：ditb    文件：ProtobufMessageBodyProducer.java    
@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;
}
项目：ditb    文件：ProtobufMessageBodyProducer.java    
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();
}
项目：LCIndex-HBase-0.94.16    文件：TableInfoModel.java    
@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;
}
项目：LCIndex-HBase-0.94.16    文件：ScannerModel.java    
@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;
}
项目：LCIndex-HBase-0.94.16    文件：CellModel.java    
@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;
}
项目：LCIndex-HBase-0.94.16    文件：TableListModel.java    
@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;
}
项目：LCIndex-HBase-0.94.16    文件：RowModel.java    
@Override
public ProtobufMessageHandler getObjectFromMessage(byte[] message)
    throws IOException {
  // there is no standalone row protobuf message
  throw new UnsupportedOperationException(
      "no protobuf equivalent to RowModel");
}
项目：LCIndex-HBase-0.94.16    文件：ProtobufMessageBodyProducer.java    
@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;
}