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

Methods

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) Create a new ReplicateWALEntryRequest from a list of HLog entries
static void	replicateWALEntry(AdminProtos.AdminService.BlockingInterface admin, WAL.Entry[] entries) 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)
                              throws IOException

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

Parameters:

admin -

entries -

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)

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

Returns:

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