Package org.apache.hadoop.hbase.replication

Class ReplicationPeerConfig

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationPeerConfig

@Public
public class ReplicationPeerConfig
extends Object

A configuration for the replication peer cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplicationPeerConfig(ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl builder)

Method Summary

Modifier and Type	Method	Description
long	getBandwidth()
String	getClusterKey()
Map<String,String>	getConfiguration()
Set<String>	getExcludeNamespaces()
Map<TableName,List<String>>	getExcludeTableCFsMap()
Set<String>	getNamespaces()
Map<byte[],byte[]>	getPeerData()
String	getRemoteWALDir()
String	getReplicationEndpointImpl()
Map<TableName,List<String>>	getTableCFsMap()
boolean	isSerial()
boolean	isSyncReplication()	Use remote wal dir to decide whether a peer is sync replication peer
boolean	needToReplicate(TableName table)	Decide whether the table need replicate to the peer cluster
boolean	needToReplicate(TableName table, byte[] family)	Decide whether the passed family of the table need replicate to the peer cluster according to this peer config.
static ReplicationPeerConfigBuilder	newBuilder()
static ReplicationPeerConfigBuilder	newBuilder(ReplicationPeerConfig peerConfig)
boolean	replicateAllUserTables()
String	toString()
private Map<TableName,List<String>>	unmodifiableTableCFsMap(Map<TableName,List<String>> tableCFsMap)

Methods inherited from class java.lang.Object

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

Field Details

clusterKey

private String clusterKey

replicationEndpointImpl

private String replicationEndpointImpl

peerData

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

configuration

private final Map<String,String> configuration

tableCFsMap

private Map<TableName,? extends Collection<String>> tableCFsMap

namespaces

private Set<String> namespaces

replicateAllUserTables

private boolean replicateAllUserTables

excludeTableCFsMap

private Map<TableName,? extends Collection<String>> excludeTableCFsMap

excludeNamespaces

private Set<String> excludeNamespaces

bandwidth

private long bandwidth

serial

private final boolean serial

remoteWALDir

private String remoteWALDir

Constructor Details

ReplicationPeerConfig

private ReplicationPeerConfig(ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl builder)

Method Details

unmodifiableTableCFsMap

private Map<TableName,List<String>> unmodifiableTableCFsMap(Map<TableName,List<String>> tableCFsMap)

getClusterKey

public String getClusterKey()

getReplicationEndpointImpl

public String getReplicationEndpointImpl()

getPeerData

public Map<byte[],byte[]> getPeerData()

getConfiguration

public Map<String,String> getConfiguration()

getTableCFsMap

public Map<TableName,List<String>> getTableCFsMap()

getNamespaces

public Set<String> getNamespaces()

getBandwidth

public long getBandwidth()

replicateAllUserTables

public boolean replicateAllUserTables()

getExcludeTableCFsMap

public Map<TableName,List<String>> getExcludeTableCFsMap()

getExcludeNamespaces

public Set<String> getExcludeNamespaces()

getRemoteWALDir

public String getRemoteWALDir()

isSyncReplication

public boolean isSyncReplication()

Use remote wal dir to decide whether a peer is sync replication peer

newBuilder

public static ReplicationPeerConfigBuilder newBuilder()

isSerial

public boolean isSerial()

newBuilder

public static ReplicationPeerConfigBuilder newBuilder(ReplicationPeerConfig peerConfig)

toString

public String toString()

Overrides:

toString in class Object

needToReplicate

public boolean needToReplicate(TableName table)

Decide whether the table need replicate to the peer cluster

Parameters:

table - name of the table

Returns:

true if the table need replicate to the peer cluster

needToReplicate

public boolean needToReplicate(TableName table,
 byte[] family)

Decide whether the passed family of the table need replicate to the peer cluster according to this peer config.

Parameters:

table - name of the table

family - family name

Returns:

true if (the family of) the table need replicate to the peer cluster. If passed family is null, return true if any CFs of the table need replicate; If passed family is not null, return true if the passed family need replicate.