@InterfaceAudience.Public public class ReplicationPeerConfig extends Object
Modifier and Type | Class and Description |
---|---|
(package private) static class |
ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl |
Modifier and Type | Field and Description |
---|---|
private long |
bandwidth |
private String |
clusterKey |
private Map<String,String> |
configuration |
private Set<String> |
excludeNamespaces |
private Map<TableName,? extends Collection<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,? extends Collection<String>> |
tableCFsMap |
Modifier | Constructor and Description |
---|---|
private |
ReplicationPeerConfig(ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl builder) |
private String clusterKey
private String replicationEndpointImpl
private final Map<String,String> configuration
private Map<TableName,? extends Collection<String>> tableCFsMap
private Set<String> namespaces
private boolean replicateAllUserTables
private Map<TableName,? extends Collection<String>> excludeTableCFsMap
private Set<String> excludeNamespaces
private long bandwidth
private final boolean serial
private String remoteWALDir
private ReplicationPeerConfig(ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl builder)
private Map<TableName,List<String>> unmodifiableTableCFsMap(Map<TableName,List<String>> tableCFsMap)
public String getClusterKey()
public String getReplicationEndpointImpl()
public Map<byte[],byte[]> getPeerData()
public Map<String,String> getConfiguration()
public Map<TableName,List<String>> getTableCFsMap()
public Set<String> getNamespaces()
public long getBandwidth()
public boolean replicateAllUserTables()
public Map<TableName,List<String>> getExcludeTableCFsMap()
public Set<String> getExcludeNamespaces()
public String getRemoteWALDir()
public boolean isSyncReplication()
public static ReplicationPeerConfigBuilder newBuilder()
public boolean isSerial()
public static ReplicationPeerConfigBuilder newBuilder(ReplicationPeerConfig peerConfig)
public boolean needToReplicate(TableName table)
table
- name of the tablepublic boolean needToReplicate(TableName table, byte[] family)
table
- name of the tablefamily
- family nameCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.