public class ReplicationProtbufUtil
extends java.lang.Object
Constructor and Description |
---|
ReplicationProtbufUtil() |
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.
|
public static void replicateWALEntry(AdminService.BlockingInterface admin, Entry[] entries, java.lang.String replicationClusterId, Path sourceBaseNamespaceDir, Path sourceHFileArchiveDir) throws java.io.IOException
admin
- Admin serviceentries
- Array of WAL entries to be replicatedreplicationClusterId
- Id which will uniquely identify source cluster FS client
configurations in the replication configuration directorysourceBaseNamespaceDir
- Path to source cluster base namespace directorysourceHFileArchiveDir
- Path to the source cluster hfile archive directoryjava.io.IOException
public static <any> buildReplicateWALEntryRequest(Entry[] entries)
entries
- the WAL entries to be replicatedpublic static <any> buildReplicateWALEntryRequest(Entry[] entries, byte[] encodedRegionName, java.lang.String replicationClusterId, Path sourceBaseNamespaceDir, Path sourceHFileArchiveDir)
entries
- the WAL entries to be replicatedencodedRegionName
- alternative region name to use if not nullreplicationClusterId
- Id which will uniquely identify source cluster FS client
configurations in the replication configuration directorysourceBaseNamespaceDir
- Path to source cluster base namespace directorysourceHFileArchiveDir
- Path to the source cluster hfile archive directory