@InterfaceAudience.Private public class WALUtil extends Object
WAL.| Modifier and Type | Field and Description |
|---|---|
private static org.apache.commons.logging.Log |
LOG |
| Modifier | Constructor and Description |
|---|---|
private |
WALUtil() |
| Modifier and Type | Method and Description |
|---|---|
static long |
writeBulkLoadMarkerAndSync(WAL wal,
HTableDescriptor htd,
HRegionInfo hri,
org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor desc,
MultiVersionConcurrencyControl mvcc)
Write a log marker that a bulk load has succeeded and is about to be committed.
|
static long |
writeCompactionMarker(WAL wal,
HTableDescriptor htd,
HRegionInfo hri,
org.apache.hadoop.hbase.protobuf.generated.WALProtos.CompactionDescriptor c,
MultiVersionConcurrencyControl mvcc)
Write the marker that a compaction has succeeded and is about to be committed.
|
static long |
writeFlushMarker(WAL wal,
HTableDescriptor htd,
HRegionInfo hri,
org.apache.hadoop.hbase.protobuf.generated.WALProtos.FlushDescriptor f,
boolean sync,
MultiVersionConcurrencyControl mvcc)
Write a flush marker indicating a start / abort or a complete of a region flush
|
private static long |
writeMarker(WAL wal,
HTableDescriptor htd,
HRegionInfo hri,
WALEdit edit,
MultiVersionConcurrencyControl mvcc,
boolean sync) |
static long |
writeRegionEventMarker(WAL wal,
HTableDescriptor htd,
HRegionInfo hri,
org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor r,
MultiVersionConcurrencyControl mvcc)
Write a region open marker indicating that the region is opened
|
public static long writeCompactionMarker(WAL wal, HTableDescriptor htd, HRegionInfo hri, org.apache.hadoop.hbase.protobuf.generated.WALProtos.CompactionDescriptor c, MultiVersionConcurrencyControl mvcc) throws IOException
mvcc - Used by WAL to get sequence Id for the waledit.IOExceptionpublic static long writeFlushMarker(WAL wal, HTableDescriptor htd, HRegionInfo hri, org.apache.hadoop.hbase.protobuf.generated.WALProtos.FlushDescriptor f, boolean sync, MultiVersionConcurrencyControl mvcc) throws IOException
IOExceptionpublic static long writeRegionEventMarker(WAL wal, HTableDescriptor htd, HRegionInfo hri, org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor r, MultiVersionConcurrencyControl mvcc) throws IOException
IOExceptionpublic static long writeBulkLoadMarkerAndSync(WAL wal, HTableDescriptor htd, HRegionInfo hri, org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor desc, MultiVersionConcurrencyControl mvcc) throws IOException
wal - The log to write into.htd - A description of the table that we are bulk loading into.hri - A description of the region in the table that we are bulk loading into.desc - A protocol buffers based description of the client's bulk loading requestIOException - We will throw an IOException if we can not append to the HLog.private static long writeMarker(WAL wal, HTableDescriptor htd, HRegionInfo hri, WALEdit edit, MultiVersionConcurrencyControl mvcc, boolean sync) throws IOException
IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.