public class WALUtil
extends java.lang.Object
WAL
. For internal use only.Modifier and Type | Method and Description |
---|---|
static WALKeyImpl |
doFullAppendTransaction(WAL wal,
java.util.NavigableMap<byte[],java.lang.Integer> replicationScope,
RegionInfo hri,
WALEdit edit,
MultiVersionConcurrencyControl mvcc,
boolean sync)
A 'full' WAL transaction involves starting an mvcc transaction followed by an append,
an optional sync, and then a call to complete the mvcc transaction.
|
static long |
getWALBlockSize(Configuration conf,
FileSystem fs,
Path dir)
Blocksize returned here is 2x the default HDFS blocksize unless explicitly set in
Configuration.
|
static WALKeyImpl |
writeBulkLoadMarkerAndSync(WAL wal,
java.util.NavigableMap<byte[],java.lang.Integer> replicationScope,
RegionInfo hri,
WALProtos.BulkLoadDescriptor desc,
MultiVersionConcurrencyControl mvcc)
Write a log marker that a bulk load has succeeded and is about to be committed.
|
static WALKeyImpl |
writeCompactionMarker(WAL wal,
java.util.NavigableMap<byte[],java.lang.Integer> replicationScope,
RegionInfo hri,
CompactionDescriptor c,
MultiVersionConcurrencyControl mvcc)
Write the marker that a compaction has succeeded and is about to be committed.
|
static WALKeyImpl |
writeFlushMarker(WAL wal,
java.util.NavigableMap<byte[],java.lang.Integer> replicationScope,
RegionInfo hri,
FlushDescriptor f,
boolean sync,
MultiVersionConcurrencyControl mvcc)
Write a flush marker indicating a start / abort or a complete of a region flush
|
static WALKeyImpl |
writeRegionEventMarker(WAL wal,
java.util.NavigableMap<byte[],java.lang.Integer> replicationScope,
RegionInfo hri,
RegionEventDescriptor r,
MultiVersionConcurrencyControl mvcc)
Write a region open marker indicating that the region is opened.
|
public static WALKeyImpl writeCompactionMarker(WAL wal, java.util.NavigableMap<byte[],java.lang.Integer> replicationScope, RegionInfo hri, CompactionDescriptor c, MultiVersionConcurrencyControl mvcc) throws java.io.IOException
This write is for internal use only. Not for external client consumption.
mvcc
- Used by WAL to get sequence Id for the waledit.java.io.IOException
public static WALKeyImpl writeFlushMarker(WAL wal, java.util.NavigableMap<byte[],java.lang.Integer> replicationScope, RegionInfo hri, FlushDescriptor f, boolean sync, MultiVersionConcurrencyControl mvcc) throws java.io.IOException
This write is for internal use only. Not for external client consumption.
java.io.IOException
public static WALKeyImpl writeRegionEventMarker(WAL wal, java.util.NavigableMap<byte[],java.lang.Integer> replicationScope, RegionInfo hri, RegionEventDescriptor r, MultiVersionConcurrencyControl mvcc) throws java.io.IOException
java.io.IOException
public static WALKeyImpl writeBulkLoadMarkerAndSync(WAL wal, java.util.NavigableMap<byte[],java.lang.Integer> replicationScope, RegionInfo hri, WALProtos.BulkLoadDescriptor desc, MultiVersionConcurrencyControl mvcc) throws java.io.IOException
wal
- The log to write into.replicationScope
- The replication scope of the families in the HRegionhri
- 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 requestjava.io.IOException
- We will throw an IOException if we can not append to the HLog.public static WALKeyImpl doFullAppendTransaction(WAL wal, java.util.NavigableMap<byte[],java.lang.Integer> replicationScope, RegionInfo hri, WALEdit edit, MultiVersionConcurrencyControl mvcc, boolean sync) throws java.io.IOException
This write is for internal use only. Not for external client consumption.
java.io.IOException
public static long getWALBlockSize(Configuration conf, FileSystem fs, Path dir) throws java.io.IOException
java.io.IOException