Package org.apache.hadoop.hbase.replication

Class ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl

All Implemented Interfaces:

ReplicationPeerConfigBuilder

Enclosing class:

ReplicationPeerConfig

static class ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl
extends Object
implements ReplicationPeerConfigBuilder

Field Summary

Fields

Modifier and Type	Field	Description
private long	bandwidth
private String	clusterKey
private Map<String,String>	configuration
private Set<String>	excludeNamespaces
private Map<TableName,List<String>>	excludeTableCFsMap
private Set<String>	namespaces
private Map<byte[],byte[]>	peerData
private String	remoteWALDir
private boolean	replicateAllUserTables
private String	replicationEndpointImpl
private boolean	serial
private Map<TableName,List<String>>	tableCFsMap

Constructor Summary

Constructors

Constructor	Description
ReplicationPeerConfigBuilderImpl()

Method Summary

Modifier and Type	Method	Description
ReplicationPeerConfig	build()	Builds the configuration object from the current state of this.
ReplicationPeerConfigBuilder	putConfiguration(String key, String value)	Sets a "raw" configuration property for this replication peer.
ReplicationPeerConfigBuilder	putPeerData(byte[] key, byte[] value)	Sets the serialized peer configuration data
ReplicationPeerConfigBuilder	removeConfiguration(String key)	Removes a "raw" configuration property for this replication peer.
ReplicationPeerConfigBuilder	setBandwidth(long bandwidth)	Sets the speed, in bytes per second, for any one RegionServer to replicate data to the peer.
ReplicationPeerConfigBuilder	setClusterKey(String clusterKey)	Set the clusterKey which is the concatenation of the slave cluster's: hbase.zookeeper.quorum:hbase.zookeeper.property.clientPort:zookeeper.znode.parent
ReplicationPeerConfigBuilder	setExcludeNamespaces(Set<String> excludeNamespaces)	Sets the collection of namespaces which should not be replicated when all user tables are configured to be replicated.
ReplicationPeerConfigBuilder	setExcludeTableCFsMap(Map<TableName,List<String>> excludeTableCFsMap)	Sets the mapping of table name to column families which should not be replicated.
ReplicationPeerConfigBuilder	setNamespaces(Set<String> namespaces)	Sets a unique collection of HBase namespaces that should be replicated to this peer.
ReplicationPeerConfigBuilder	setRemoteWALDir(String dir)	Set the remote peer cluster's wal directory.
ReplicationPeerConfigBuilder	setReplicateAllUserTables(boolean replicateAllUserTables)	Configures HBase to replicate all user tables (not system tables) to the peer.
ReplicationPeerConfigBuilder	setReplicationEndpointImpl(String replicationEndpointImpl)	Sets the ReplicationEndpoint plugin class for this peer.
ReplicationPeerConfigBuilder	setSerial(boolean serial)	Sets whether we should preserve order when replicating, i.e, serial replication.
ReplicationPeerConfigBuilder	setTableCFsMap(Map<TableName,List<String>> tableCFsMap)	Sets an explicit map of tables and column families in those tables that should be replicated to the given peer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationPeerConfigBuilder

putAllConfiguration, putAllPeerData

Field Details

clusterKey

private String clusterKey

replicationEndpointImpl

private String replicationEndpointImpl

peerData

private Map<byte[],byte[]> peerData

configuration

private Map<String,String> configuration

tableCFsMap

private Map<TableName,List<String>> tableCFsMap

namespaces

private Set<String> namespaces

replicateAllUserTables

private boolean replicateAllUserTables

excludeTableCFsMap

private Map<TableName,List<String>> excludeTableCFsMap

excludeNamespaces

private Set<String> excludeNamespaces

bandwidth

private long bandwidth

serial

private boolean serial

remoteWALDir

private String remoteWALDir

Constructor Details

ReplicationPeerConfigBuilderImpl

ReplicationPeerConfigBuilderImpl()

Method Details

setClusterKey

public ReplicationPeerConfigBuilder setClusterKey(String clusterKey)

Description copied from interface: ReplicationPeerConfigBuilder

Set the clusterKey which is the concatenation of the slave cluster's: hbase.zookeeper.quorum:hbase.zookeeper.property.clientPort:zookeeper.znode.parent

Specified by:

setClusterKey in interface ReplicationPeerConfigBuilder

setReplicationEndpointImpl

public ReplicationPeerConfigBuilder setReplicationEndpointImpl(String replicationEndpointImpl)

Description copied from interface: ReplicationPeerConfigBuilder

Sets the ReplicationEndpoint plugin class for this peer.

Specified by:

setReplicationEndpointImpl in interface ReplicationPeerConfigBuilder

Parameters:

replicationEndpointImpl - a class implementing ReplicationEndpoint

putConfiguration

public ReplicationPeerConfigBuilder putConfiguration(String key,
 String value)

Description copied from interface: ReplicationPeerConfigBuilder

Sets a "raw" configuration property for this replication peer. For experts only.

Specified by:

putConfiguration in interface ReplicationPeerConfigBuilder

