public interface ReplicationSinkService extends ReplicationService
Modifier and Type | Method and Description |
---|---|
void |
replicateLogEntries(java.util.List<WALEntry> entries,
CellScanner cells,
java.lang.String replicationClusterId,
java.lang.String sourceBaseNamespaceDirPath,
java.lang.String sourceHFileArchiveDirPath)
Carry on the list of log entries down to the sink
|
initialize, refreshAndGetReplicationLoad, startReplicationService, stopReplicationService
void replicateLogEntries(java.util.List<WALEntry> entries, CellScanner cells, java.lang.String replicationClusterId, java.lang.String sourceBaseNamespaceDirPath, java.lang.String sourceHFileArchiveDirPath) throws java.io.IOException
entries
- list of WALEntries to replicatecells
- 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 directorysourceBaseNamespaceDirPath
- Path that point to the source cluster base namespace
directory required for replicating hfilessourceHFileArchiveDirPath
- Path that point to the source cluster hfile archive directoryjava.io.IOException