@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 boolean |
replicateAllUserTables |
private String |
replicationEndpointImpl |
private boolean |
serial |
private Map<TableName,? extends Collection<String>> |
tableCFsMap |
Modifier | Constructor and Description |
---|---|
|
ReplicationPeerConfig()
Deprecated.
as release of 2.0.0, and it will be removed in 3.0.0. Use
ReplicationPeerConfigBuilder to create new ReplicationPeerConfig. |
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 ReplicationPeerConfig(ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl builder)
@Deprecated public ReplicationPeerConfig()
ReplicationPeerConfigBuilder
to create new ReplicationPeerConfig.private Map<TableName,List<String>> unmodifiableTableCFsMap(Map<TableName,List<String>> tableCFsMap)
@Deprecated public ReplicationPeerConfig setClusterKey(String clusterKey)
ReplicationPeerConfigBuilder.setClusterKey(String)
instead.@Deprecated public ReplicationPeerConfig setReplicationEndpointImpl(String replicationEndpointImpl)
ReplicationPeerConfigBuilder.setReplicationEndpointImpl(String)
instead.replicationEndpointImpl
- a class implementing ReplicationEndpointpublic String getClusterKey()
public String getReplicationEndpointImpl()
public Map<byte[],byte[]> getPeerData()
public Map<String,String> getConfiguration()
public Map<TableName,List<String>> getTableCFsMap()
@Deprecated public ReplicationPeerConfig setTableCFsMap(Map<TableName,? extends Collection<String>> tableCFsMap)
ReplicationPeerConfigBuilder.setTableCFsMap(Map)
instead.public Set<String> getNamespaces()
@Deprecated public ReplicationPeerConfig setNamespaces(Set<String> namespaces)
ReplicationPeerConfigBuilder.setNamespaces(Set)
instead.public long getBandwidth()
@Deprecated public ReplicationPeerConfig setBandwidth(long bandwidth)
ReplicationPeerConfigBuilder.setBandwidth(long)
instead.public boolean replicateAllUserTables()
@Deprecated public ReplicationPeerConfig setReplicateAllUserTables(boolean replicateAllUserTables)
ReplicationPeerConfigBuilder.setReplicateAllUserTables(boolean)
instead.public Map<TableName,List<String>> getExcludeTableCFsMap()
@Deprecated public ReplicationPeerConfig setExcludeTableCFsMap(Map<TableName,? extends Collection<String>> tableCFsMap)
ReplicationPeerConfigBuilder.setExcludeTableCFsMap(Map)
instead.public Set<String> getExcludeNamespaces()
@Deprecated public ReplicationPeerConfig setExcludeNamespaces(Set<String> namespaces)
ReplicationPeerConfigBuilder.setExcludeNamespaces(Set)
instead.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.