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

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

项目：ditb    文件：RemoteHTable.java    
protected Result[] buildResultFromModel(final CellSetModel model) {
  List<Result> results = new ArrayList<Result>();
  for (RowModel row: model.getRows()) {
    List<Cell> kvs = new ArrayList<Cell>();
    for (CellModel cell: row.getCells()) {
      byte[][] split = KeyValue.parseColumn(cell.getColumn());
      byte[] column = split[0];
      byte[] qualifier = null;
      if (split.length == 1) {
        qualifier = HConstants.EMPTY_BYTE_ARRAY;
      } else if (split.length == 2) {
        qualifier = split[1];
      } else {
        throw new IllegalArgumentException("Invalid familyAndQualifier provided.");
      }
      kvs.add(new KeyValue(row.getKey(), column, qualifier,
        cell.getTimestamp(), cell.getValue()));
    }
    results.add(Result.create(kvs));
  }
  return results.toArray(new Result[results.size()]);
}
项目：ditb    文件：TestScannerResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    CellModel.class,
    CellSetModel.class,
    RowModel.class,
    ScannerModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  Admin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TABLE);
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
  expectedRows1 = insertData(TEST_UTIL.getConfiguration(), TABLE, COLUMN_1, 1.0);
  expectedRows2 = insertData(TEST_UTIL.getConfiguration(), TABLE, COLUMN_2, 0.5);
}
项目：ditb    文件：TestMultiRowResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  context = JAXBContext.newInstance(
          CellModel.class,
          CellSetModel.class,
          RowModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  client = new Client(new Cluster().add("localhost", REST_TEST_UTIL.getServletPort()));
  Admin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TABLE);
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
}
项目：ditb    文件：TestGetAndPutResource.java    
@Test
public void testInvalidCheckParam() throws IOException, JAXBException {
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(COLUMN_1),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + COLUMN_1 + "?check=blah";

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(response.getCode(), 400);
}
项目：ditb    文件：TestGetAndPutResource.java    
@Test
public void testInvalidColumnPut() throws IOException, JAXBException {
  String dummyColumn = "doesnot:exist";
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(dummyColumn),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + dummyColumn;

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(response.getCode(), 404);
}
项目：ditb    文件：RowResourceBase.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster(3);
  REST_TEST_UTIL.startServletContainer(conf);
  context = JAXBContext.newInstance(
      CellModel.class,
      CellSetModel.class,
      RowModel.class);
  xmlMarshaller = context.createMarshaller();
  xmlUnmarshaller = context.createUnmarshaller();
  jsonMapper = new JacksonProvider()
  .locateMapper(CellSetModel.class, MediaType.APPLICATION_JSON_TYPE);
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
}
项目：ditb    文件：RowResourceBase.java    
protected static Response checkAndPutValuePB(String url, String table,
    String row, String column, String valueToCheck, String valueToPut, HashMap<String,String> otherCells)
      throws IOException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));

  if(otherCells != null) {
    for (Map.Entry<String,String> entry :otherCells.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }

  // This Cell need to be added as last cell.
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));

  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  Response response = client.put(url, Constants.MIMETYPE_PROTOBUF,
    cellSetModel.createProtobufOutput());
  Thread.yield();
  return response;
}
项目：ditb    文件：RowResourceBase.java    
protected static Response checkAndPutValueXML(String url, String table,
    String row, String column, String valueToCheck, String valueToPut, HashMap<String,String> otherCells)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));

  if(otherCells != null) {
    for (Map.Entry<String,String> entry :otherCells.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }

  // This Cell need to be added as last cell.
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：ditb    文件：RowResourceBase.java    
protected static Response checkAndDeleteXML(String url, String table,
    String row, String column, String valueToCheck, HashMap<String,String> cellsToDelete)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);

  if(cellsToDelete != null) {
    for (Map.Entry<String,String> entry :cellsToDelete.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }
  // Add this at the end
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：ditb    文件：RowResourceBase.java    
protected static Response checkAndDeleteJson(String url, String table,
    String row, String column, String valueToCheck, HashMap<String,String> cellsToDelete)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);

  if(cellsToDelete != null) {
    for (Map.Entry<String,String> entry :cellsToDelete.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }
  // Add this at the end
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  String jsonString = jsonMapper.writeValueAsString(cellSetModel);
  Response response = client.put(url, Constants.MIMETYPE_JSON,
    Bytes.toBytes(jsonString));
  Thread.yield();
  return response;
}
项目：ditb    文件：RowResourceBase.java    
protected static Response checkAndDeleteValuePB(String url, String table,
    String row, String column, String valueToCheck, HashMap<String,String> cellsToDelete)
    throws IOException {
  RowModel rowModel = new RowModel(row);

  if(cellsToDelete != null) {
    for (Map.Entry<String,String> entry :cellsToDelete.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }
  // Add this at the end
  rowModel.addCell(new CellModel(Bytes.toBytes(column), Bytes
      .toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  Response response = client.put(url, Constants.MIMETYPE_PROTOBUF,
      cellSetModel.createProtobufOutput());
  Thread.yield();
  return response;
}
项目：LCIndex-HBase-0.94.16    文件：TestScannerResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    CellModel.class,
    CellSetModel.class,
    RowModel.class,
    ScannerModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TABLE);
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
  expectedRows1 = insertData(TABLE, COLUMN_1, 1.0);
  expectedRows2 = insertData(TABLE, COLUMN_2, 0.5);
}
项目：LCIndex-HBase-0.94.16    文件：TestMultiRowResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  context = JAXBContext.newInstance(
          CellModel.class,
          CellSetModel.class,
          RowModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  client = new Client(new Cluster().add("localhost", REST_TEST_UTIL.getServletPort()));
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TABLE);
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
}
项目：LCIndex-HBase-0.94.16    文件：TestRowResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster(3);
  REST_TEST_UTIL.startServletContainer(conf);
  context = JAXBContext.newInstance(
      CellModel.class,
      CellSetModel.class,
      RowModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  client = new Client(new Cluster().add("localhost", 
    REST_TEST_UTIL.getServletPort()));
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TABLE);
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
}
项目：LCIndex-HBase-0.94.16    文件：TestRowResource.java    
private static Response checkAndPutValueXML(String url, String table,
    String row, String column, String valueToCheck, String valueToPut)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  marshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：LCIndex-HBase-0.94.16    文件：TestRowResource.java    
