Interface ReplicationSinkService
- All Superinterfaces:
ReplicationService
- All Known Implementing Classes:
ReplicationSinkServiceImpl
A sink for a replication stream has to expose this service. This service allows an application to
hook into the regionserver and behave as a replication sink.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
replicateLogEntries
(List<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry> entries, ExtendedCellScanner cells, String replicationClusterId, String sourceBaseNamespaceDirPath, String sourceHFileArchiveDirPath) Carry on the list of log entries down to the sinkMethods inherited from interface org.apache.hadoop.hbase.regionserver.ReplicationService
initialize, refreshAndGetReplicationLoad, startReplicationService, stopReplicationService
-
Method Details
-
replicateLogEntries
void replicateLogEntries(List<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry> entries, ExtendedCellScanner 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 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 directory- Throws:
IOException
-