Parameters:

key - Configuration property key

value - Configuration property value

Returns:

this

removeConfiguration

public ReplicationPeerConfigBuilder removeConfiguration(String key)

Description copied from interface: ReplicationPeerConfigBuilder

Removes a "raw" configuration property for this replication peer. For experts only.

Specified by:

removeConfiguration in interface ReplicationPeerConfigBuilder

Parameters:

key - Configuration property key to ve removed

Returns:

this

putPeerData

public ReplicationPeerConfigBuilder putPeerData(byte[] key,
 byte[] value)

Description copied from interface: ReplicationPeerConfigBuilder

Sets the serialized peer configuration data

Specified by:

putPeerData in interface ReplicationPeerConfigBuilder

Returns:

this

setTableCFsMap

public ReplicationPeerConfigBuilder setTableCFsMap(Map<TableName,List<String>> tableCFsMap)

Description copied from interface: ReplicationPeerConfigBuilder

Sets an explicit map of tables and column families in those tables that should be replicated to the given peer. Use ReplicationPeerConfigBuilder.setReplicateAllUserTables(boolean) to replicate all tables to a peer.

Specified by:

setTableCFsMap in interface ReplicationPeerConfigBuilder

Parameters:

tableCFsMap - A map from tableName to column family names. An empty collection can be passed to indicate replicating all column families.

Returns:

this

See Also:

• ReplicationPeerConfigBuilder.setReplicateAllUserTables(boolean)

setNamespaces

public ReplicationPeerConfigBuilder setNamespaces(Set<String> namespaces)

Description copied from interface: ReplicationPeerConfigBuilder

Sets a unique collection of HBase namespaces that should be replicated to this peer.

Specified by:

setNamespaces in interface ReplicationPeerConfigBuilder

Parameters:

namespaces - A set of namespaces to be replicated to this peer.

Returns:

this

setReplicateAllUserTables

public ReplicationPeerConfigBuilder setReplicateAllUserTables(boolean replicateAllUserTables)

Description copied from interface: ReplicationPeerConfigBuilder

Configures HBase to replicate all user tables (not system tables) to the peer. Default is true.

Specified by:

setReplicateAllUserTables in interface ReplicationPeerConfigBuilder

Parameters:

replicateAllUserTables - True if all user tables should be replicated, else false.

Returns:

this

setExcludeTableCFsMap

public ReplicationPeerConfigBuilder setExcludeTableCFsMap(Map<TableName,List<String>> excludeTableCFsMap)

Description copied from interface: ReplicationPeerConfigBuilder

Sets the mapping of table name to column families which should not be replicated. This method sets state which is mutually exclusive to ReplicationPeerConfigBuilder.setTableCFsMap(Map). Invoking this method is only relevant when all user tables are being replicated.

Specified by:

setExcludeTableCFsMap in interface ReplicationPeerConfigBuilder

Parameters:

excludeTableCFsMap - A mapping of table names to column families which should not be replicated. An empty list of column families implies all families for the table.

Returns:

this.

setExcludeNamespaces

public ReplicationPeerConfigBuilder setExcludeNamespaces(Set<String> excludeNamespaces)

Description copied from interface: ReplicationPeerConfigBuilder

Sets the collection of namespaces which should not be replicated when all user tables are configured to be replicated. This method sets state which is mutually exclusive to ReplicationPeerConfigBuilder.setNamespaces(Set). Invoking this method is only relevant when all user tables are being replicated.

Specified by:

setExcludeNamespaces in interface ReplicationPeerConfigBuilder

Parameters:

excludeNamespaces - A set of namespaces whose tables should not be replicated.

Returns:

this

setBandwidth

public ReplicationPeerConfigBuilder setBandwidth(long bandwidth)

Description copied from interface: ReplicationPeerConfigBuilder

Sets the speed, in bytes per second, for any one RegionServer to replicate data to the peer.

Specified by:

setBandwidth in interface ReplicationPeerConfigBuilder

Parameters:

bandwidth - Bytes per second

Returns:

this.

setSerial

public ReplicationPeerConfigBuilder setSerial(boolean serial)

Description copied from interface: ReplicationPeerConfigBuilder

Sets whether we should preserve order when replicating, i.e, serial replication.

Default false.

Specified by:

setSerial in interface ReplicationPeerConfigBuilder

Parameters:

serial - true means preserve order, otherwise false.

Returns:

this

setRemoteWALDir

public ReplicationPeerConfigBuilder setRemoteWALDir(String dir)

Description copied from interface: ReplicationPeerConfigBuilder

Set the remote peer cluster's wal directory. Used by synchronous replication.

Specified by:

setRemoteWALDir in interface ReplicationPeerConfigBuilder

Parameters:

dir - the remote peer cluster's wal directory

Returns:

this

build

public ReplicationPeerConfig build()

Description copied from interface: ReplicationPeerConfigBuilder

Builds the configuration object from the current state of this.

Specified by:

build in interface ReplicationPeerConfigBuilder

Returns:

A ReplicationPeerConfig instance.