1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.rest.protobuf.generated.CellSetMessage.CellSet

Java 类org.apache.hadoop.hbase.rest.protobuf.generated.CellSetMessage.CellSet 实例源码

项目：ditb    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteStringer.wrap(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteStringer.wrap(cell.getColumn()));
      cellBuilder.setData(ByteStringer.wrap(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(HBaseZeroCopyByteString.wrap(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(HBaseZeroCopyByteString.wrap(cell.getColumn()));
      cellBuilder.setData(HBaseZeroCopyByteString.wrap(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteStringer.wrap(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteStringer.wrap(cell.getColumn()));
      cellBuilder.setData(ByteStringer.wrap(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(HBaseZeroCopyByteString.wrap(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(HBaseZeroCopyByteString.wrap(cell.getColumn()));
      cellBuilder.setData(HBaseZeroCopyByteString.wrap(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ZeroCopyLiteralByteString.wrap(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ZeroCopyLiteralByteString.wrap(cell.getColumn()));
      cellBuilder.setData(ZeroCopyLiteralByteString.wrap(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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    文件：CellSetModel.java    
@Override
public byte[] createProtobufOutput() {
  CellSet.Builder builder = CellSet.newBuilder();
  for (RowModel row: getRows()) {
    CellSet.Row.Builder rowBuilder = CellSet.Row.newBuilder();
    rowBuilder.setKey(ByteString.copyFrom(row.getKey()));
    for (CellModel cell: row.getCells()) {
      Cell.Builder cellBuilder = Cell.newBuilder();
      cellBuilder.setColumn(ByteString.copyFrom(cell.getColumn()));
      cellBuilder.setData(ByteString.copyFrom(cell.getValue()));
      if (cell.hasUserTimestamp()) {
        cellBuilder.setTimestamp(cell.getTimestamp());
      }
      rowBuilder.addValues(cellBuilder);
    }
    builder.addRows(rowBuilder);
  }
  return builder.build().toByteArray();
}
项目：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;
}