org.apache.hadoop.hbase.replication.regionserver

Interface ReplicationSourceInterface

All Known Implementing Classes:

ReplicationSource

@InterfaceAudience.Private
public interface ReplicationSourceInterface

Interface that defines a replication source

Method Summary

Modifier and Type	Method and Description
void	addHFileRefs(TableName tableName, byte[] family, java.util.List<Pair<Path,Path>> pairs) Add hfile names to the queue to be replicated.
void	enqueueLog(Path log) Add a log to the list of logs to replicate
Path	getCurrentPath() Get the current log that's replicated
java.lang.String	getPeerClusterId() Get the id that the source is replicating to.
java.lang.String	getPeerClusterZnode() Get the id that the source is replicating to
java.lang.String	getStats() Get a string representation of the current statistics for this source
void	init(Configuration conf, FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Stoppable stopper, java.lang.String peerClusterZnode, java.util.UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics) Initializer for the source
void	startup() Start the replication
void	terminate(java.lang.String reason) End the replication
void	terminate(java.lang.String reason, java.lang.Exception cause) End the replication

Method Detail

init

void init(Configuration conf,
          FileSystem fs,
          ReplicationSourceManager manager,
          ReplicationQueues replicationQueues,
          ReplicationPeers replicationPeers,
          Stoppable stopper,
          java.lang.String peerClusterZnode,
          java.util.UUID clusterId,
          ReplicationEndpoint replicationEndpoint,
          MetricsSource metrics)
   throws java.io.IOException

Initializer for the source

Parameters:

conf - the configuration to use

fs - the file system to use

manager - the manager to use

replicationQueues -

replicationPeers -

stopper - the stopper object for this region server

peerClusterZnode -

clusterId -

Throws:

java.io.IOException

enqueueLog

void enqueueLog(Path log)

Add a log to the list of logs to replicate

Parameters:

log - path to the log to replicate

getCurrentPath

Path getCurrentPath()

Get the current log that's replicated

Returns:

the current log

startup

void startup()

Start the replication

terminate

void terminate(java.lang.String reason)

End the replication

Parameters:

reason - why it's terminating

terminate

void terminate(java.lang.String reason,
               java.lang.Exception cause)

End the replication

Parameters:

reason - why it's terminating

cause - the error that's causing it

getPeerClusterZnode

java.lang.String getPeerClusterZnode()

Get the id that the source is replicating to

Returns:

peer cluster id

getPeerClusterId

java.lang.String getPeerClusterId()

Get the id that the source is replicating to.

Returns:

peer cluster id

getStats

java.lang.String getStats()

Get a string representation of the current statistics for this source

Returns:

printable stats

addHFileRefs

void addHFileRefs(TableName tableName,
                  byte[] family,
                  java.util.List<Pair<Path,Path>> pairs)
           throws ReplicationException

Add hfile names to the queue to be replicated.

Parameters:

tableName - Name of the table these files belongs to

family - Name of the family these files belong to

pairs - list of pairs of { HFile location in staging dir, HFile path in region dir which will be added in the queue for replication}

Throws:

ReplicationException - If failed to add hfile references