Package org.apache.hadoop.hbase.replication

Class ReplicationSinkServiceImpl

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationSinkServiceImpl

All Implemented Interfaces:

ReplicationService, ReplicationSinkService

@Private
public class ReplicationSinkServiceImpl
extends Object
implements ReplicationSinkService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	ReplicationSinkServiceImpl.ReplicationStatisticsChore

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private static final org.slf4j.Logger	LOG
private ReplicationLoad	replicationLoad
private ReplicationSink	replicationSink
private Server	server
private int	statsPeriodInSecond

Constructor Summary

Constructors

Constructor	Description
ReplicationSinkServiceImpl()

Method Summary

Modifier and Type	Method	Description
void	initialize(Server server, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logdir, org.apache.hadoop.fs.Path oldLogDir, WALFactory walFactory)	Initializes the replication service object.
ReplicationLoad	refreshAndGetReplicationLoad()	Refresh and Get ReplicationLoad
void	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 sink
void	startReplicationService()	Start replication services.
void	stopReplicationService()	Stops replication service.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

conf

private org.apache.hadoop.conf.Configuration conf

server

private Server server

replicationSink

private ReplicationSink replicationSink

replicationLoad

private ReplicationLoad replicationLoad

statsPeriodInSecond

private int statsPeriodInSecond

Constructor Details

ReplicationSinkServiceImpl

public ReplicationSinkServiceImpl()

Method Details

replicateLogEntries

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

Description copied from interface: ReplicationSinkService

Carry on the list of log entries down to the sink

Specified by:

replicateLogEntries in interface ReplicationSinkService

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

initialize

public void initialize(Server server,
 org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path logdir,
 org.apache.hadoop.fs.Path oldLogDir,
 WALFactory walFactory)
                throws IOException

Description copied from interface: ReplicationService

Initializes the replication service object.

Specified by:

initialize in interface ReplicationService

Throws:

IOException

startReplicationService

public void startReplicationService()
                             throws IOException

Description copied from interface: ReplicationService

Start replication services.

Specified by:

startReplicationService in interface ReplicationService

Throws:

IOException

stopReplicationService

public void stopReplicationService()

Description copied from interface: ReplicationService

Stops replication service.

Specified by:

stopReplicationService in interface ReplicationService

refreshAndGetReplicationLoad

public ReplicationLoad refreshAndGetReplicationLoad()

Description copied from interface: ReplicationService

Refresh and Get ReplicationLoad

Specified by:

refreshAndGetReplicationLoad in interface ReplicationService