@Test
public void testInvalidCheckParam() throws IOException, JAXBException {
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(COLUMN_1),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  marshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + COLUMN_1 + "?check=blah";

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(response.getCode(), 400);
}
项目：HIndex    文件：RemoteHTable.java    
protected Result[] buildResultFromModel(final CellSetModel model) {
  List<Result> results = new ArrayList<Result>();
  for (RowModel row: model.getRows()) {
    List<Cell> kvs = new ArrayList<Cell>();
    for (CellModel cell: row.getCells()) {
      byte[][] split = KeyValue.parseColumn(cell.getColumn());
      byte[] column = split[0];
      byte[] qualifier = null;
      if (split.length == 1) {
        qualifier = HConstants.EMPTY_BYTE_ARRAY;
      } else if (split.length == 2) {
        qualifier = split[1];
      } else {
        throw new IllegalArgumentException("Invalid familyAndQualifier provided.");
      }
      kvs.add(new KeyValue(row.getKey(), column, qualifier,
        cell.getTimestamp(), cell.getValue()));
    }
    results.add(Result.create(kvs));
  }
  return results.toArray(new Result[results.size()]);
}
项目：HIndex    文件：TestScannerResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    CellModel.class,
    CellSetModel.class,
    RowModel.class,
    ScannerModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(TABLE));
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
  expectedRows1 = insertData(TEST_UTIL.getConfiguration(), TABLE, COLUMN_1, 1.0);
  expectedRows2 = insertData(TEST_UTIL.getConfiguration(), TABLE, COLUMN_2, 0.5);
}
项目：HIndex    文件：TestMultiRowResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  context = JAXBContext.newInstance(
          CellModel.class,
          CellSetModel.class,
          RowModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  client = new Client(new Cluster().add("localhost", REST_TEST_UTIL.getServletPort()));
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(TABLE));
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
}
项目：HIndex    文件：TestGetAndPutResource.java    
@Test
public void testInvalidCheckParam() throws IOException, JAXBException {
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(COLUMN_1),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + COLUMN_1 + "?check=blah";

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(response.getCode(), 400);
}
项目：HIndex    文件：TestGetAndPutResource.java    
@Test
public void testInvalidColumnPut() throws IOException, JAXBException {
  String dummyColumn = "doesnot:exist";
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(dummyColumn),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + dummyColumn;

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(response.getCode(), 404);
}
项目：HIndex    文件：RowResourceBase.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster(3);
  REST_TEST_UTIL.startServletContainer(conf);
  context = JAXBContext.newInstance(
      CellModel.class,
      CellSetModel.class,
      RowModel.class);
  xmlMarshaller = context.createMarshaller();
  xmlUnmarshaller = context.createUnmarshaller();
  jsonMapper = new JacksonProvider()
  .locateMapper(CellSetModel.class, MediaType.APPLICATION_JSON_TYPE);
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
}
项目：HIndex    文件：RowResourceBase.java    
protected static Response checkAndPutValueXML(String url, String table,
    String row, String column, String valueToCheck, String valueToPut)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：IRIndex    文件：TestScannerResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    CellModel.class,
    CellSetModel.class,
    RowModel.class,
    ScannerModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TABLE);
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
  expectedRows1 = insertData(TABLE, COLUMN_1, 1.0);
  expectedRows2 = insertData(TABLE, COLUMN_2, 0.5);
}
项目：c5    文件：RemoteHTable.java    
protected Result[] buildResultFromModel(final CellSetModel model) {
  List<Result> results = new ArrayList<Result>();
  for (RowModel row: model.getRows()) {
    List<Cell> kvs = new ArrayList<Cell>();
    for (CellModel cell: row.getCells()) {
      byte[][] split = KeyValue.parseColumn(cell.getColumn());
      byte[] column = split[0];
      byte[] qualifier = null;
      if (split.length == 1) {
        qualifier = HConstants.EMPTY_BYTE_ARRAY;
      } else if (split.length == 2) {
        qualifier = split[1];
      } else {
        throw new IllegalArgumentException("Invalid familyAndQualifier provided.");
      }
      kvs.add(new KeyValue(row.getKey(), column, qualifier,
        cell.getTimestamp(), cell.getValue()));
    }
    results.add(Result.create(kvs));
  }
  return results.toArray(new Result[results.size()]);
}
项目：IRIndex    文件：TestRowResource.java    
private static Response checkAndPutValueXML(String url, String table,
    String row, String column, String valueToCheck, String valueToPut)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  marshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：IRIndex    文件：TestRowResource.java    
