Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.replication | |
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.master.replication | |
org.apache.hadoop.hbase.regionserver.compactions | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.security.access | |
org.apache.hadoop.hbase.thrift2.client | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
default SyncReplicationState |
Admin.getReplicationPeerSyncReplicationState(String peerId)
Get the current cluster state in a synchronous replication peer.
|
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<SyncReplicationState> |
AsyncAdmin.getReplicationPeerSyncReplicationState(String peerId)
Get the current cluster state in a synchronous replication peer.
|
Modifier and Type | Method and Description |
---|---|
static SyncReplicationState |
ReplicationPeerConfigUtil.toSyncReplicationState(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.SyncReplicationState state) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.SyncReplicationState |
ReplicationPeerConfigUtil.toSyncReplicationState(SyncReplicationState state) |
Modifier and Type | Method and Description |
---|---|
default void |
MasterObserver.postTransitReplicationPeerSyncReplicationState(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
SyncReplicationState from,
SyncReplicationState to)
Called after transit current cluster state for the specified synchronous replication peer
|
default void |
MasterObserver.preTransitReplicationPeerSyncReplicationState(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
SyncReplicationState state)
Called before transit current cluster state for the specified synchronous replication peer
|
Modifier and Type | Method and Description |
---|---|
void |
MasterCoprocessorHost.postTransitReplicationPeerSyncReplicationState(String peerId,
SyncReplicationState from,
SyncReplicationState to) |
void |
MasterCoprocessorHost.preTransitReplicationPeerSyncReplicationState(String peerId,
SyncReplicationState state) |
long |
HMaster.transitReplicationPeerSyncReplicationState(String peerId,
SyncReplicationState state) |
long |
MasterServices.transitReplicationPeerSyncReplicationState(String peerId,
SyncReplicationState clusterState)
Set current cluster state for a synchronous replication peer.
|
Modifier and Type | Field and Description |
---|---|
protected SyncReplicationState |
TransitPeerSyncReplicationStateProcedure.fromState |
private SyncReplicationState |
TransitPeerSyncReplicationStateProcedure.toState |
Modifier and Type | Field and Description |
---|---|
private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<SyncReplicationState,EnumSet<SyncReplicationState>> |
ReplicationPeerManager.allowedTransition |
private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<SyncReplicationState,EnumSet<SyncReplicationState>> |
ReplicationPeerManager.allowedTransition |
Modifier and Type | Method and Description |
---|---|
(package private) ReplicationPeerDescription |
ReplicationPeerManager.preTransitPeerSyncReplicationState(String peerId,
SyncReplicationState state)
Returns the old desciption of the peer
|
void |
ReplicationPeerManager.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState state) |
void |
ReplicationPeerManager.transitPeerSyncReplicationState(String peerId,
SyncReplicationState newState) |
Constructor and Description |
---|
TransitPeerSyncReplicationStateProcedure(String peerId,
SyncReplicationState state) |
Modifier and Type | Method and Description |
---|---|
boolean |
ForbidMajorCompactionChecker.test(SyncReplicationState state,
SyncReplicationState newState) |
Modifier and Type | Field and Description |
---|---|
private SyncReplicationState |
ReplicationPeerDescription.syncReplicationState |
Modifier and Type | Method and Description |
---|---|
SyncReplicationState |
ReplicationPeerImpl.getNewSyncReplicationState() |
private static SyncReplicationState |
ReplicationPeerImpl.getNewSyncReplicationState(int bits) |
SyncReplicationState |
ReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId)
Get the new sync replication state.
|
SyncReplicationState |
ZKReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId) |
SyncReplicationState |
FSReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId) |
SyncReplicationState |
ReplicationPeerStorage.getPeerSyncReplicationState(String peerId)
Get the sync replication state.
|
SyncReplicationState |
ZKReplicationPeerStorage.getPeerSyncReplicationState(String peerId) |
SyncReplicationState |
FSReplicationPeerStorage.getPeerSyncReplicationState(String peerId) |
SyncReplicationState |
ReplicationPeerImpl.getSyncReplicationState() |
SyncReplicationState |
ReplicationPeer.getSyncReplicationState()
Returns the sync replication state of the peer by reading local cache.
|
SyncReplicationState |
ReplicationPeerDescription.getSyncReplicationState() |
private static SyncReplicationState |
ReplicationPeerImpl.getSyncReplicationState(int bits) |
private SyncReplicationState |
ZKReplicationPeerStorage.getSyncReplicationState(String peerId,
String path) |
static SyncReplicationState |
SyncReplicationState.parseFrom(byte[] bytes) |
SyncReplicationState |
ReplicationPeers.refreshPeerNewSyncReplicationState(String peerId) |
static SyncReplicationState |
SyncReplicationState.valueOf(int value) |
static SyncReplicationState |
SyncReplicationState.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static SyncReplicationState[] |
SyncReplicationState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
private Pair<SyncReplicationState,SyncReplicationState> |
FSReplicationPeerStorage.getStateAndNewState(String peerId) |
private Pair<SyncReplicationState,SyncReplicationState> |
FSReplicationPeerStorage.getStateAndNewState(String peerId) |
Pair<SyncReplicationState,SyncReplicationState> |
ReplicationPeerImpl.getSyncReplicationStateAndNewState() |
Pair<SyncReplicationState,SyncReplicationState> |
ReplicationPeerImpl.getSyncReplicationStateAndNewState() |
static Pair<SyncReplicationState,SyncReplicationState> |
SyncReplicationState.parseStateAndNewStateFrom(byte[] bytes) |
static Pair<SyncReplicationState,SyncReplicationState> |
SyncReplicationState.parseStateAndNewStateFrom(byte[] bytes) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled,
SyncReplicationState syncReplicationState)
Add a replication peer.
|
void |
ZKReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled,
SyncReplicationState syncReplicationState) |
void |
FSReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled,
SyncReplicationState syncReplicationState) |
void |
ReplicationPeerImpl.setNewSyncReplicationState(SyncReplicationState newState) |
void |
ReplicationPeerStorage.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState state)
Set the new sync replication state that we are going to transit to.
|
void |
ZKReplicationPeerStorage.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState state) |
void |
FSReplicationPeerStorage.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState newState) |
static byte[] |
SyncReplicationState.toByteArray(SyncReplicationState state) |
static byte[] |
SyncReplicationState.toByteArray(SyncReplicationState state,
SyncReplicationState newState) |
Constructor and Description |
---|
ReplicationPeerDescription(String id,
boolean enabled,
ReplicationPeerConfig config,
SyncReplicationState syncReplicationState) |
ReplicationPeerImpl(org.apache.hadoop.conf.Configuration conf,
String id,
ReplicationPeerConfig peerConfig,
boolean peerState,
SyncReplicationState syncReplicationState,
SyncReplicationState newSyncReplicationState)
Constructor that takes all the objects required to communicate with the specified peer, except
for the region server addresses.
|
Modifier and Type | Method and Description |
---|---|
default void |
PeerActionListener.peerSyncReplicationStateChange(String peerId,
SyncReplicationState from,
SyncReplicationState to,
int stage) |
boolean |
RejectRequestsFromClientStateChecker.test(SyncReplicationState state,
SyncReplicationState newState) |
boolean |
RejectReplicationRequestStateChecker.test(SyncReplicationState state,
SyncReplicationState newState) |
Modifier and Type | Method and Description |
---|---|
boolean |
SyncReplicationPeerInfoProvider.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.
|
boolean |
SyncReplicationPeerInfoProvider.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.
|
boolean |
SyncReplicationPeerInfoProviderImpl.checkState(TableName table,
BiPredicate<SyncReplicationState,SyncReplicationState> checker) |
boolean |
SyncReplicationPeerInfoProviderImpl.checkState(TableName table,
BiPredicate<SyncReplicationState,SyncReplicationState> checker) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.preTransitReplicationPeerSyncReplicationState(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
SyncReplicationState clusterState) |
Modifier and Type | Method and Description |
---|---|
Future<Void> |
ThriftAdmin.transitReplicationPeerSyncReplicationStateAsync(String peerId,
SyncReplicationState state) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractWALProvider.peerSyncReplicationStateChange(String peerId,
SyncReplicationState from,
SyncReplicationState to,
int stage) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.