Java 类org.apache.hadoop.hbase.coprocessor.example.BulkDeleteProtocol.DeleteType 实例源码

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpoint() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 500, DeleteType.ROW,
      null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion()
    throws Throwable {
  byte[] tableName = Bytes
      .toBytes("testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 10, DeleteType.ROW, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpoint() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 500, DeleteType.ROW,
      null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion()
    throws Throwable {
  byte[] tableName = Bytes
      .toBytes("testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 10, DeleteType.ROW, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpoint() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 500, DeleteType.ROW,
      null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion()
    throws Throwable {
  byte[] tableName = Bytes
      .toBytes("testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 10, DeleteType.ROW, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpoint() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 500, DeleteType.ROW,
      null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion()
    throws Throwable {
  byte[] tableName = Bytes
      .toBytes("testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 10, DeleteType.ROW, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpoint() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 500, DeleteType.ROW,
      null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion()
    throws Throwable {
  byte[] tableName = Bytes
      .toBytes("testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 10, DeleteType.ROW, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：hindex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpoint() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 500, DeleteType.ROW,
      null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：hindex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion()
    throws Throwable {
  byte[] tableName = Bytes
      .toBytes("testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    puts.add(createPut(rowkey, "v1"));
  }
  ht.put(puts);
  // Deleting all the rows.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, new Scan(), 10, DeleteType.ROW, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(0, rows);
}

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithConditionBasedDelete() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan();
  FilterList fl = new FilterList(Operator.MUST_PASS_ALL);
  SingleColumnValueFilter scvf = new SingleColumnValueFilter(FAMILY1, QUALIFIER3,
      CompareOp.EQUAL, Bytes.toBytes("v1"));
  //fl.addFilter(new FirstKeyOnlyFilter());
  fl.addFilter(scvf);
  scan.setFilter(fl);
  // Deleting all the rows where cf1:c1=v1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.ROW, null);
  assertEquals(10, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(90, rows);
}

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumn() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumn");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER2);
  // Delete the column cf1:col2
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.COLUMN, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertEquals(2, result.getFamilyMap(FAMILY1).size());
    assertTrue(result.getColumn(FAMILY1, QUALIFIER2).isEmpty());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteFamily() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteFamily");
  HTableDescriptor htd = new HTableDescriptor(tableName);
  htd.addFamily(new HColumnDescriptor(FAMILY1));
  htd.addFamily(new HColumnDescriptor(FAMILY2));
  TEST_UTIL.getHBaseAdmin().createTable(htd, Bytes.toBytes(0), Bytes.toBytes(120), 5);
  HTable ht = new HTable(TEST_UTIL.getConfiguration(), tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    put.add(FAMILY1, QUALIFIER1, "v1".getBytes());
    put.add(FAMILY2, QUALIFIER2, "v2".getBytes());
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the column family cf1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.FAMILY, null);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertTrue(result.getFamilyMap(FAMILY1).isEmpty());
    assertEquals(1, result.getColumn(FAMILY2, QUALIFIER2).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithConditionBasedDelete() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan();
  FilterList fl = new FilterList(Operator.MUST_PASS_ALL);
  SingleColumnValueFilter scvf = new SingleColumnValueFilter(FAMILY1, QUALIFIER3,
      CompareOp.EQUAL, Bytes.toBytes("v1"));
  //fl.addFilter(new FirstKeyOnlyFilter());
  fl.addFilter(scvf);
  scan.setFilter(fl);
  // Deleting all the rows where cf1:c1=v1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.ROW, null);
  assertEquals(10, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(90, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumn() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumn");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER2);
  // Delete the column cf1:col2
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.COLUMN, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertEquals(2, result.getFamilyMap(FAMILY1).size());
    assertTrue(result.getColumn(FAMILY1, QUALIFIER2).isEmpty());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteFamily() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteFamily");
  HTableDescriptor htd = new HTableDescriptor(tableName);
  htd.addFamily(new HColumnDescriptor(FAMILY1));
  htd.addFamily(new HColumnDescriptor(FAMILY2));
  TEST_UTIL.getHBaseAdmin().createTable(htd, Bytes.toBytes(0), Bytes.toBytes(120), 5);
  HTable ht = new HTable(TEST_UTIL.getConfiguration(), tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    put.add(FAMILY1, QUALIFIER1, "v1".getBytes());
    put.add(FAMILY2, QUALIFIER2, "v2".getBytes());
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the column family cf1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.FAMILY, null);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertTrue(result.getFamilyMap(FAMILY1).isEmpty());
    assertEquals(1, result.getColumn(FAMILY2, QUALIFIER2).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithConditionBasedDelete() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan();
  FilterList fl = new FilterList(Operator.MUST_PASS_ALL);
  SingleColumnValueFilter scvf = new SingleColumnValueFilter(FAMILY1, QUALIFIER3,
      CompareOp.EQUAL, Bytes.toBytes("v1"));
  //fl.addFilter(new FirstKeyOnlyFilter());
  fl.addFilter(scvf);
  scan.setFilter(fl);
  // Deleting all the rows where cf1:c1=v1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.ROW, null);
  assertEquals(10, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(90, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumn() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumn");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER2);
  // Delete the column cf1:col2
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.COLUMN, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertEquals(2, result.getFamilyMap(FAMILY1).size());
    assertTrue(result.getColumn(FAMILY1, QUALIFIER2).isEmpty());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteFamily() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteFamily");
  HTableDescriptor htd = new HTableDescriptor(tableName);
  htd.addFamily(new HColumnDescriptor(FAMILY1));
  htd.addFamily(new HColumnDescriptor(FAMILY2));
  TEST_UTIL.getHBaseAdmin().createTable(htd, Bytes.toBytes(0), Bytes.toBytes(120), 5);
  HTable ht = new HTable(TEST_UTIL.getConfiguration(), tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    put.add(FAMILY1, QUALIFIER1, "v1".getBytes());
    put.add(FAMILY2, QUALIFIER2, "v2".getBytes());
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the column family cf1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.FAMILY, null);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertTrue(result.getFamilyMap(FAMILY1).isEmpty());
    assertEquals(1, result.getColumn(FAMILY2, QUALIFIER2).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithConditionBasedDelete() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan();
  FilterList fl = new FilterList(Operator.MUST_PASS_ALL);
  SingleColumnValueFilter scvf = new SingleColumnValueFilter(FAMILY1, QUALIFIER3,
      CompareOp.EQUAL, Bytes.toBytes("v1"));
  //fl.addFilter(new FirstKeyOnlyFilter());
  fl.addFilter(scvf);
  scan.setFilter(fl);
  // Deleting all the rows where cf1:c1=v1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.ROW, null);
  assertEquals(10, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(90, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumn() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumn");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER2);
  // Delete the column cf1:col2
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.COLUMN, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertEquals(2, result.getFamilyMap(FAMILY1).size());
    assertTrue(result.getColumn(FAMILY1, QUALIFIER2).isEmpty());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteFamily() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteFamily");
  HTableDescriptor htd = new HTableDescriptor(tableName);
  htd.addFamily(new HColumnDescriptor(FAMILY1));
  htd.addFamily(new HColumnDescriptor(FAMILY2));
  TEST_UTIL.getHBaseAdmin().createTable(htd, Bytes.toBytes(0), Bytes.toBytes(120), 5);
  HTable ht = new HTable(TEST_UTIL.getConfiguration(), tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    put.add(FAMILY1, QUALIFIER1, "v1".getBytes());
    put.add(FAMILY2, QUALIFIER2, "v2".getBytes());
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the column family cf1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.FAMILY, null);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertTrue(result.getFamilyMap(FAMILY1).isEmpty());
    assertEquals(1, result.getColumn(FAMILY2, QUALIFIER2).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithConditionBasedDelete() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan();
  FilterList fl = new FilterList(Operator.MUST_PASS_ALL);
  SingleColumnValueFilter scvf = new SingleColumnValueFilter(FAMILY1, QUALIFIER3,
      CompareOp.EQUAL, Bytes.toBytes("v1"));
  //fl.addFilter(new FirstKeyOnlyFilter());
  fl.addFilter(scvf);
  scan.setFilter(fl);
  // Deleting all the rows where cf1:c1=v1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.ROW, null);
  assertEquals(10, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(90, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumn() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumn");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER2);
  // Delete the column cf1:col2
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.COLUMN, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertEquals(2, result.getFamilyMap(FAMILY1).size());
    assertTrue(result.getColumn(FAMILY1, QUALIFIER2).isEmpty());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteFamily() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteFamily");
  HTableDescriptor htd = new HTableDescriptor(tableName);
  htd.addFamily(new HColumnDescriptor(FAMILY1));
  htd.addFamily(new HColumnDescriptor(FAMILY2));
  TEST_UTIL.getHBaseAdmin().createTable(htd, Bytes.toBytes(0), Bytes.toBytes(120), 5);
  HTable ht = new HTable(TEST_UTIL.getConfiguration(), tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    put.add(FAMILY1, QUALIFIER1, "v1".getBytes());
    put.add(FAMILY2, QUALIFIER2, "v2".getBytes());
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the column family cf1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.FAMILY, null);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertTrue(result.getFamilyMap(FAMILY1).isEmpty());
    assertEquals(1, result.getColumn(FAMILY2, QUALIFIER2).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：hindex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithConditionBasedDelete() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan();
  FilterList fl = new FilterList(Operator.MUST_PASS_ALL);
  SingleColumnValueFilter scvf = new SingleColumnValueFilter(FAMILY1, QUALIFIER3,
      CompareOp.EQUAL, Bytes.toBytes("v1"));
  //fl.addFilter(new FirstKeyOnlyFilter());
  fl.addFilter(scvf);
  scan.setFilter(fl);
  // Deleting all the rows where cf1:c1=v1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.ROW, null);
  assertEquals(10, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    rows++;
  }
  assertEquals(90, rows);
}

项目：hindex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumn() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumn");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    byte[] rowkey = Bytes.toBytes(j);
    String value = (j % 10 == 0) ? "v1" : "v2";
    puts.add(createPut(rowkey, value));
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER2);
  // Delete the column cf1:col2
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.COLUMN, null);
  assertEquals(100, noOfRowsDeleted);

  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertEquals(2, result.getFamilyMap(FAMILY1).size());
    assertTrue(result.getColumn(FAMILY1, QUALIFIER2).isEmpty());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(1, result.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：hindex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteFamily() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteFamily");
  HTableDescriptor htd = new HTableDescriptor(tableName);
  htd.addFamily(new HColumnDescriptor(FAMILY1));
  htd.addFamily(new HColumnDescriptor(FAMILY2));
  TEST_UTIL.getHBaseAdmin().createTable(htd, Bytes.toBytes(0), Bytes.toBytes(120), 5);
  HTable ht = new HTable(TEST_UTIL.getConfiguration(), tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    put.add(FAMILY1, QUALIFIER1, "v1".getBytes());
    put.add(FAMILY2, QUALIFIER2, "v2".getBytes());
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the column family cf1
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.FAMILY, null);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  for (Result result : ht.getScanner(new Scan())) {
    assertTrue(result.getFamilyMap(FAMILY1).isEmpty());
    assertEquals(1, result.getColumn(FAMILY2, QUALIFIER2).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumnVersion() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // Latest version values
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    put.add(FAMILY1, null, value);
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the latest version values of all the columns in family cf1.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.VERSION,
      HConstants.LATEST_TIMESTAMP);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  scan = new Scan ();
  scan.setMaxVersions();
  for (Result result : ht.getScanner(scan)) {
    assertEquals(3, result.getFamilyMap(FAMILY1).size());
    List<KeyValue> column = result.getColumn(FAMILY1, QUALIFIER1);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER2);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER3);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));
    rows++;
  }
  assertEquals(100, rows);
}

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumnVersionBasedOnTS() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersionBasedOnTS");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    // TS = 1000L
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1000L, value);
    put.add(FAMILY1, QUALIFIER2, 1000L, value);
    put.add(FAMILY1, QUALIFIER3, 1000L, value);
    // TS = 1234L
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // Latest version values
    value = "v3".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER3);
  // Delete the column cf1:c3's one version at TS=1234 
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.VERSION, 1234L);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  scan = new Scan ();
  scan.setMaxVersions();
  for (Result result : ht.getScanner(scan)) {
    assertEquals(3, result.getFamilyMap(FAMILY1).size());
    assertEquals(3, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(3, result.getColumn(FAMILY1, QUALIFIER2).size());
    List<KeyValue> column = result.getColumn(FAMILY1, QUALIFIER3);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v3".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v1".getBytes(), column.get(1).getValue()));
    rows++;
  }
  assertEquals(100, rows);
}

项目：LCIndex-HBase-0.94.16 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithNumberOfVersions() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithNumberOfVersions");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    // TS = 1000L
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1000L, value);
    put.add(FAMILY1, QUALIFIER2, 1000L, value);
    put.add(FAMILY1, QUALIFIER3, 1000L, value);
    // TS = 1234L
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // TS = 2000L
    value = "v3".getBytes();
    put.add(FAMILY1, QUALIFIER1, 2000L, value);
    put.add(FAMILY1, QUALIFIER2, 2000L, value);
    put.add(FAMILY1, QUALIFIER3, 2000L, value);
    // Latest version values
    value = "v4".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    puts.add(put);
  }
  ht.put(puts);

  // Delete all the versions of columns cf1:c1 and cf1:c2 falling with the time range
  // [1000,2000)
  final Scan scan = new Scan();
  scan.addColumn(FAMILY1, QUALIFIER1);
  scan.addColumn(FAMILY1, QUALIFIER2);
  scan.setTimeRange(1000L, 2000L);
  scan.setMaxVersions();

  long noOfDeletedRows = 0L;
  long noOfVersionsDeleted = 0L;
  Batch.Call<BulkDeleteProtocol, BulkDeleteResponse> callable = 
      new Batch.Call<BulkDeleteProtocol, BulkDeleteResponse>() {
    public BulkDeleteResponse call(BulkDeleteProtocol instance) throws IOException {
      return instance.delete(scan, DeleteType.VERSION, null, 500);
    }
  };
  Map<byte[], BulkDeleteResponse> result = ht.coprocessorExec(BulkDeleteProtocol.class,
      scan.getStartRow(), scan.getStopRow(), callable);
  for (BulkDeleteResponse response : result.values()) {
    noOfDeletedRows += response.getRowsDeleted();
    noOfVersionsDeleted += response.getVersionsDeleted();
  }
  assertEquals(100, noOfDeletedRows);
  assertEquals(400, noOfVersionsDeleted);

  int rows = 0;
  Scan scan1 = new Scan ();
  scan1.setMaxVersions();
  for (Result res : ht.getScanner(scan1)) {
    assertEquals(3, res.getFamilyMap(FAMILY1).size());
    List<KeyValue> column = res.getColumn(FAMILY1, QUALIFIER1);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v4".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v3".getBytes(), column.get(1).getValue()));
    column = res.getColumn(FAMILY1, QUALIFIER2);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v4".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v3".getBytes(), column.get(1).getValue()));
    assertEquals(4, res.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumnVersion() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // Latest version values
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    put.add(FAMILY1, null, value);
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the latest version values of all the columns in family cf1.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.VERSION,
      HConstants.LATEST_TIMESTAMP);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  scan = new Scan ();
  scan.setMaxVersions();
  for (Result result : ht.getScanner(scan)) {
    assertEquals(3, result.getFamilyMap(FAMILY1).size());
    List<KeyValue> column = result.getColumn(FAMILY1, QUALIFIER1);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER2);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER3);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));
    rows++;
  }
  assertEquals(100, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumnVersionBasedOnTS() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersionBasedOnTS");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    // TS = 1000L
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1000L, value);
    put.add(FAMILY1, QUALIFIER2, 1000L, value);
    put.add(FAMILY1, QUALIFIER3, 1000L, value);
    // TS = 1234L
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // Latest version values
    value = "v3".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER3);
  // Delete the column cf1:c3's one version at TS=1234 
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.VERSION, 1234L);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  scan = new Scan ();
  scan.setMaxVersions();
  for (Result result : ht.getScanner(scan)) {
    assertEquals(3, result.getFamilyMap(FAMILY1).size());
    assertEquals(3, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(3, result.getColumn(FAMILY1, QUALIFIER2).size());
    List<KeyValue> column = result.getColumn(FAMILY1, QUALIFIER3);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v3".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v1".getBytes(), column.get(1).getValue()));
    rows++;
  }
  assertEquals(100, rows);
}

