org.apache.hadoop.hbase.wal

Class SyncReplicationWALProvider.DefaultSyncReplicationPeerInfoProvider

java.lang.Object

org.apache.hadoop.hbase.wal.SyncReplicationWALProvider.DefaultSyncReplicationPeerInfoProvider

All Implemented Interfaces:

SyncReplicationPeerInfoProvider

Enclosing class:

SyncReplicationWALProvider

private static class SyncReplicationWALProvider.DefaultSyncReplicationPeerInfoProvider
extends Object
implements SyncReplicationPeerInfoProvider

Constructor Summary

Constructors

Modifier	Constructor and Description
private	DefaultSyncReplicationPeerInfoProvider()

Method Summary

Modifier and Type	Method and 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

Constructor Detail

DefaultSyncReplicationPeerInfoProvider

private DefaultSyncReplicationPeerInfoProvider()

Method Detail

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