Uses of Enum Class
org.apache.hadoop.hbase.replication.SyncReplicationState
Package
Description
Provides HBase Client
Table of Contents
Multi Cluster Replication
-
Uses of SyncReplicationState in org.apache.hadoop.hbase.client
Modifier and TypeMethodDescriptiondefault SyncReplicationState
Admin.getReplicationPeerSyncReplicationState
(String peerId) Get the current cluster state in a synchronous replication peer.Modifier and TypeMethodDescriptiondefault CompletableFuture<SyncReplicationState>
AsyncAdmin.getReplicationPeerSyncReplicationState
(String peerId) Get the current cluster state in a synchronous replication peer.Modifier and TypeMethodDescriptiondefault void
Admin.transitReplicationPeerSyncReplicationState
(String peerId, SyncReplicationState state) Transit current cluster to a new state in a synchronous replication peer.AsyncAdmin.transitReplicationPeerSyncReplicationState
(String peerId, SyncReplicationState state) Transit current cluster to a new state in a synchronous replication peer.AsyncHBaseAdmin.transitReplicationPeerSyncReplicationState
(String peerId, SyncReplicationState clusterState) RawAsyncHBaseAdmin.transitReplicationPeerSyncReplicationState
(String peerId, SyncReplicationState clusterState) Admin.transitReplicationPeerSyncReplicationStateAsync
(String peerId, SyncReplicationState state) Transit current cluster to a new state in a synchronous replication peer.AdminOverAsyncAdmin.transitReplicationPeerSyncReplicationStateAsync
(String peerId, SyncReplicationState state) -
Uses of SyncReplicationState in org.apache.hadoop.hbase.client.replication
Modifier and TypeMethodDescriptionstatic SyncReplicationState
ReplicationPeerConfigUtil.toSyncReplicationState
(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.SyncReplicationState state) Modifier and TypeMethodDescriptionstatic org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.SyncReplicationState
ReplicationPeerConfigUtil.toSyncReplicationState
(SyncReplicationState state) -
Uses of SyncReplicationState in org.apache.hadoop.hbase.coprocessor
Modifier and TypeMethodDescriptiondefault void
MasterObserver.postTransitReplicationPeerSyncReplicationState
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, SyncReplicationState from, SyncReplicationState to) Called after transit current cluster state for the specified synchronous replication peerdefault void
MasterObserver.preTransitReplicationPeerSyncReplicationState
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, SyncReplicationState state) Called before transit current cluster state for the specified synchronous replication peer -
Uses of SyncReplicationState in org.apache.hadoop.hbase.master
Modifier and TypeMethodDescriptionvoid
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. -
Uses of SyncReplicationState in org.apache.hadoop.hbase.master.replication
Modifier and TypeFieldDescriptionprotected SyncReplicationState
TransitPeerSyncReplicationStateProcedure.fromState
private SyncReplicationState
TransitPeerSyncReplicationStateProcedure.toState
Modifier and TypeFieldDescriptionprivate final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<SyncReplicationState,
EnumSet<SyncReplicationState>> ReplicationPeerManager.allowedTransition
private final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<SyncReplicationState,
EnumSet<SyncReplicationState>> ReplicationPeerManager.allowedTransition
Modifier and TypeMethodDescription(package private) ReplicationPeerDescription
ReplicationPeerManager.preTransitPeerSyncReplicationState
(String peerId, SyncReplicationState state) Returns the old desciption of the peervoid
ReplicationPeerManager.setPeerNewSyncReplicationState
(String peerId, SyncReplicationState state) void
ReplicationPeerManager.transitPeerSyncReplicationState
(String peerId, SyncReplicationState newState) ModifierConstructorDescriptionTransitPeerSyncReplicationStateProcedure
(String peerId, SyncReplicationState state) -
Uses of SyncReplicationState in org.apache.hadoop.hbase.regionserver.compactions
Modifier and TypeMethodDescriptionboolean
ForbidMajorCompactionChecker.test
(SyncReplicationState state, SyncReplicationState newState) -
Uses of SyncReplicationState in org.apache.hadoop.hbase.replication
Modifier and TypeFieldDescriptionprivate final SyncReplicationState
ReplicationPeerDescription.syncReplicationState
Modifier and TypeMethodDescriptionReplicationPeerImpl.getNewSyncReplicationState()
private static SyncReplicationState
ReplicationPeerImpl.getNewSyncReplicationState
(int bits) FSReplicationPeerStorage.getPeerNewSyncReplicationState
(String peerId) ReplicationPeerStorage.getPeerNewSyncReplicationState
(String peerId) Get the new sync replication state.ZKReplicationPeerStorage.getPeerNewSyncReplicationState
(String peerId) FSReplicationPeerStorage.getPeerSyncReplicationState
(String peerId) ReplicationPeerStorage.getPeerSyncReplicationState
(String peerId) Get the sync replication state.ZKReplicationPeerStorage.getPeerSyncReplicationState
(String peerId) ReplicationPeer.getSyncReplicationState()
Returns the sync replication state of the peer by reading local cache.ReplicationPeerDescription.getSyncReplicationState()
ReplicationPeerImpl.getSyncReplicationState()
private static SyncReplicationState
ReplicationPeerImpl.getSyncReplicationState
(int bits) private SyncReplicationState
ZKReplicationPeerStorage.getSyncReplicationState
(String peerId, String path) static SyncReplicationState
SyncReplicationState.parseFrom
(byte[] bytes) ReplicationPeers.refreshPeerNewSyncReplicationState
(String peerId) static SyncReplicationState
SyncReplicationState.valueOf
(int value) Returns the enum constant of this class with the specified name.static SyncReplicationState
Returns the enum constant of this class with the specified name.static SyncReplicationState[]
SyncReplicationState.values()
Returns an array containing the constants of this enum class, in the order they are declared.Modifier and TypeMethodDescriptionprivate Pair<SyncReplicationState,
SyncReplicationState> FSReplicationPeerStorage.getStateAndNewState
(String peerId) private Pair<SyncReplicationState,
SyncReplicationState> FSReplicationPeerStorage.getStateAndNewState
(String peerId) ReplicationPeerImpl.getSyncReplicationStateAndNewState()
ReplicationPeerImpl.getSyncReplicationStateAndNewState()
SyncReplicationState.parseStateAndNewStateFrom
(byte[] bytes) SyncReplicationState.parseStateAndNewStateFrom
(byte[] bytes) Modifier and TypeMethodDescriptionvoid
FSReplicationPeerStorage.addPeer
(String peerId, ReplicationPeerConfig peerConfig, boolean enabled, SyncReplicationState syncReplicationState) 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
ReplicationPeerImpl.setNewSyncReplicationState
(SyncReplicationState newState) void
FSReplicationPeerStorage.setPeerNewSyncReplicationState
(String peerId, 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) static byte[]
SyncReplicationState.toByteArray
(SyncReplicationState state) static byte[]
SyncReplicationState.toByteArray
(SyncReplicationState state, SyncReplicationState newState) ModifierConstructorDescriptionReplicationPeerDescription
(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. -
Uses of SyncReplicationState in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeMethodDescriptiondefault void
PeerActionListener.peerSyncReplicationStateChange
(String peerId, SyncReplicationState from, SyncReplicationState to, int stage) boolean
RejectReplicationRequestStateChecker.test
(SyncReplicationState state, SyncReplicationState newState) boolean
RejectRequestsFromClientStateChecker.test
(SyncReplicationState state, SyncReplicationState newState) Modifier and TypeMethodDescriptionboolean
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) -
Uses of SyncReplicationState in org.apache.hadoop.hbase.security.access
Modifier and TypeMethodDescriptionvoid
AccessController.preTransitReplicationPeerSyncReplicationState
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, SyncReplicationState clusterState) -
Uses of SyncReplicationState in org.apache.hadoop.hbase.thrift2.client
Modifier and TypeMethodDescriptionThriftAdmin.transitReplicationPeerSyncReplicationStateAsync
(String peerId, SyncReplicationState state) -
Uses of SyncReplicationState in org.apache.hadoop.hbase.wal
Modifier and TypeMethodDescriptionvoid
AbstractWALProvider.peerSyncReplicationStateChange
(String peerId, SyncReplicationState from, SyncReplicationState to, int stage)