org.apache.hadoop.hbase.protobuf

Class ReplicationProtbufUtil

java.lang.Object

org.apache.hadoop.hbase.protobuf.ReplicationProtbufUtil

public class ReplicationProtbufUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ReplicationProtbufUtil()

Method Summary

Modifier and Type	Method and Description
static <any>	buildReplicateWALEntryRequest(Entry[] entries) Create a new ReplicateWALEntryRequest from a list of WAL entries
static <any>	buildReplicateWALEntryRequest(Entry[] entries, byte[] encodedRegionName, java.lang.String replicationClusterId, Path sourceBaseNamespaceDir, Path sourceHFileArchiveDir) Create a new ReplicateWALEntryRequest from a list of WAL entries
static void	replicateWALEntry(AdminService.BlockingInterface admin, Entry[] entries, java.lang.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(AdminService.BlockingInterface admin,
                                     Entry[] entries,
                                     java.lang.String replicationClusterId,
                                     Path sourceBaseNamespaceDir,
                                     Path sourceHFileArchiveDir)
                              throws java.io.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:

java.io.IOException

buildReplicateWALEntryRequest

public static <any> buildReplicateWALEntryRequest(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 <any> buildReplicateWALEntryRequest(Entry[] entries,
                                                  byte[] encodedRegionName,
                                                  java.lang.String replicationClusterId,
                                                  Path sourceBaseNamespaceDir,
                                                  Path sourceHFileArchiveDir)

Create a new ReplicateWALEntryRequest from a list of WAL entries

Parameters:

entries - the WAL 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.