@Test
public void testInvalidCheckParam() throws IOException, JAXBException {
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(COLUMN_1),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  marshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + COLUMN_1 + "?check=blah";

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(response.getCode(), 400);
}
项目：hbase    文件：RemoteHTable.java    
protected Result[] buildResultFromModel(final CellSetModel model) {
  List<Result> results = new ArrayList<>();
  for (RowModel row: model.getRows()) {
    List<Cell> kvs = new ArrayList<>(row.getCells().size());
    for (CellModel cell: row.getCells()) {
      byte[][] split = CellUtil.parseColumn(cell.getColumn());
      byte[] column = split[0];
      byte[] qualifier = null;
      if (split.length == 1) {
        qualifier = HConstants.EMPTY_BYTE_ARRAY;
      } else if (split.length == 2) {
        qualifier = split[1];
      } else {
        throw new IllegalArgumentException("Invalid familyAndQualifier provided.");
      }
      kvs.add(new KeyValue(row.getKey(), column, qualifier,
        cell.getTimestamp(), cell.getValue()));
    }
    results.add(Result.create(kvs));
  }
  return results.toArray(new Result[results.size()]);
}
项目：hbase    文件：TestGetAndPutResource.java    
@Test
public void testInvalidCheckParam() throws IOException, JAXBException {
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(COLUMN_1),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + COLUMN_1 + "?check=blah";

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(400, response.getCode());
}
项目：hbase    文件：TestGetAndPutResource.java    
@Test
public void testInvalidColumnPut() throws IOException, JAXBException {
  String dummyColumn = "doesnot:exist";
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(dummyColumn),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + dummyColumn;

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(404, response.getCode());
}
项目：c5    文件：TestRowResource.java    
@Test
public void testInvalidCheckParam() throws IOException, JAXBException {
  CellSetModel cellSetModel = new CellSetModel();
  RowModel rowModel = new RowModel(ROW_1);
  rowModel.addCell(new CellModel(Bytes.toBytes(COLUMN_1),
    Bytes.toBytes(VALUE_1)));
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  marshaller.marshal(cellSetModel, writer);

  final String path = "/" + TABLE + "/" + ROW_1 + "/" + COLUMN_1 + "?check=blah";

  Response response = client.put(path, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  assertEquals(response.getCode(), 400);
}
项目：c5    文件：TestRowResource.java    
private static Response checkAndPutValueXML(String url, String table,
    String row, String column, String valueToCheck, String valueToPut)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  marshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：hbase    文件：RowResourceBase.java    
protected static Response checkAndPutValuePB(String url, String table,
    String row, String column, String valueToCheck, String valueToPut, HashMap<String,String> otherCells)
      throws IOException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));

  if(otherCells != null) {
    for (Map.Entry<String,String> entry :otherCells.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }

  // This Cell need to be added as last cell.
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));

  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  Response response = client.put(url, Constants.MIMETYPE_PROTOBUF,
    cellSetModel.createProtobufOutput());
  Thread.yield();
  return response;
}
项目：hbase    文件：RowResourceBase.java    
protected static Response checkAndPutValueXML(String url, String table,
    String row, String column, String valueToCheck, String valueToPut, HashMap<String,String> otherCells)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));

  if(otherCells != null) {
    for (Map.Entry<String,String> entry :otherCells.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }

  // This Cell need to be added as last cell.
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：hbase    文件：RowResourceBase.java    
protected static Response checkAndDeleteXML(String url, String table,
    String row, String column, String valueToCheck, HashMap<String,String> cellsToDelete)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);

  if(cellsToDelete != null) {
    for (Map.Entry<String,String> entry :cellsToDelete.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }
  // Add this at the end
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：hbase    文件：RowResourceBase.java    
protected static Response checkAndDeleteJson(String url, String table,
    String row, String column, String valueToCheck, HashMap<String,String> cellsToDelete)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);

  if(cellsToDelete != null) {
    for (Map.Entry<String,String> entry :cellsToDelete.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }
  // Add this at the end
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  String jsonString = jsonMapper.writeValueAsString(cellSetModel);
  Response response = client.put(url, Constants.MIMETYPE_JSON,
    Bytes.toBytes(jsonString));
  Thread.yield();
  return response;
}
项目：hbase    文件：RowResourceBase.java    
protected static Response checkAndDeleteValuePB(String url, String table,
    String row, String column, String valueToCheck, HashMap<String,String> cellsToDelete)
    throws IOException {
  RowModel rowModel = new RowModel(row);

  if(cellsToDelete != null) {
    for (Map.Entry<String,String> entry :cellsToDelete.entrySet()) {
      rowModel.addCell(new CellModel(Bytes.toBytes(entry.getKey()), Bytes.toBytes(entry.getValue())));
    }
  }
  // Add this at the end
  rowModel.addCell(new CellModel(Bytes.toBytes(column), Bytes
      .toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  Response response = client.put(url, Constants.MIMETYPE_PROTOBUF,
      cellSetModel.createProtobufOutput());
  Thread.yield();
  return response;
}
项目：PyroDB    文件：RowResourceBase.java    
protected static Response checkAndPutValueXML(String url, String table,
    String row, String column, String valueToCheck, String valueToPut)
      throws IOException, JAXBException {
  RowModel rowModel = new RowModel(row);
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToPut)));
  rowModel.addCell(new CellModel(Bytes.toBytes(column),
    Bytes.toBytes(valueToCheck)));
  CellSetModel cellSetModel = new CellSetModel();
  cellSetModel.addRow(rowModel);
  StringWriter writer = new StringWriter();
  xmlMarshaller.marshal(cellSetModel, writer);
  Response response = client.put(url, Constants.MIMETYPE_XML,
    Bytes.toBytes(writer.toString()));
  Thread.yield();
  return response;
}
项目：PyroDB    文件：TestScannerResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  client = new Client(new Cluster().add("localhost",
    REST_TEST_UTIL.getServletPort()));
  context = JAXBContext.newInstance(
    CellModel.class,
    CellSetModel.class,
    RowModel.class,
    ScannerModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(TABLE));
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
  expectedRows1 = insertData(TEST_UTIL.getConfiguration(), TABLE, COLUMN_1, 1.0);
  expectedRows2 = insertData(TEST_UTIL.getConfiguration(), TABLE, COLUMN_2, 0.5);
}
项目：PyroDB    文件：TestMultiRowResource.java    
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  conf = TEST_UTIL.getConfiguration();
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(conf);
  context = JAXBContext.newInstance(
          CellModel.class,
          CellSetModel.class,
          RowModel.class);
  marshaller = context.createMarshaller();
  unmarshaller = context.createUnmarshaller();
  client = new Client(new Cluster().add("localhost", REST_TEST_UTIL.getServletPort()));
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (admin.tableExists(TABLE)) {
    return;
  }
  HTableDescriptor htd = new HTableDescriptor(TableName.valueOf(TABLE));
  htd.addFamily(new HColumnDescriptor(CFA));
  htd.addFamily(new HColumnDescriptor(CFB));
  admin.createTable(htd);
}