Uses of Class
org.apache.hadoop.hbase.replication.ReplicationPeerConfig
Packages that use ReplicationPeerConfig
Package
Description
Provides HBase Client
Table of Contents
Multi Cluster Replication
-
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.client
Methods in org.apache.hadoop.hbase.client that return ReplicationPeerConfigModifier and TypeMethodDescriptionAdmin.getReplicationPeerConfig(String peerId) Returns the configured ReplicationPeerConfig for the specified peer.AdminOverAsyncAdmin.getReplicationPeerConfig(String peerId) Methods in org.apache.hadoop.hbase.client that return types with arguments of type ReplicationPeerConfigModifier and TypeMethodDescriptionAsyncAdmin.getReplicationPeerConfig(String peerId) Returns the configured ReplicationPeerConfig for the specified peerAsyncHBaseAdmin.getReplicationPeerConfig(String peerId) RawAsyncHBaseAdmin.getReplicationPeerConfig(String peerId) Methods in org.apache.hadoop.hbase.client with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptiondefault voidAdmin.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig) Add a new replication peer for replicating data to slave cluster.default voidAdmin.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) Add a new replication peer for replicating data to slave cluster.default CompletableFuture<Void>AsyncAdmin.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig) Add a new replication peer for replicating data to slave clusterAsyncAdmin.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) Add a new replication peer for replicating data to slave clusterAsyncHBaseAdmin.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) RawAsyncHBaseAdmin.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) Admin.addReplicationPeerAsync(String peerId, ReplicationPeerConfig peerConfig) Add a new replication peer but does not block and wait for it.Admin.addReplicationPeerAsync(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) Add a new replication peer but does not block and wait for it.AdminOverAsyncAdmin.addReplicationPeerAsync(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) default voidAdmin.updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) Update the peerConfig for the specified peer.AsyncAdmin.updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) Update the peerConfig for the specified peerAsyncHBaseAdmin.updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) RawAsyncHBaseAdmin.updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) Admin.updateReplicationPeerConfigAsync(String peerId, ReplicationPeerConfig peerConfig) Update the peerConfig for the specified peer but does not block and wait for it.AdminOverAsyncAdmin.updateReplicationPeerConfigAsync(String peerId, ReplicationPeerConfig peerConfig) -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.client.replication
Methods in org.apache.hadoop.hbase.client.replication that return ReplicationPeerConfigModifier and TypeMethodDescriptionstatic ReplicationPeerConfigReplicationPeerConfigUtil.appendExcludeTableCFsToReplicationPeerConfig(Map<TableName, List<String>> excludeTableCfs, ReplicationPeerConfig peerConfig) static ReplicationPeerConfigReplicationPeerConfigUtil.appendTableCFsToReplicationPeerConfig(Map<TableName, List<String>> tableCfs, ReplicationPeerConfig peerConfig) static ReplicationPeerConfigReplicationPeerConfigUtil.convert(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeer peer) static ReplicationPeerConfigReplicationPeerConfigUtil.parsePeerFrom(byte[] bytes) Parse the serialized representation of a peer configuration.static ReplicationPeerConfigReplicationPeerConfigUtil.removeExcludeTableCFsFromReplicationPeerConfig(Map<TableName, List<String>> excludeTableCfs, ReplicationPeerConfig peerConfig, String id) static ReplicationPeerConfigReplicationPeerConfigUtil.removeTableCFsFromReplicationPeerConfig(Map<TableName, List<String>> tableCfs, ReplicationPeerConfig peerConfig, String id) static ReplicationPeerConfigReplicationPeerConfigUtil.updateReplicationBasePeerConfigs(org.apache.hadoop.conf.Configuration conf, ReplicationPeerConfig receivedPeerConfig) Helper method to add/removev base peer configs from Configuration to ReplicationPeerConfig This merges the user supplied peer configurationReplicationPeerConfigwith peer configs provided as property hbase.replication.peer.base.configs in hbase configuration.Methods in org.apache.hadoop.hbase.client.replication with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptionstatic ReplicationPeerConfigReplicationPeerConfigUtil.appendExcludeTableCFsToReplicationPeerConfig(Map<TableName, List<String>> excludeTableCfs, ReplicationPeerConfig peerConfig) static ReplicationPeerConfigReplicationPeerConfigUtil.appendTableCFsToReplicationPeerConfig(Map<TableName, List<String>> tableCfs, ReplicationPeerConfig peerConfig) static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeerReplicationPeerConfigUtil.convert(ReplicationPeerConfig peerConfig) static org.apache.hadoop.conf.ConfigurationReplicationPeerConfigUtil.getPeerClusterConfiguration(org.apache.hadoop.conf.Configuration conf, ReplicationPeerConfig peerConfig) Returns the configuration needed to talk to the remote slave cluster.static ReplicationPeerConfigReplicationPeerConfigUtil.removeExcludeTableCFsFromReplicationPeerConfig(Map<TableName, List<String>> excludeTableCfs, ReplicationPeerConfig peerConfig, String id) static ReplicationPeerConfigReplicationPeerConfigUtil.removeTableCFsFromReplicationPeerConfig(Map<TableName, List<String>> tableCfs, ReplicationPeerConfig peerConfig, String id) static byte[]ReplicationPeerConfigUtil.toByteArray(ReplicationPeerConfig peerConfig) Returns Serialized protobuf ofpeerConfigwith pb magic prefix prepended suitable for use as content of a this.peersZNode; i.e.static ReplicationPeerConfigReplicationPeerConfigUtil.updateReplicationBasePeerConfigs(org.apache.hadoop.conf.Configuration conf, ReplicationPeerConfig receivedPeerConfig) Helper method to add/removev base peer configs from Configuration to ReplicationPeerConfig This merges the user supplied peer configurationReplicationPeerConfigwith peer configs provided as property hbase.replication.peer.base.configs in hbase configuration. -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.coprocessor
Methods in org.apache.hadoop.hbase.coprocessor with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptiondefault voidMasterObserver.postAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called after add a replication peerdefault voidMasterObserver.postUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called after update peerConfig for the specified peerdefault voidMasterObserver.preAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called before add a replication peerdefault voidMasterObserver.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called before update peerConfig for the specified peer -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.mapreduce.replication
Methods in org.apache.hadoop.hbase.mapreduce.replication that return types with arguments of type ReplicationPeerConfigModifier and TypeMethodDescriptionprivate static Pair<ReplicationPeerConfig,org.apache.hadoop.conf.Configuration> VerifyReplication.getPeerQuorumConfig(org.apache.hadoop.conf.Configuration conf, String peerId) -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.master
Methods in org.apache.hadoop.hbase.master that return ReplicationPeerConfigModifier and TypeMethodDescriptionHMaster.getReplicationPeerConfig(String peerId) MasterServices.getReplicationPeerConfig(String peerId) Returns the configured ReplicationPeerConfig for the specified peerMethods in org.apache.hadoop.hbase.master with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptionlongHMaster.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) longMasterServices.addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) Add a new replication peer for replicating data to slave clustervoidMasterCoprocessorHost.postAddReplicationPeer(String peerId, ReplicationPeerConfig peerConfig) voidMasterCoprocessorHost.postUpdateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) voidMasterCoprocessorHost.preAddReplicationPeer(String peerId, ReplicationPeerConfig peerConfig) voidMasterCoprocessorHost.preUpdateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) longHMaster.updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) longMasterServices.updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig) Update the peerConfig for the specified peer -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.master.replication
Fields in org.apache.hadoop.hbase.master.replication declared as ReplicationPeerConfigModifier and TypeFieldDescriptionprivate ReplicationPeerConfigUpdatePeerConfigProcedure.oldPeerConfigprivate ReplicationPeerConfigAddPeerProcedure.peerConfigprivate ReplicationPeerConfigRemovePeerProcedure.peerConfigprivate ReplicationPeerConfigUpdatePeerConfigProcedure.peerConfigMethods in org.apache.hadoop.hbase.master.replication that return ReplicationPeerConfigModifier and TypeMethodDescriptionprotected ReplicationPeerConfigAddPeerProcedure.getNewPeerConfig()protected ReplicationPeerConfigModifyPeerProcedure.getNewPeerConfig()protected ReplicationPeerConfigUpdatePeerConfigProcedure.getNewPeerConfig()protected ReplicationPeerConfigModifyPeerProcedure.getOldPeerConfig()protected ReplicationPeerConfigUpdatePeerConfigProcedure.getOldPeerConfig()(package private) ReplicationPeerConfigReplicationPeerManager.preRemovePeer(String peerId) Methods in org.apache.hadoop.hbase.master.replication that return types with arguments of type ReplicationPeerConfigMethods in org.apache.hadoop.hbase.master.replication with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptionvoidReplicationPeerManager.addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) private voidReplicationPeerManager.checkConfiguredWALEntryFilters(ReplicationPeerConfig peerConfig) private voidReplicationPeerManager.checkPeerConfig(ReplicationPeerConfig peerConfig) private voidReplicationPeerManager.checkPeerConfigForSyncReplication(ReplicationPeerConfig peerConfig) private voidReplicationPeerManager.checkSyncReplicationPeerConfigConflict(ReplicationPeerConfig peerConfig) (package private) voidReplicationPeerManager.preAddPeer(String peerId, ReplicationPeerConfig peerConfig) (package private) ReplicationPeerDescriptionReplicationPeerManager.preUpdatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) Return the old peer description.protected final voidAbstractPeerProcedure.setLastPushedSequenceId(MasterProcedureEnv env, ReplicationPeerConfig peerConfig) voidReplicationPeerManager.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) Constructors in org.apache.hadoop.hbase.master.replication with parameters of type ReplicationPeerConfigModifierConstructorDescriptionAddPeerProcedure(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) UpdatePeerConfigProcedure(String peerId, ReplicationPeerConfig peerConfig) -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.replication
Fields in org.apache.hadoop.hbase.replication declared as ReplicationPeerConfigModifier and TypeFieldDescriptionprivate final ReplicationPeerConfigReplicationPeerDescription.configprivate ReplicationPeerConfigReplicationPeerImpl.peerConfigMethods in org.apache.hadoop.hbase.replication that return ReplicationPeerConfigModifier and TypeMethodDescriptionReplicationPeerConfig.ReplicationPeerConfigBuilderImpl.build()ReplicationPeerConfigBuilder.build()Builds the configuration object from the current state ofthis.FSReplicationPeerStorage.getPeerConfig(String peerId) ReplicationEndpoint.Context.getPeerConfig()ReplicationPeer.getPeerConfig()Get the peer config objectReplicationPeerDescription.getPeerConfig()ReplicationPeerImpl.getPeerConfig()ReplicationPeerStorage.getPeerConfig(String peerId) Get the peer config of a replication peer.ZKReplicationPeerStorage.getPeerConfig(String peerId) ReplicationPeers.refreshPeerConfig(String peerId) Methods in org.apache.hadoop.hbase.replication with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptionvoidFSReplicationPeerStorage.addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled, SyncReplicationState syncReplicationState) voidReplicationPeerStorage.addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled, SyncReplicationState syncReplicationState) Add a replication peer.voidZKReplicationPeerStorage.addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled, SyncReplicationState syncReplicationState) static booleanReplicationUtils.isNamespacesAndTableCFsEqual(ReplicationPeerConfig rpc1, ReplicationPeerConfig rpc2) static ReplicationPeerConfigBuilderReplicationPeerConfig.newBuilder(ReplicationPeerConfig peerConfig) voidBaseReplicationEndpoint.peerConfigUpdated(ReplicationPeerConfig rpc) voidReplicationPeerConfigListener.peerConfigUpdated(ReplicationPeerConfig rpc) Callback method for when users update the ReplicationPeerConfig for this peervoidReplicationPeerImpl.setPeerConfig(ReplicationPeerConfig peerConfig) voidFSReplicationPeerStorage.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) voidReplicationPeerStorage.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) Update the config a replication peer.voidZKReplicationPeerStorage.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) Constructors in org.apache.hadoop.hbase.replication with parameters of type ReplicationPeerConfigModifierConstructorDescriptionReplicationPeerDescription(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 ReplicationPeerConfig in org.apache.hadoop.hbase.replication.regionserver
Methods in org.apache.hadoop.hbase.replication.regionserver with parameters of type ReplicationPeerConfigModifier and TypeMethodDescription(package private) voidSyncReplicationPeerMappingManager.add(String peerId, ReplicationPeerConfig peerConfig) (package private) voidSyncReplicationPeerMappingManager.remove(String peerId, ReplicationPeerConfig peerConfig) -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.security.access
Methods in org.apache.hadoop.hbase.security.access with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptionvoidAccessController.preAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) voidAccessController.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.security.visibility
Methods in org.apache.hadoop.hbase.security.visibility with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptionvoidVisibilityReplicationEndpoint.peerConfigUpdated(ReplicationPeerConfig rpc) -
Uses of ReplicationPeerConfig in org.apache.hadoop.hbase.thrift2.client
Methods in org.apache.hadoop.hbase.thrift2.client that return ReplicationPeerConfigMethods in org.apache.hadoop.hbase.thrift2.client with parameters of type ReplicationPeerConfigModifier and TypeMethodDescriptionThriftAdmin.addReplicationPeerAsync(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) ThriftAdmin.updateReplicationPeerConfigAsync(String peerId, ReplicationPeerConfig peerConfig)