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.