Java 类org.apache.hadoop.hbase.rest.protobuf.generated.TableInfoMessage.TableInfo 实例源码

项目:ditb    文件:TableInfoModel.java   
@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();
}
项目: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;
}
项目:LCIndex-HBase-0.94.16    文件:TableInfoModel.java   
@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();
}
项目: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;
}
项目:HIndex    文件:TableInfoModel.java   
@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();
}
项目:HIndex    文件: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;
}
项目:IRIndex    文件:TableInfoModel.java   
@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();
}
项目:IRIndex    文件: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;
}
项目:hbase    文件:TableInfoModel.java   
@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();
}
项目:hbase    文件: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;
}
项目:RStore    文件:TableInfoModel.java   
@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();
}
项目:RStore    文件: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;
}
项目:PyroDB    文件:TableInfoModel.java   
@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();
}
项目:PyroDB    文件: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;
}
项目:c5    文件:TableInfoModel.java   
@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();
}
项目:c5    文件: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;
}
项目:HBase-Research    文件:TableInfoModel.java   
@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();
}
项目:HBase-Research    文件: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;
}
项目:hbase-0.94.8-qod    文件:TableInfoModel.java   
@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();
}
项目:hbase-0.94.8-qod    文件: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;
}
项目:hbase-0.94.8-qod    文件:TableInfoModel.java   
@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();
}
项目:hbase-0.94.8-qod    文件: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;
}
项目:DominoHBase    文件:TableInfoModel.java   
@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();
}
项目:DominoHBase    文件: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;
}
项目:hindex    文件:TableInfoModel.java   
@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();
}
项目:hindex    文件: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;
}