Examples of org.apache.hadoop.hbase.client.Delete.deleteColumn()

Class org.apache.hadoop.hbase.client.Delete

Examples of org.apache.hadoop.hbase.client.Delete.deleteColumn()

org.apache.hadoop.hbase.client.Delete.deleteColumn()
Delete the latest version of the specified column. This is an expensive call in that on the server-side, it first does a get to find the latest versions timestamp. Then it adds a delete using the fetched cells timestamp. @param family family name @param qualifier column qualifier @return this for invocation chaining

                //撤消前面的add或remove操作
                if (oldPut != null) {
                    Delete delete = new Delete(oldPut.getRow());
                    for (Map.Entry<byte[], List<KeyValue>> e : oldPut.getFamilyMap().entrySet()) {
                        for (KeyValue kv : e.getValue()) {
                            delete.deleteColumn(e.getKey(), kv.getQualifier(), kv.getTimestamp());
                        }
                    }
                    hs.getRegionServer().delete(hr.getRegionName(), delete);
                } else
                    throw DbException.throwInternalError("oldPut is null???");

View Full Code Here

   * Reset the split parent region info in meta table
   */
  private void resetSplitParent(HbckInfo hi) throws IOException {
    RowMutations mutations = new RowMutations(hi.metaEntry.getRegionName());
    Delete d = new Delete(hi.metaEntry.getRegionName());
    d.deleteColumn(HConstants.CATALOG_FAMILY, HConstants.SPLITA_QUALIFIER);
    d.deleteColumn(HConstants.CATALOG_FAMILY, HConstants.SPLITB_QUALIFIER);
    mutations.add(d);


    HRegionInfo hri = new HRegionInfo(hi.metaEntry);
    hri.setOffline(false);

View Full Code Here

   */
  private void resetSplitParent(HbckInfo hi) throws IOException {
    RowMutations mutations = new RowMutations(hi.metaEntry.getRegionName());
    Delete d = new Delete(hi.metaEntry.getRegionName());
    d.deleteColumn(HConstants.CATALOG_FAMILY, HConstants.SPLITA_QUALIFIER);
    d.deleteColumn(HConstants.CATALOG_FAMILY, HConstants.SPLITB_QUALIFIER);
    mutations.add(d);


    HRegionInfo hri = new HRegionInfo(hi.metaEntry);
    hri.setOffline(false);
    hri.setSplit(false);

View Full Code Here

      tableName,
      new Boolean[] {true, true, true, true, false}
          );


      Delete delete = new Delete(ROW);
      delete.deleteColumn(A, A);
      delete.deleteColumn(B, B);
      delete.deleteColumn(C, C);
      table.delete(delete);


      verifyMethodResult(SimpleRegionObserver.class,

View Full Code Here

      new Boolean[] {true, true, true, true, false}
          );


      Delete delete = new Delete(ROW);
      delete.deleteColumn(A, A);
      delete.deleteColumn(B, B);
      delete.deleteColumn(C, C);
      table.delete(delete);


      verifyMethodResult(SimpleRegionObserver.class,
          new String[] {"hadPreGet", "hadPostGet", "hadPrePut", "hadPostPut",

View Full Code Here

          );


      Delete delete = new Delete(ROW);
      delete.deleteColumn(A, A);
      delete.deleteColumn(B, B);
      delete.deleteColumn(C, C);
      table.delete(delete);


      verifyMethodResult(SimpleRegionObserver.class,
          new String[] {"hadPreGet", "hadPostGet", "hadPrePut", "hadPostPut",
        "hadPreBatchMutate", "hadPostBatchMutate", "hadDelete"},

View Full Code Here

      put.add(A, A, A);
      put.add(B, B, B);
      put.add(C, C, C);


      Delete delete = new Delete(ROW);
      delete.deleteColumn(A, A);
      delete.deleteColumn(B, B);
      delete.deleteColumn(C, C);


      RowMutations arm = new RowMutations(ROW);
      arm.add(put);

View Full Code Here

      put.add(B, B, B);
      put.add(C, C, C);


      Delete delete = new Delete(ROW);
      delete.deleteColumn(A, A);
      delete.deleteColumn(B, B);
      delete.deleteColumn(C, C);


      RowMutations arm = new RowMutations(ROW);
      arm.add(put);
      arm.add(delete);

View Full Code Here

      put.add(C, C, C);


      Delete delete = new Delete(ROW);
      delete.deleteColumn(A, A);
      delete.deleteColumn(B, B);
      delete.deleteColumn(C, C);


      RowMutations arm = new RowMutations(ROW);
      arm.add(put);
      arm.add(delete);
      table.mutateRow(arm);

View Full Code Here

  }


  @Test
  public void testMinorCompactionWithDeleteColumn2() throws Exception {
    Delete dc = new Delete(secondRowBytes);
    dc.deleteColumn(fam2, col2);
    /* compactionThreshold is 3. The table has 4 versions: 0, 1, 2, and 3.
     * we only delete the latest version. One might expect to see only
     * versions 1 and 2. HBase differs, and gives us 0, 1 and 2.
     * This is okay as well. Since there was no compaction done before the
     * delete, version 0 seems to stay on.

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.