org.apache.hadoop.hbase.protobuf

Class ReplicationProtbufUtil

java.lang.Object

org.apache.hadoop.hbase.protobuf.ReplicationProtbufUtil

@InterfaceAudience.Private
public class ReplicationProtbufUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
ReplicationProtbufUtil()

Method Summary

Modifier and Type	Method and Description
static Pair<AdminProtos.ReplicateWALEntryRequest,CellScanner>	buildReplicateWALEntryRequest(WAL.Entry[] entries) Create a new ReplicateWALEntryRequest from a list of WAL entries
static Pair<AdminProtos.ReplicateWALEntryRequest,CellScanner>	buildReplicateWALEntryRequest(WAL.Entry[] entries, byte[] encodedRegionName, String replicationClusterId, Path sourceBaseNamespaceDir, Path sourceHFileArchiveDir) Create a new ReplicateWALEntryRequest from a list of HLog entries
static void	replicateWALEntry(AdminProtos.AdminService.BlockingInterface admin, WAL.Entry[] entries, String replicationClusterId, Path sourceBaseNamespaceDir, Path sourceHFileArchiveDir) A helper to replicate a list of WAL entries using admin protocol.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationProtbufUtil

public ReplicationProtbufUtil()

Method Detail

replicateWALEntry

public static void replicateWALEntry(AdminProtos.AdminService.BlockingInterface admin,
                                     WAL.Entry[] entries,
                                     String replicationClusterId,
                                     Path sourceBaseNamespaceDir,
                                     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<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<AdminProtos.ReplicateWALEntryRequest,CellScanner> buildReplicateWALEntryRequest(WAL.Entry[] entries,
                                                                                                   byte[] encodedRegionName,
                                                                                                   String replicationClusterId,
                                                                                                   Path sourceBaseNamespaceDir,
                                                                                                   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.