Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
static WALKeyImpl |
WALUtil.doFullAppendTransaction(WAL wal,
NavigableMap<byte[],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 WALKeyImpl |
WALUtil.writeBulkLoadMarkerAndSync(WAL wal,
NavigableMap<byte[],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 |
WALUtil.writeCompactionMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
WALProtos.CompactionDescriptor c,
MultiVersionConcurrencyControl mvcc)
Write the marker that a compaction has succeeded and is about to be committed.
|
static WALKeyImpl |
WALUtil.writeFlushMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
WALProtos.FlushDescriptor f,
boolean sync,
MultiVersionConcurrencyControl mvcc)
Write a flush marker indicating a start / abort or a complete of a region flush
|
static WALKeyImpl |
WALUtil.writeRegionEventMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
WALProtos.RegionEventDescriptor r,
MultiVersionConcurrencyControl mvcc)
Write a region open marker indicating that the region is opened.
|
Modifier and Type | Method and Description |
---|---|
long |
FSHLog.append(RegionInfo hri,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore) |
long |
AsyncFSWAL.append(RegionInfo hri,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore) |
abstract long |
AbstractFSWAL.append(RegionInfo info,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore)
NOTE: This append, at a time that is usually after this call returns, starts an mvcc
transaction by calling 'begin' wherein which we assign this update a sequenceid.
|
protected long |
AbstractFSWAL.stampSequenceIdAndPublishToRingBuffer(RegionInfo hri,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore,
com.lmax.disruptor.RingBuffer<org.apache.hadoop.hbase.regionserver.wal.RingBufferTruck> ringBuffer) |
Modifier and Type | Field and Description |
---|---|
static WALKeyImpl |
WALKeyImpl.EMPTY_WALKEYIMPL |
Modifier and Type | Method and Description |
---|---|
WALKeyImpl |
WAL.Entry.getKey()
Gets the key
|
Modifier and Type | Method and Description |
---|---|
long |
WAL.append(RegionInfo info,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore)
Append a set of edits to the WAL.
|
Constructor and Description |
---|
Entry(WALKeyImpl key,
WALEdit edit)
Constructor for both params
|
Copyright © 2007–2019 Cloudera. All rights reserved.