项目：IRIndex 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithNumberOfVersions() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithNumberOfVersions");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    // TS = 1000L
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1000L, value);
    put.add(FAMILY1, QUALIFIER2, 1000L, value);
    put.add(FAMILY1, QUALIFIER3, 1000L, value);
    // TS = 1234L
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // TS = 2000L
    value = "v3".getBytes();
    put.add(FAMILY1, QUALIFIER1, 2000L, value);
    put.add(FAMILY1, QUALIFIER2, 2000L, value);
    put.add(FAMILY1, QUALIFIER3, 2000L, value);
    // Latest version values
    value = "v4".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    puts.add(put);
  }
  ht.put(puts);

  // Delete all the versions of columns cf1:c1 and cf1:c2 falling with the time range
  // [1000,2000)
  final Scan scan = new Scan();
  scan.addColumn(FAMILY1, QUALIFIER1);
  scan.addColumn(FAMILY1, QUALIFIER2);
  scan.setTimeRange(1000L, 2000L);
  scan.setMaxVersions();

  long noOfDeletedRows = 0L;
  long noOfVersionsDeleted = 0L;
  Batch.Call<BulkDeleteProtocol, BulkDeleteResponse> callable = 
      new Batch.Call<BulkDeleteProtocol, BulkDeleteResponse>() {
    public BulkDeleteResponse call(BulkDeleteProtocol instance) throws IOException {
      return instance.delete(scan, DeleteType.VERSION, null, 500);
    }
  };
  Map<byte[], BulkDeleteResponse> result = ht.coprocessorExec(BulkDeleteProtocol.class,
      scan.getStartRow(), scan.getStopRow(), callable);
  for (BulkDeleteResponse response : result.values()) {
    noOfDeletedRows += response.getRowsDeleted();
    noOfVersionsDeleted += response.getVersionsDeleted();
  }
  assertEquals(100, noOfDeletedRows);
  assertEquals(400, noOfVersionsDeleted);

  int rows = 0;
  Scan scan1 = new Scan ();
  scan1.setMaxVersions();
  for (Result res : ht.getScanner(scan1)) {
    assertEquals(3, res.getFamilyMap(FAMILY1).size());
    List<KeyValue> column = res.getColumn(FAMILY1, QUALIFIER1);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v4".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v3".getBytes(), column.get(1).getValue()));
    column = res.getColumn(FAMILY1, QUALIFIER2);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v4".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v3".getBytes(), column.get(1).getValue()));
    assertEquals(4, res.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumnVersion() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // Latest version values
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    put.add(FAMILY1, null, value);
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the latest version values of all the columns in family cf1.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.VERSION,
      HConstants.LATEST_TIMESTAMP);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  scan = new Scan ();
  scan.setMaxVersions();
  for (Result result : ht.getScanner(scan)) {
    assertEquals(3, result.getFamilyMap(FAMILY1).size());
    List<KeyValue> column = result.getColumn(FAMILY1, QUALIFIER1);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER2);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER3);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));
    rows++;
  }
  assertEquals(100, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumnVersionBasedOnTS() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersionBasedOnTS");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    // TS = 1000L
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1000L, value);
    put.add(FAMILY1, QUALIFIER2, 1000L, value);
    put.add(FAMILY1, QUALIFIER3, 1000L, value);
    // TS = 1234L
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // Latest version values
    value = "v3".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addColumn(FAMILY1, QUALIFIER3);
  // Delete the column cf1:c3's one version at TS=1234 
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.VERSION, 1234L);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  scan = new Scan ();
  scan.setMaxVersions();
  for (Result result : ht.getScanner(scan)) {
    assertEquals(3, result.getFamilyMap(FAMILY1).size());
    assertEquals(3, result.getColumn(FAMILY1, QUALIFIER1).size());
    assertEquals(3, result.getColumn(FAMILY1, QUALIFIER2).size());
    List<KeyValue> column = result.getColumn(FAMILY1, QUALIFIER3);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v3".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v1".getBytes(), column.get(1).getValue()));
    rows++;
  }
  assertEquals(100, rows);
}

