Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
private static WALKeyImpl |
WALUtil.doFullMarkerAppendTransaction(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
WALEdit edit,
MultiVersionConcurrencyControl mvcc,
Map<String,byte[]> extendedAttributes,
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,
org.apache.hadoop.hbase.shaded.protobuf.generated.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,
org.apache.hadoop.hbase.shaded.protobuf.generated.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,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor f,
boolean sync,
MultiVersionConcurrencyControl mvcc)
Write a flush marker indicating a start / abort or a complete of a region flush
This write is for internal use only.
|
private static WALKeyImpl |
WALUtil.writeMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
WALEdit edit,
MultiVersionConcurrencyControl mvcc,
Map<String,byte[]> extendedAttributes) |
static WALKeyImpl |
WALUtil.writeRegionEventMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.RegionEventDescriptor r,
MultiVersionConcurrencyControl mvcc)
Write a region open marker indicating that the region is opened.
|
Modifier and Type | Method and Description |
---|---|
protected long |
AsyncFSWAL.append(RegionInfo hri,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore) |
protected long |
FSHLog.append(RegionInfo hri,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore) |
protected abstract long |
AbstractFSWAL.append(RegionInfo info,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore)
Append a set of edits to the WAL.
|
long |
AbstractFSWAL.appendData(RegionInfo info,
WALKeyImpl key,
WALEdit edits) |
long |
AbstractFSWAL.appendMarker(RegionInfo info,
WALKeyImpl key,
WALEdit edits) |
protected long |
AbstractFSWAL.stampSequenceIdAndPublishToRingBuffer(RegionInfo hri,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore,
com.lmax.disruptor.RingBuffer<RingBufferTruck> ringBuffer) |
Constructor and Description |
---|
FSWALEntry(long txid,
WALKeyImpl key,
WALEdit edit,
RegionInfo regionInfo,
boolean inMemstore,
ServerCall<?> rpcCall) |
Modifier and Type | Field and Description |
---|---|
static WALKeyImpl |
WALKeyImpl.EMPTY_WALKEYIMPL |
private WALKeyImpl |
WAL.Entry.key |
Modifier and Type | Method and Description |
---|---|
WALKeyImpl |
WAL.Entry.getKey()
Gets the key n
|
Modifier and Type | Method and Description |
---|---|
private long |
DisabledWALProvider.DisabledWAL.append(RegionInfo info,
WALKeyImpl key,
WALEdit edits,
boolean inMemstore) |
long |
DisabledWALProvider.DisabledWAL.appendData(RegionInfo info,
WALKeyImpl key,
WALEdit edits) |
long |
WAL.appendData(RegionInfo info,
WALKeyImpl key,
WALEdit edits)
Append a set of data edits to the WAL.
|
long |
DisabledWALProvider.DisabledWAL.appendMarker(RegionInfo info,
WALKeyImpl key,
WALEdit edits) |
long |
WAL.appendMarker(RegionInfo info,
WALKeyImpl key,
WALEdit edits)
Append an operational 'meta' event marker edit to the WAL.
|
Constructor and Description |
---|
Entry(WALKeyImpl key,
WALEdit edit)
Constructor for both params
|
WALKeyImpl(WALKeyImpl key,
Map<String,byte[]> extendedAttributes)
Copy constructor that takes in an existing WALKeyImpl plus some extended attributes.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.