org.apache.hadoop.hbase.regionserver
Class GetDeleteTracker

java.lang.Object
  org.apache.hadoop.hbase.regionserver.GetDeleteTracker

All Implemented Interfaces:

DeleteTracker

public class GetDeleteTracker
extends Object
implements DeleteTracker

This class is responsible for the tracking and enforcement of Deletes during the course of a Get operation.

This class is utilized through three methods:

• add(byte[], int, int, long, byte) when encountering a Delete
• isDeleted(byte[], int, int, long) when checking if a Put KeyValue has been deleted
• update() when reaching the end of a StoreFile

  This class is NOT thread-safe as queries are never multi-threaded

  Nested Class Summary

  protected static class

  GetDeleteTracker.Delete Internal class used to store the necessary information for a Delete.

  Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.DeleteTracker

  DeleteTracker.DeleteCompare

  Field Summary

  protected List<GetDeleteTracker.Delete>

  deletes

  Constructor Summary

  GetDeleteTracker()
  Constructor

  Method Summary

  void	add(byte[] buffer, int qualifierOffset, int qualifierLength, long timestamp, byte type) Add the specified KeyValue to the list of deletes to check against for this row operation.
  protected DeleteTracker.DeleteCompare	compareDeletes(GetDeleteTracker.Delete oldDelete, GetDeleteTracker.Delete newDelete)
  boolean	isDeleted(byte[] buffer, int qualifierOffset, int qualifierLength, long timestamp) Check if the specified KeyValue buffer has been deleted by a previously seen delete.
  boolean	isEmpty()
  void	reset() Called between rows.
  void	update() Called at the end of every StoreFile.

  Methods inherited from class java.lang.Object

  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  Field Detail

  deletes

  protected List<GetDeleteTracker.Delete> deletes

  Constructor Detail

  GetDeleteTracker

  public GetDeleteTracker()

  Constructor

  Method Detail

  add

  public void add(byte[] buffer,
                  int qualifierOffset,
                  int qualifierLength,
                  long timestamp,
                  byte type)

  Add the specified KeyValue to the list of deletes to check against for this row operation.

  This is called when a Delete is encountered in a StoreFile.

  Specified by:

  add in interface DeleteTracker

  Parameters:

  buffer -

  qualifierOffset -

  qualifierLength -

  timestamp -

  type -

  isDeleted

  public boolean isDeleted(byte[] buffer,
                           int qualifierOffset,
                           int qualifierLength,
                           long timestamp)

  Check if the specified KeyValue buffer has been deleted by a previously seen delete.

  Specified by:

  isDeleted in interface DeleteTracker

  Parameters:

  buffer - KeyValue buffer

  qualifierOffset - column qualifier offset

  qualifierLength - column qualifier length

  timestamp - timestamp

  Returns:

  true is the specified KeyValue is deleted, false if not

  isEmpty

  public boolean isEmpty()

  Specified by:

  isEmpty in interface DeleteTracker

  Returns:

  true if there are no current delete, false otherwise

  reset

  public void reset()

  Description copied from interface: DeleteTracker

  Called between rows.

  This clears everything as if a new DeleteTracker was instantiated.

  Specified by:

  reset in interface DeleteTracker

  update

  public void update()

  Called at the end of every StoreFile.

  Many optimized implementations of Trackers will require an update at when the end of each StoreFile is reached.

  Specified by:

  update in interface DeleteTracker

  compareDeletes

  protected DeleteTracker.DeleteCompare compareDeletes(GetDeleteTracker.Delete oldDelete,
                                                       GetDeleteTracker.Delete newDelete)