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

   * 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);


    Put p = new Put(hi.metaEntry.getRegionName());
    HRegionInfo hri = new HRegionInfo(hi.metaEntry);

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);


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

View Full Code Here

    Put p = new Put(T1, ts);
    p.add(c0, c0, T1);
    region.put(p);


    Delete d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts);
    region.delete(d, null, true);


    // scan still returns delete markers and deletes rows
    Scan s = new Scan();
    s.setRaw(true);

View Full Code Here

    long ts = System.currentTimeMillis();  
    Put p = new Put(T1, ts);
    p.add(c0, c0, T1);
    region.put(p);
    Delete d = new Delete(T1, ts+2, null);
    d.deleteColumn(c0, c0, ts);
    region.delete(d, null, true);


    // "past" get does not see rows behind delete marker
    Get g = new Get(T1);
    g.setMaxVersions();

View Full Code Here


    Delete d = new Delete(T1, ts+1);
    region.delete(d, true);


    d = new Delete(T1, ts+2);
    d.deleteColumn(c0, c0, ts+2);
    region.delete(d, true);


    d = new Delete(T1, ts+3);
    d.deleteColumns(c0, c0, ts+3);
    region.delete(d, true);

View Full Code Here

    d = new Delete(T1, ts, null);
    d.deleteFamily(c0);
    region.delete(d, null, true);


    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+1);
    region.delete(d, null, true);
    
    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+2);
    region.delete(d, null, true);

View Full Code Here

    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+1);
    region.delete(d, null, true);
    
    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+2);
    region.delete(d, null, true);


    // 1 family marker, 1 column marker, 2 version markers
    assertEquals(4, countDeleteMarkers(region));

View Full Code Here

    d = new Delete(T1, ts, null);
    d.deleteFamily(c0, ts);
    region.delete(d, null, true);


    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+1);
    region.delete(d, null, true);
    
    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+2);
    region.delete(d, null, true);

View Full Code Here

    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+1);
    region.delete(d, null, true);
    
    d = new Delete(T1, ts, null);
    d.deleteColumn(c0, c0, ts+2);
    region.delete(d, null, true);


    // 1 family marker, 1 column marker, 2 version markers
    assertEquals(4, countDeleteMarkers(region));

View Full Code Here

    // test corner case (Put and Delete have same TS)
    d.deleteColumns(c0, c0, ts);
    region.delete(d, null, true);


    d = new Delete(T1, ts+1, null);
    d.deleteColumn(c0, c0, ts+1);
    region.delete(d, null, true);
    
    d = new Delete(T1, ts+3, null);
    d.deleteColumn(c0, c0, ts+3);
    region.delete(d, null, true);

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.