Uses of Class
org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink
-
Uses of RegionReplicationSink in org.apache.hadoop.hbase.regionserver
Modifier and TypeFieldDescriptionprotected Optional<RegionReplicationSink>
HRegion.regionReplicationSink
Modifier and TypeMethodDescriptionprivate void
HRegion.attachRegionReplicationToFlushOpSeqIdMVCCEntry
(MultiVersionConcurrencyControl.WriteEntry flushOpSeqIdMVCCEntry, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor desc, RegionReplicationSink sink) CreateWALEdit
forWALProtos.FlushDescriptor
and attachadd(org.apache.hadoop.hbase.wal.WALKeyImpl, org.apache.hadoop.hbase.wal.WALEdit, org.apache.hadoop.hbase.ipc.ServerCall<?>)
to the flushOpSeqIdMVCCEntry. -
Uses of RegionReplicationSink in org.apache.hadoop.hbase.regionserver.wal
Modifier and TypeMethodDescriptionprivate 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 flushprivate 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.