@InterfaceAudience.Private public interface SyncReplicationPeerInfoProvider
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 . |
Optional<Pair<String,String>> getPeerIdAndRemoteWALDir(TableName table)
SyncReplicationState.ACTIVE
.boolean checkState(TableName table, BiPredicate<SyncReplicationState,SyncReplicationState> checker)
Will call the checker with current sync replication state and new sync replication state.
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.