Method Detail

• replicateLogEntries

  void replicateLogEntries(List<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry> entries,
                         CellScanner cells,
                         String replicationClusterId,
                         String sourceBaseNamespaceDirPath,
                         String sourceHFileArchiveDirPath)
                           throws IOException

  Carry on the list of log entries down to the sink

  Parameters:

  entries - list of WALEntries to replicate

  cells - Cells that the WALEntries refer to (if cells is non-null)

  replicationClusterId - Id which will uniquely identify source cluster FS client configurations in the replication configuration directory

  sourceBaseNamespaceDirPath - Path that point to the source cluster base namespace directory required for replicating hfiles

  sourceHFileArchiveDirPath - Path that point to the source cluster hfile archive directory

  Throws:

  IOException