org.apache.hadoop.hbase.client.replication

Class ReplicationPeerConfigUtil

java.lang.Object

org.apache.hadoop.hbase.client.replication.ReplicationPeerConfigUtil

@InterfaceAudience.Private
 @InterfaceStability.Stable
public final class ReplicationPeerConfigUtil
extends Object

Helper for TableCFs Operations.

Field Summary

Fields

Modifier and Type	Field and Description
static String	HBASE_REPLICATION_PEER_BASE_CONFIG
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ReplicationPeerConfigUtil()

Method Summary

Modifier and Type	Method and Description
static ReplicationPeerConfig	addBasePeerConfigsIfNotPresent(org.apache.hadoop.conf.Configuration conf, ReplicationPeerConfig receivedPeerConfig) Helper method to add base peer configs from Configuration to ReplicationPeerConfig if not present in latter.
static ReplicationPeerConfig	appendExcludeTableCFsToReplicationPeerConfig(Map<TableName,List<String>> excludeTableCfs, ReplicationPeerConfig peerConfig)
static ReplicationPeerConfig	appendTableCFsToReplicationPeerConfig(Map<TableName,List<String>> tableCfs, ReplicationPeerConfig peerConfig)
static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[]	convert(Map<TableName,? extends Collection<String>> tableCfs) convert map to TableCFs Object
static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeer	convert(ReplicationPeerConfig peerConfig)
static ReplicationPeerConfig	convert(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeer peer)
static String	convert(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] tableCFs) Convert TableCFs Object to String.
static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[]	convert(String tableCFsConfig) Convert string to TableCFs Object.
static Map<TableName,List<String>>	convert2Map(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] tableCFs) Convert tableCFs Object to Map.
static String	convertToString(Map<TableName,? extends Collection<String>> tableCfs)
static String	convertToString(Set<String> namespaces)
private static Map<TableName,List<String>>	copyTableCFsMap(Map<TableName,List<String>> preTableCfs)
static org.apache.hadoop.conf.Configuration	getPeerClusterConfiguration(org.apache.hadoop.conf.Configuration conf, ReplicationPeerDescription peer) Returns the configuration needed to talk to the remote slave cluster.
static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF	getTableCF(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] tableCFs, String table) Get TableCF in TableCFs, if not exist, return null.
private static Map<TableName,List<String>>	mergeTableCFs(Map<TableName,List<String>> preTableCfs, Map<TableName,List<String>> tableCfs)
static ReplicationPeerConfig	parsePeerFrom(byte[] bytes)
static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[]	parseTableCFs(byte[] bytes) Parse bytes into TableCFs.
static Map<TableName,List<String>>	parseTableCFsFromConfig(String tableCFsConfig) Convert tableCFs string into Map.
static ReplicationPeerConfig	removeExcludeTableCFsFromReplicationPeerConfig(Map<TableName,List<String>> excludeTableCfs, ReplicationPeerConfig peerConfig, String id)
static ReplicationPeerConfig	removeTableCFsFromReplicationPeerConfig(Map<TableName,List<String>> tableCfs, ReplicationPeerConfig peerConfig, String id)
static byte[]	toByteArray(ReplicationPeerConfig peerConfig)
static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeerDescription	toProtoReplicationPeerDescription(ReplicationPeerDescription desc)
static ReplicationPeerDescription	toReplicationPeerDescription(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeerDescription desc)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

HBASE_REPLICATION_PEER_BASE_CONFIG

public static final String HBASE_REPLICATION_PEER_BASE_CONFIG

See Also:

Constant Field Values

Constructor Detail

ReplicationPeerConfigUtil

private ReplicationPeerConfigUtil()

Method Detail

convertToString

public static String convertToString(Set<String> namespaces)

convert

public static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] convert(Map<TableName,? extends Collection<String>> tableCfs)

convert map to TableCFs Object

convertToString

public static String convertToString(Map<TableName,? extends Collection<String>> tableCfs)

convert

public static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] convert(String tableCFsConfig)

Convert string to TableCFs Object. This is only for read TableCFs information from TableCF node. Input String Format: ns1.table1:cf1,cf2;ns2.table2:cfA,cfB;ns3.table3.

convert

public static String convert(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] tableCFs)

Convert TableCFs Object to String. Output String Format: ns1.table1:cf1,cf2;ns2.table2:cfA,cfB;table3

getTableCF

public static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF getTableCF(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] tableCFs,
                                                                                                     String table)

