Method Detail

• convert

  public static org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.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.protobuf.generated.ZooKeeperProtos.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.protobuf.generated.ZooKeeperProtos.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.protobuf.generated.ZooKeeperProtos.TableCF getTableCF(org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.TableCF[] tableCFs,
                                                                              String table)

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

• parseTableCFs

  public static org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.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.protobuf.generated.ZooKeeperProtos.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

• 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