@InterfaceAudience.Private
public interface DeleteTracker
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 StoreFileModifier and Type | Interface and Description |
---|---|
static class |
DeleteTracker.DeleteCompare
Return codes for comparison of two Deletes.
|
static class |
DeleteTracker.DeleteResult
Returns codes for delete result.
|
Modifier and Type | Method and Description |
---|---|
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.
|
DeleteTracker.DeleteResult |
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.
|
void add(byte[] buffer, int qualifierOffset, int qualifierLength, long timestamp, byte type)
This is called when a Delete is encountered in a StoreFile.
buffer
- KeyValue bufferqualifierOffset
- column qualifier offsetqualifierLength
- column qualifier lengthtimestamp
- timestamptype
- delete type as byteDeleteTracker.DeleteResult isDeleted(byte[] buffer, int qualifierOffset, int qualifierLength, long timestamp)
buffer
- KeyValue bufferqualifierOffset
- column qualifier offsetqualifierLength
- column qualifier lengthtimestamp
- timestampboolean 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.
Copyright © 2013 The Apache Software Foundation. All rights reserved.