Get TableCF in TableCFs, if not exist, return null.

parseTableCFs

public static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] parseTableCFs(byte[] bytes)
                                                                                                   throws IOException

Parse bytes into TableCFs. It is used for backward compatibility. Old format bytes have no PB_MAGIC Header

Throws:

IOException

parseTableCFsFromConfig

public static Map<TableName,List<String>> parseTableCFsFromConfig(String tableCFsConfig)

Convert tableCFs string into Map.

convert2Map

public static Map<TableName,List<String>> convert2Map(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.TableCF[] tableCFs)

Convert tableCFs Object to Map.

parsePeerFrom

public static ReplicationPeerConfig parsePeerFrom(byte[] bytes)
                                           throws DeserializationException

Parameters:

bytes - Content of a peer znode.

Returns:

ClusterKey parsed from the passed bytes.

Throws:

DeserializationException

convert

public static ReplicationPeerConfig convert(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeer peer)

convert

public static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeer convert(ReplicationPeerConfig peerConfig)

toByteArray

public static byte[] toByteArray(ReplicationPeerConfig peerConfig)

Parameters:

peerConfig -

Returns:

Serialized protobuf of peerConfig with pb magic prefix prepended suitable for use as content of a this.peersZNode; i.e. the content of PEER_ID znode under /hbase/replication/peers/PEER_ID

toReplicationPeerDescription

public static ReplicationPeerDescription toReplicationPeerDescription(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeerDescription desc)

toProtoReplicationPeerDescription

public static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationPeerDescription toProtoReplicationPeerDescription(ReplicationPeerDescription desc)

appendTableCFsToReplicationPeerConfig

public static ReplicationPeerConfig appendTableCFsToReplicationPeerConfig(Map<TableName,List<String>> tableCfs,
                                                                          ReplicationPeerConfig peerConfig)

addBasePeerConfigsIfNotPresent

public static ReplicationPeerConfig addBasePeerConfigsIfNotPresent(org.apache.hadoop.conf.Configuration conf,
                                                                   ReplicationPeerConfig receivedPeerConfig)

Helper method to add base peer configs from Configuration to ReplicationPeerConfig if not present in latter. This merges the user supplied peer configuration ReplicationPeerConfig with peer configs provided as property hbase.replication.peer.base.configs in hbase configuration. Expected format for this hbase configuration is "k1=v1;k2=v2,v2_1". Original value of conf is retained if already present in ReplicationPeerConfig.

Parameters:

conf - Configuration

Returns:

ReplicationPeerConfig containing updated configs.

appendExcludeTableCFsToReplicationPeerConfig

public static ReplicationPeerConfig appendExcludeTableCFsToReplicationPeerConfig(Map<TableName,List<String>> excludeTableCfs,
                                                                                 ReplicationPeerConfig peerConfig)
                                                                          throws ReplicationException

Throws:

ReplicationException

mergeTableCFs

private static Map<TableName,List<String>> mergeTableCFs(Map<TableName,List<String>> preTableCfs,
                                                         Map<TableName,List<String>> tableCfs)

copyTableCFsMap

private static Map<TableName,List<String>> copyTableCFsMap(Map<TableName,List<String>> preTableCfs)

removeTableCFsFromReplicationPeerConfig

public static ReplicationPeerConfig removeTableCFsFromReplicationPeerConfig(Map<TableName,List<String>> tableCfs,
                                                                            ReplicationPeerConfig peerConfig,
                                                                            String id)
                                                                     throws ReplicationException

Throws:

ReplicationException

removeExcludeTableCFsFromReplicationPeerConfig

public static ReplicationPeerConfig removeExcludeTableCFsFromReplicationPeerConfig(Map<TableName,List<String>> excludeTableCfs,
                                                                                   ReplicationPeerConfig peerConfig,
                                                                                   String id)
                                                                            throws ReplicationException

Throws:

ReplicationException

getPeerClusterConfiguration

public static org.apache.hadoop.conf.Configuration getPeerClusterConfiguration(org.apache.hadoop.conf.Configuration conf,
                                                                               ReplicationPeerDescription peer)
                                                                        throws IOException

Returns the configuration needed to talk to the remote slave cluster.

Parameters:

conf - the base configuration

peer - the description of replication peer

Returns:

the configuration for the peer cluster, null if it was unable to get the configuration

Throws:

IOException - when create peer cluster configuration failed