@InterfaceAudience.Private public interface DeleteTracker extends ShipperListener
This class is utilized through three methods:
add(org.apache.hadoop.hbase.Cell)
when encountering a DeleteisDeleted(org.apache.hadoop.hbase.Cell)
when checking if a Put Cell has been deletedupdate()
when reaching the end of a StoreFileModifier and Type | Interface and Description |
---|---|
static class |
DeleteTracker.DeleteResult
Returns codes for delete result.
|
Modifier and Type | Method and Description |
---|---|
void |
add(Cell cell)
Add the specified cell to the list of deletes to check against for this row operation.
|
CellComparator |
getCellComparator()
Return the comparator passed to this delete tracker
|
DeleteTracker.DeleteResult |
isDeleted(Cell cell)
Check if the specified cell 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.
|
beforeShipped
void add(Cell cell)
This is called when a Delete is encountered in a StoreFile.
cell
- - the delete cellDeleteTracker.DeleteResult isDeleted(Cell cell)
cell
- - current cell to check if deleted by a previously seen deleteboolean isEmpty()
void update()
Many optimized implementations of Trackers will require an update at when the end of each StoreFile is reached.
void reset()
This clears everything as if a new DeleteTracker was instantiated.
CellComparator getCellComparator()
Copyright © 2007–2019 Cloudera. All rights reserved.