Package org.apache.hadoop.hbase.replication.regionserver

Class SyncReplicationPeerInfoProviderImpl

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.SyncReplicationPeerInfoProviderImpl

All Implemented Interfaces:

SyncReplicationPeerInfoProvider

@Private
class SyncReplicationPeerInfoProviderImpl
extends Object
implements SyncReplicationPeerInfoProvider

Field Summary

Fields

Modifier and Type	Field	Description
private final SyncReplicationPeerMappingManager	mapping
private final ReplicationPeers	replicationPeers

Constructor Summary

Constructors

Constructor	Description
SyncReplicationPeerInfoProviderImpl(ReplicationPeers replicationPeers, SyncReplicationPeerMappingManager mapping)

Method Summary

Modifier and Type	Method	Description
boolean	checkState(TableName table, BiPredicate<SyncReplicationState,SyncReplicationState> checker)	Check whether the given table is contained in a sync replication peer which can pass the state checker.
Optional<Pair<String,String>>	getPeerIdAndRemoteWALDir(TableName table)	Return the peer id and remote WAL directory if the table is synchronously replicated and the state is SyncReplicationState.ACTIVE.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

replicationPeers

private final ReplicationPeers replicationPeers

mapping

private final SyncReplicationPeerMappingManager mapping

Constructor Details

SyncReplicationPeerInfoProviderImpl

SyncReplicationPeerInfoProviderImpl(ReplicationPeers replicationPeers,
 SyncReplicationPeerMappingManager mapping)

Method Details

getPeerIdAndRemoteWALDir

public Optional<Pair<String,String>> getPeerIdAndRemoteWALDir(TableName table)

Description copied from interface: SyncReplicationPeerInfoProvider

Return the peer id and remote WAL directory if the table is synchronously replicated and the state is SyncReplicationState.ACTIVE.

Specified by:

getPeerIdAndRemoteWALDir in interface SyncReplicationPeerInfoProvider

checkState

public boolean checkState(TableName table,
 BiPredicate<SyncReplicationState,SyncReplicationState> checker)

Description copied from interface: SyncReplicationPeerInfoProvider

Check whether the given table is contained in a sync replication peer which can pass the state checker.

Will call the checker with current sync replication state and new sync replication state.

Specified by:

checkState in interface SyncReplicationPeerInfoProvider