项目：HBase-Research 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteWithNumberOfVersions() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteWithNumberOfVersions");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    // TS = 1000L
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1000L, value);
    put.add(FAMILY1, QUALIFIER2, 1000L, value);
    put.add(FAMILY1, QUALIFIER3, 1000L, value);
    // TS = 1234L
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // TS = 2000L
    value = "v3".getBytes();
    put.add(FAMILY1, QUALIFIER1, 2000L, value);
    put.add(FAMILY1, QUALIFIER2, 2000L, value);
    put.add(FAMILY1, QUALIFIER3, 2000L, value);
    // Latest version values
    value = "v4".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    puts.add(put);
  }
  ht.put(puts);

  // Delete all the versions of columns cf1:c1 and cf1:c2 falling with the time range
  // [1000,2000)
  final Scan scan = new Scan();
  scan.addColumn(FAMILY1, QUALIFIER1);
  scan.addColumn(FAMILY1, QUALIFIER2);
  scan.setTimeRange(1000L, 2000L);
  scan.setMaxVersions();

  long noOfDeletedRows = 0L;
  long noOfVersionsDeleted = 0L;
  Batch.Call<BulkDeleteProtocol, BulkDeleteResponse> callable = 
      new Batch.Call<BulkDeleteProtocol, BulkDeleteResponse>() {
    public BulkDeleteResponse call(BulkDeleteProtocol instance) throws IOException {
      return instance.delete(scan, DeleteType.VERSION, null, 500);
    }
  };
  Map<byte[], BulkDeleteResponse> result = ht.coprocessorExec(BulkDeleteProtocol.class,
      scan.getStartRow(), scan.getStopRow(), callable);
  for (BulkDeleteResponse response : result.values()) {
    noOfDeletedRows += response.getRowsDeleted();
    noOfVersionsDeleted += response.getVersionsDeleted();
  }
  assertEquals(100, noOfDeletedRows);
  assertEquals(400, noOfVersionsDeleted);

  int rows = 0;
  Scan scan1 = new Scan ();
  scan1.setMaxVersions();
  for (Result res : ht.getScanner(scan1)) {
    assertEquals(3, res.getFamilyMap(FAMILY1).size());
    List<KeyValue> column = res.getColumn(FAMILY1, QUALIFIER1);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v4".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v3".getBytes(), column.get(1).getValue()));
    column = res.getColumn(FAMILY1, QUALIFIER2);
    assertEquals(2, column.size());
    assertTrue(Bytes.equals("v4".getBytes(), column.get(0).getValue()));
    assertTrue(Bytes.equals("v3".getBytes(), column.get(1).getValue()));
    assertEquals(4, res.getColumn(FAMILY1, QUALIFIER3).size());
    rows++;
  }
  assertEquals(100, rows);
}

