Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.wal |
Modifier and Type | Field and Description |
---|---|
protected Optional<RegionReplicationSink> |
HRegion.regionReplicationSink |
Modifier and Type | Method and Description |
---|---|
Optional<RegionReplicationSink> |
HRegion.getRegionReplicationSink() |
Modifier and Type | Method and Description |
---|---|
private void |
HRegion.attachRegionReplicationToFlushOpSeqIdMVCCEntry(MultiVersionConcurrencyControl.WriteEntry flushOpSeqIdMVCCEntry,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor desc,
RegionReplicationSink sink)
Create
WALEdit for WALProtos.FlushDescriptor and attach add(org.apache.hadoop.hbase.wal.WALKeyImpl, org.apache.hadoop.hbase.wal.WALEdit, org.apache.hadoop.hbase.ipc.ServerCall<?>)
to the flushOpSeqIdMVCCEntry. |
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,
RegionReplicationSink sink)
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,
RegionReplicationSink sink)
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,
RegionReplicationSink sink)
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,
RegionReplicationSink sink)
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,
RegionReplicationSink sink) |
static WALKeyImpl |
WALUtil.writeRegionEventMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.RegionEventDescriptor r,
MultiVersionConcurrencyControl mvcc,
RegionReplicationSink sink)
Write a region open marker indicating that the region is opened.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.