org.apache.hadoop.hbase.replication

Class ReplicationSourceDummy

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationSourceDummy

All Implemented Interfaces:

ReplicationSourceInterface

public class ReplicationSourceDummy
extends Object
implements ReplicationSourceInterface

Source that does nothing at all, helpful to test ReplicationSourceManager

Constructor Summary

Constructors

Constructor and Description
ReplicationSourceDummy()

Method Summary

Modifier and Type	Method and Description
void	enqueueLog(Path log) Add a log to the list of logs to replicate
Path	getCurrentPath() Get the current log that's replicated
String	getPeerClusterId() Get the id that the source is replicating to.
String	getPeerClusterZnode() Get the id that the source is replicating to
String	getStats() Get a string representation of the current statistics for this source
void	init(Configuration conf, FileSystem fs, ReplicationSourceManager manager, ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId, UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics) Initializer for the source
void	startup() Start the replication
void	terminate(String reason) End the replication
void	terminate(String reason, Exception e) End the replication

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationSourceDummy

public ReplicationSourceDummy()

Method Detail

init

public void init(Configuration conf,
                 FileSystem fs,
                 ReplicationSourceManager manager,
                 ReplicationQueues rq,
                 ReplicationPeers rp,
                 Stoppable stopper,
                 String peerClusterId,
                 UUID clusterId,
                 ReplicationEndpoint replicationEndpoint,
                 MetricsSource metrics)
          throws IOException

Description copied from interface: ReplicationSourceInterface

Initializer for the source

Specified by:

init in interface ReplicationSourceInterface

Parameters:

conf - the configuration to use

fs - the file system to use

manager - the manager to use

stopper - the stopper object for this region server

Throws:

IOException

enqueueLog

public void enqueueLog(Path log)

Description copied from interface: ReplicationSourceInterface

Add a log to the list of logs to replicate

Specified by:

enqueueLog in interface ReplicationSourceInterface

Parameters:

log - path to the log to replicate

getCurrentPath

public Path getCurrentPath()

Description copied from interface: ReplicationSourceInterface

Get the current log that's replicated

Specified by:

getCurrentPath in interface ReplicationSourceInterface

Returns:

the current log

startup

public void startup()

Description copied from interface: ReplicationSourceInterface

Start the replication

Specified by:

startup in interface ReplicationSourceInterface

terminate

public void terminate(String reason)

Description copied from interface: ReplicationSourceInterface

End the replication

Specified by:

terminate in interface ReplicationSourceInterface

Parameters:

reason - why it's terminating

terminate

public void terminate(String reason,
                      Exception e)

Description copied from interface: ReplicationSourceInterface

End the replication

Specified by:

terminate in interface ReplicationSourceInterface

Parameters:

reason - why it's terminating

e - the error that's causing it

getPeerClusterZnode

public String getPeerClusterZnode()

Description copied from interface: ReplicationSourceInterface

Get the id that the source is replicating to

Specified by:

getPeerClusterZnode in interface ReplicationSourceInterface

Returns:

peer cluster id

getPeerClusterId

public String getPeerClusterId()

Description copied from interface: ReplicationSourceInterface

Get the id that the source is replicating to.

Specified by:

getPeerClusterId in interface ReplicationSourceInterface

Returns:

peer cluster id

getStats

public String getStats()

Description copied from interface: ReplicationSourceInterface

Get a string representation of the current statistics for this source

Specified by:

getStats in interface ReplicationSourceInterface

Returns:

printable stats