Uses of Package
org.apache.hadoop.hbase.replication.regionserver
Package
Description
Multi Cluster Replication
-
ClassDescriptionA handler for modifying replication peer in peer procedures.This class is used for exporting some of the info from replication metricsThis chore is responsible to create replication marker rows with special WALEdit with family as
WALEdit.METAFAMILY
and column qualifier asWALEdit.REPLICATION_MARKER
and empty value.This class is responsible to manage all the replication sources.Get the information for a sync replication peer. -
ClassDescriptionUsed by replication to prevent replicating unacked log entries.
-
ClassDescriptionThis class is for maintaining the various replication statistics for a source and publishing them through the metrics interfaces.This class is used for exporting some of the info from replication metricsThis class is responsible for replicating the edits coming from another cluster.
-
ClassDescriptionProvides access to gauges and counters.Hadoop2 implementation of MetricsReplicationSource.This class is for maintaining the various replication statistics for a sink and publishing them through the metrics interfaces.This class is for maintaining the various replication statistics for a source and publishing them through the metrics interfaces.Get notification for replication peer events.A handler for modifying replication peer in peer procedures.Class that handles the recovered source of a replication stream, which is transfered from another dead region server.Used by a
RecoveredReplicationSource
.Check whether we need to reject the replication request from source cluster.Check whether we need to reject the request from client.This class is used for exporting some of the info from replication metricsClass that handles the source of a replication stream.Interface that defines a replication sourceThis class is responsible to manage all the replication sources.This thread reads entries from a queue and ships them.Reads and filters WAL entries, groups the filtered entries into batches, and puts the batches onto a queuePer-peer per-node throttling controller for replication: enabled if bandwidth > 0, a cycle = 100ms, by throttling we guarantee data pushed to peer within each cycle won't exceed 'bandwidth' bytesHelper class to determine whether we can push a given WAL entry without breaking the replication order.Interface that defines how a region server in peer cluster will get source cluster file system configurations.Get the information for a sync replication peer.Used to map region to sync replication peer id.Holds a batch of WAL entries to replicate, along with some statisticsImplementations are installed on a Replication Sink called from inside ReplicationSink#replicateEntries to filter replicated WALEntries based off WALEntry attributes.Streaming access to WAL entries.Used by replication to prevent replicating unacked log entries. -
ClassDescriptionGet notification for replication peer events.Get the information for a sync replication peer.Used by replication to prevent replicating unacked log entries.