@InterfaceAudience.LimitedPrivate(value={"Replication","Coprocesssor"}) public class WALEdit extends java.lang.Object implements HeapSize
Modifier and Type | Field and Description |
---|---|
static byte[] |
BULK_LOAD |
static WALEdit |
EMPTY_WALEDIT |
static Log |
LOG |
static byte[] |
METAFAMILY |
Modifier and Type | Method and Description |
---|---|
WALEdit |
add(Cell cell) |
static WALEdit |
createBulkLoadEvent(HRegionInfo hri,
WALProtos.BulkLoadDescriptor bulkLoadDescriptor)
Create a bulk loader WALEdit
|
static WALEdit |
createCompaction(HRegionInfo hri,
WALProtos.CompactionDescriptor c)
Create a compaction WALEdit
|
static WALEdit |
createFlushWALEdit(HRegionInfo hri,
WALProtos.FlushDescriptor f) |
static WALEdit |
createRegionEventWALEdit(HRegionInfo hri,
WALProtos.RegionEventDescriptor regionEventDesc) |
java.util.NavigableMap<byte[],java.lang.Integer> |
getAndRemoveScopes() |
static WALProtos.BulkLoadDescriptor |
getBulkLoadDescriptor(Cell cell)
Deserialized and returns a BulkLoadDescriptor from the passed in Cell
|
java.util.ArrayList<Cell> |
getCells() |
static WALProtos.CompactionDescriptor |
getCompaction(Cell kv)
Deserialized and returns a CompactionDescriptor is the KeyValue contains one.
|
static WALProtos.FlushDescriptor |
getFlushDescriptor(Cell cell) |
static WALProtos.RegionEventDescriptor |
getRegionEventDescriptor(Cell cell) |
long |
heapSize() |
boolean |
isEmpty() |
boolean |
isMetaEdit() |
static boolean |
isMetaEditFamily(byte[] f) |
static boolean |
isMetaEditFamily(Cell cell) |
boolean |
isReplay() |
void |
readFields(java.io.DataInput in) |
int |
readFromCells(Codec.Decoder cellDecoder,
int expectedCount)
Reads WALEdit from cells.
|
void |
setCells(java.util.ArrayList<Cell> cells)
This is not thread safe.
|
void |
setCompressionContext(CompressionContext compressionContext) |
int |
size() |
java.lang.String |
toString() |
void |
write(java.io.DataOutput out) |
public static final Log LOG
public static final byte[] METAFAMILY
public static final byte[] BULK_LOAD
public static final WALEdit EMPTY_WALEDIT
public static boolean isMetaEditFamily(byte[] f)
f
- f
is METAFAMILY
public static boolean isMetaEditFamily(Cell cell)
public boolean isMetaEdit()
public boolean isReplay()
public void setCompressionContext(CompressionContext compressionContext)
public boolean isEmpty()
public int size()
public java.util.ArrayList<Cell> getCells()
@InterfaceAudience.Private public void setCells(java.util.ArrayList<Cell> cells)
cells
- the list of cells that this WALEdit now contains.public java.util.NavigableMap<byte[],java.lang.Integer> getAndRemoveScopes()
public void readFields(java.io.DataInput in) throws java.io.IOException
java.io.IOException
public void write(java.io.DataOutput out) throws java.io.IOException
java.io.IOException
public int readFromCells(Codec.Decoder cellDecoder, int expectedCount) throws java.io.IOException
cellDecoder
- Cell decoder.expectedCount
- Expected cell count.java.io.IOException
public long heapSize()
public java.lang.String toString()
toString
in class java.lang.Object
public static WALEdit createFlushWALEdit(HRegionInfo hri, WALProtos.FlushDescriptor f)
public static WALProtos.FlushDescriptor getFlushDescriptor(Cell cell) throws java.io.IOException
java.io.IOException
public static WALEdit createRegionEventWALEdit(HRegionInfo hri, WALProtos.RegionEventDescriptor regionEventDesc)
public static WALProtos.RegionEventDescriptor getRegionEventDescriptor(Cell cell) throws java.io.IOException
java.io.IOException
public static WALEdit createCompaction(HRegionInfo hri, WALProtos.CompactionDescriptor c)
c
- c
serialized as its valuepublic static WALProtos.CompactionDescriptor getCompaction(Cell kv) throws java.io.IOException
kv
- the key valuejava.io.IOException
public static WALEdit createBulkLoadEvent(HRegionInfo hri, WALProtos.BulkLoadDescriptor bulkLoadDescriptor)
hri
- The HRegionInfo for the region in which we are bulk loadingbulkLoadDescriptor
- The descriptor for the Bulk Loaderpublic static WALProtos.BulkLoadDescriptor getBulkLoadDescriptor(Cell cell) throws java.io.IOException
cell
- the key valuejava.io.IOException