Package | Description |
---|---|
org.apache.hadoop.hbase.replication | |
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Class and Description |
---|---|
class |
BaseWALEntryFilter
A base class WALEntryFilter implementations.
|
class |
ChainWALEntryFilter
A
WALEntryFilter which contains multiple filters and applies them
in chain order |
class |
ClusterMarkingEntryFilter
Filters out entries with our peerClusterId (i.e.
|
class |
NamespaceTableCfWALEntryFilter
Filter a WAL Entry by the peer config: replicate_all flag, namespaces config, table-cfs config,
exclude namespaces config, and exclude table-cfs config.
|
class |
ScopeWALEntryFilter
Keeps KVs that are scoped other than local
|
class |
SystemTableWALEntryFilter
Skips WAL edits for all System tables including META
|
Modifier and Type | Method and Description |
---|---|
protected WALEntryFilter |
BaseReplicationEndpoint.getNamespaceTableCfWALEntryFilter()
Returns a WALEntryFilter for checking replication per table and CF.
|
protected WALEntryFilter |
BaseReplicationEndpoint.getScopeWALEntryFilter()
Returns a WALEntryFilter for checking the scope.
|
WALEntryFilter |
ReplicationEndpoint.getWALEntryfilter()
Returns a WALEntryFilter to use for filtering out WALEntries from the log.
|
WALEntryFilter |
BaseReplicationEndpoint.getWALEntryfilter()
Returns a default set of filters
|
Constructor and Description |
---|
ChainWALEntryFilter(WALEntryFilter... filters) |
Constructor and Description |
---|
ChainWALEntryFilter(java.util.List<WALEntryFilter> filters) |
Modifier and Type | Field and Description |
---|---|
protected WALEntryFilter |
ReplicationSource.walEntryFilter |
Modifier and Type | Method and Description |
---|---|
protected WALEntryFilter |
RegionReplicaReplicationEndpoint.getScopeWALEntryFilter() |
Constructor and Description |
---|
RecoveredReplicationSourceWALReader(FileSystem fs,
Configuration conf,
java.util.concurrent.PriorityBlockingQueue<Path> logQueue,
long startPosition,
WALEntryFilter filter,
ReplicationSource source) |
ReplicationSourceWALReader(FileSystem fs,
Configuration conf,
java.util.concurrent.PriorityBlockingQueue<Path> logQueue,
long startPosition,
WALEntryFilter filter,
ReplicationSource source)
Creates a reader worker for a given WAL queue.
|