Constructor Detail

• HBaseInterClusterReplicationEndpoint.Replicator

  public HBaseInterClusterReplicationEndpoint.Replicator(List<WAL.Entry> entries,
                                                 int ordinal)

Method Detail

• replicateEntries

  protected void replicateEntries(org.apache.hadoop.hbase.protobuf.generated.AdminProtos.AdminService.BlockingInterface rrs,
                      List<WAL.Entry> batch,
                      String replicationClusterId,
                      org.apache.hadoop.fs.Path baseNamespaceDir,
                      org.apache.hadoop.fs.Path hfileArchiveDir)
                           throws IOException

  Throws:

  IOException

• call

  public Integer call()
               throws IOException

  Specified by:

  call in interface Callable<Integer>

  Throws:

  IOException