Constructor Detail

• ReplicationProtbufUtil

  public ReplicationProtbufUtil()

Method Detail

• replicateWALEntry

  public static void replicateWALEntry(org.apache.hadoop.hbase.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin,
                       WAL.Entry[] entries,
                       String replicationClusterId,
                       org.apache.hadoop.fs.Path sourceBaseNamespaceDir,
                       org.apache.hadoop.fs.Path sourceHFileArchiveDir)
                                throws IOException

  A helper to replicate a list of WAL entries using admin protocol.

  Parameters:

  admin - Admin service

  entries - Array of WAL entries to be replicated

  replicationClusterId - Id which will uniquely identify source cluster FS client configurations in the replication configuration directory

  sourceBaseNamespaceDir - Path to source cluster base namespace directory

  sourceHFileArchiveDir - Path to the source cluster hfile archive directory

  Throws:

  IOException

• buildReplicateWALEntryRequest

  public static Pair<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryRequest,CellScanner> buildReplicateWALEntryRequest(WAL.Entry[] entries)

  Create a new ReplicateWALEntryRequest from a list of WAL entries

  Parameters:

  entries - the WAL entries to be replicated

  Returns:

  a pair of ReplicateWALEntryRequest and a CellScanner over all the WALEdit values found.

• buildReplicateWALEntryRequest

  public static Pair<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryRequest,CellScanner> buildReplicateWALEntryRequest(WAL.Entry[] entries,
                                                                                                                                byte[] encodedRegionName,
                                                                                                                                String replicationClusterId,
                                                                                                                                org.apache.hadoop.fs.Path sourceBaseNamespaceDir,
                                                                                                                                org.apache.hadoop.fs.Path sourceHFileArchiveDir)

  Create a new ReplicateWALEntryRequest from a list of HLog entries

  Parameters:

  entries - the HLog entries to be replicated

  encodedRegionName - alternative region name to use if not null

  replicationClusterId - Id which will uniquely identify source cluster FS client configurations in the replication configuration directory

  sourceBaseNamespaceDir - Path to source cluster base namespace directory

  sourceHFileArchiveDir - Path to the source cluster hfile archive directory

  Returns:

  a pair of ReplicateWALEntryRequest and a CellScanner over all the WALEdit values found.