项目：hbase-0.94.8-qod 文件：TestBulkDeleteProtocol.java

@Test
public void testBulkDeleteColumnVersion() throws Throwable {
  byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersion");
  HTable ht = createTable(tableName);
  List<Put> puts = new ArrayList<Put>(100);
  for (int j = 0; j < 100; j++) {
    Put put = new Put(Bytes.toBytes(j));
    byte[] value = "v1".getBytes();
    put.add(FAMILY1, QUALIFIER1, 1234L, value);
    put.add(FAMILY1, QUALIFIER2, 1234L, value);
    put.add(FAMILY1, QUALIFIER3, 1234L, value);
    // Latest version values
    value = "v2".getBytes();
    put.add(FAMILY1, QUALIFIER1, value);
    put.add(FAMILY1, QUALIFIER2, value);
    put.add(FAMILY1, QUALIFIER3, value);
    put.add(FAMILY1, null, value);
    puts.add(put);
  }
  ht.put(puts);
  Scan scan = new Scan ();
  scan.addFamily(FAMILY1);
  // Delete the latest version values of all the columns in family cf1.
  long noOfRowsDeleted = invokeBulkDeleteProtocol(tableName, scan, 500, DeleteType.VERSION,
      HConstants.LATEST_TIMESTAMP);
  assertEquals(100, noOfRowsDeleted);
  int rows = 0;
  scan = new Scan ();
  scan.setMaxVersions();
  for (Result result : ht.getScanner(scan)) {
    assertEquals(3, result.getFamilyMap(FAMILY1).size());
    List<KeyValue> column = result.getColumn(FAMILY1, QUALIFIER1);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER2);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));

    column = result.getColumn(FAMILY1, QUALIFIER3);
    assertEquals(1, column.size());
    assertTrue(Bytes.equals("v1".getBytes(), column.get(0).getValue()));
    rows++;
  }
  assertEquals(100, rows);
}