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.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.security.access | |
org.apache.hadoop.hbase.security.visibility | |
org.apache.hadoop.hbase.shaded.protobuf |
Modifier and Type | Method and Description |
---|---|
ReplicationPeerConfig |
HBaseAdmin.getReplicationPeerConfig(String peerId) |
ReplicationPeerConfig |
Admin.getReplicationPeerConfig(String peerId)
Returns the configured ReplicationPeerConfig for the specified peer.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ReplicationPeerConfig> |
AsyncAdmin.getReplicationPeerConfig(String peerId)
Returns the configured ReplicationPeerConfig for the specified peer
|
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<Void> |
AsyncAdmin.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig)
Add a new replication peer for replicating data to slave cluster
|
default void |
Admin.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig)
Add a new replication peer for replicating data to slave cluster.
|
void |
HBaseAdmin.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
CompletableFuture<Void> |
AsyncAdmin.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled)
Add a new replication peer for replicating data to slave cluster
|
void |
Admin.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled)
Add a new replication peer for replicating data to slave cluster.
|
default Future<Void> |
Admin.addReplicationPeerAsync(String peerId,
ReplicationPeerConfig peerConfig)
Add a new replication peer but does not block and wait for it.
|
Future<Void> |
HBaseAdmin.addReplicationPeerAsync(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
Future<Void> |
Admin.addReplicationPeerAsync(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled)
Add a new replication peer but does not block and wait for it.
|
void |
HBaseAdmin.updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
CompletableFuture<Void> |
AsyncAdmin.updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig)
Update the peerConfig for the specified peer
|
void |
Admin.updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig)
Update the peerConfig for the specified peer.
|
Future<Void> |
HBaseAdmin.updateReplicationPeerConfigAsync(String peerId,
ReplicationPeerConfig peerConfig) |
Future<Void> |
Admin.updateReplicationPeerConfigAsync(String peerId,
ReplicationPeerConfig peerConfig)
Update the peerConfig for the specified peer but does not block and wait for it.
|
Modifier and Type | Method and Description |
---|---|
Map<String,ReplicationPeerConfig> |
ReplicationAdmin.listPeerConfigs()
Deprecated.
use
Admin.listReplicationPeers() instead |
Modifier and Type | Method and Description |
---|---|
default void |
MasterObserver.postAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig)
Called after add a replication peer
|
default void |
MasterObserver.postUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig)
Called after update peerConfig for the specified peer
|
default void |
MasterObserver.preAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig)
Called before add a replication peer
|
default void |
MasterObserver.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig)
Called before update peerConfig for the specified peer
|
Modifier and Type | Method and Description |
---|---|
ReplicationPeerConfig |
MasterServices.getReplicationPeerConfig(String peerId)
Returns the configured ReplicationPeerConfig for the specified peer
|
ReplicationPeerConfig |
HMaster.getReplicationPeerConfig(String peerId) |
Modifier and Type | Method and Description |
---|---|
long |
MasterServices.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled)
Add a new replication peer for replicating data to slave cluster
|
long |
HMaster.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
void |
MasterCoprocessorHost.postAddReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig) |
void |
MasterCoprocessorHost.postUpdateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
void |
MasterCoprocessorHost.preAddReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig) |
void |
MasterCoprocessorHost.preUpdateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
long |
MasterServices.updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig)
Update the peerConfig for the specified peer
|
long |
HMaster.updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
Modifier and Type | Method and Description |
---|---|
protected ReplicationPeerConfig |
UpdatePeerConfigProcedure.getNewPeerConfig() |
protected ReplicationPeerConfig |
AddPeerProcedure.getNewPeerConfig() |
protected ReplicationPeerConfig |
ModifyPeerProcedure.getNewPeerConfig() |
protected ReplicationPeerConfig |
UpdatePeerConfigProcedure.getOldPeerConfig() |
protected ReplicationPeerConfig |
ModifyPeerProcedure.getOldPeerConfig() |
Modifier and Type | Method and Description |
---|---|
Optional<ReplicationPeerConfig> |
ReplicationPeerManager.getPeerConfig(String peerId) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationPeerManager.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
protected void |
ModifyPeerProcedure.setLastPushedSequenceId(MasterProcedureEnv env,
ReplicationPeerConfig peerConfig) |
void |
ReplicationPeerManager.updatePeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
Constructor and Description |
---|
AddPeerProcedure(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
UpdatePeerConfigProcedure(String peerId,
ReplicationPeerConfig peerConfig) |
Modifier and Type | Method and Description |
---|---|
ReplicationPeerConfig |
ReplicationPeerConfigBuilder.build()
Builds the configuration object from the current state of
this . |
ReplicationPeerConfig |
ReplicationEndpoint.Context.getPeerConfig() |
ReplicationPeerConfig |
ReplicationPeerImpl.getPeerConfig()
Get the peer config object
|
ReplicationPeerConfig |
ReplicationPeer.getPeerConfig()
Get the peer config object
|
ReplicationPeerConfig |
ReplicationPeerDescription.getPeerConfig() |
ReplicationPeerConfig |
ZKReplicationPeerStorage.getPeerConfig(String peerId) |
ReplicationPeerConfig |
ReplicationPeerStorage.getPeerConfig(String peerId)
Get the peer config of a replication peer.
|
ReplicationPeerConfig |
ReplicationPeers.refreshPeerConfig(String peerId) |
ReplicationPeerConfig |
ReplicationPeerConfig.setBandwidth(long bandwidth)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setBandwidth(long) instead. |
ReplicationPeerConfig |
ReplicationPeerConfig.setClusterKey(String clusterKey)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setClusterKey(String) instead. |
ReplicationPeerConfig |
ReplicationPeerConfig.setExcludeNamespaces(Set<String> namespaces)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setExcludeNamespaces(Set) instead. |
ReplicationPeerConfig |
ReplicationPeerConfig.setExcludeTableCFsMap(Map<TableName,? extends Collection<String>> tableCFsMap)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setExcludeTableCFsMap(Map) instead. |
ReplicationPeerConfig |
ReplicationPeerConfig.setNamespaces(Set<String> namespaces)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setNamespaces(Set) instead. |
ReplicationPeerConfig |
ReplicationPeerConfig.setReplicateAllUserTables(boolean replicateAllUserTables)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setReplicateAllUserTables(boolean) instead. |
ReplicationPeerConfig |
ReplicationPeerConfig.setReplicationEndpointImpl(String replicationEndpointImpl)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setReplicationEndpointImpl(String) instead. |
ReplicationPeerConfig |
ReplicationPeerConfig.setTableCFsMap(Map<TableName,? extends Collection<String>> tableCFsMap)
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder.setTableCFsMap(Map) instead. |
Modifier and Type | Method and Description |
---|---|
void |
ZKReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
void |
ReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled)
Add a replication peer.
|
static boolean |
ReplicationUtils.contains(ReplicationPeerConfig peerConfig,
TableName tableName)
Returns whether we should replicate the given table.
|
static org.apache.hadoop.conf.Configuration |
ReplicationUtils.getPeerClusterConfiguration(ReplicationPeerConfig peerConfig,
org.apache.hadoop.conf.Configuration baseConf) |
static boolean |
ReplicationUtils.isNamespacesAndTableCFsEqual(ReplicationPeerConfig rpc1,
ReplicationPeerConfig rpc2) |
static ReplicationPeerConfigBuilder |
ReplicationPeerConfig.newBuilder(ReplicationPeerConfig peerConfig) |
void |
BaseReplicationEndpoint.peerConfigUpdated(ReplicationPeerConfig rpc) |
void |
ReplicationPeerConfigListener.peerConfigUpdated(ReplicationPeerConfig rpc)
Callback method for when users update the ReplicationPeerConfig for this peer
|
void |
ReplicationPeerImpl.setPeerConfig(ReplicationPeerConfig peerConfig) |
void |
ZKReplicationPeerStorage.updatePeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
void |
ReplicationPeerStorage.updatePeerConfig(String peerId,
ReplicationPeerConfig peerConfig)
Update the config a replication peer.
|
Constructor and Description |
---|
ReplicationPeerDescription(String id,
boolean enabled,
ReplicationPeerConfig config) |
ReplicationPeerImpl(org.apache.hadoop.conf.Configuration conf,
String id,
boolean peerState,
ReplicationPeerConfig peerConfig)
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 |
---|---|
void |
AccessController.preAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig) |
void |
AccessController.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig) |
Modifier and Type | Method and Description |
---|---|
void |
VisibilityReplicationEndpoint.peerConfigUpdated(ReplicationPeerConfig rpc) |
Modifier and Type | Method and Description |
---|---|
static ReplicationProtos.AddReplicationPeerRequest |
RequestConverter.buildAddReplicationPeerRequest(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
static ReplicationProtos.UpdateReplicationPeerConfigRequest |
RequestConverter.buildUpdateReplicationPeerConfigRequest(String peerId,
ReplicationPeerConfig peerConfig) |
Copyright © 2007–2019 Cloudera. All rights reserved.