org.apache.hadoop.hbase.replication

Class ReplicationSourceDummy

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationSourceDummy

All Implemented Interfaces:

org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

Direct Known Subclasses:

TestReplicationSourceManager.FailInitializeDummyReplicationSource

public class ReplicationSourceDummy
extends Object
implements org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

Source that does nothing at all, helpful to test ReplicationSourceManager

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.fs.Path	currentPath
(package private) org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager	manager
(package private) org.apache.hadoop.hbase.replication.regionserver.MetricsSource	metrics
(package private) String	peerClusterId
(package private) AtomicBoolean	startup
(package private) org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider	walFileLengthProvider

Constructor Summary

Constructors

Constructor and Description
ReplicationSourceDummy()

Method Summary

Modifier and Type	Method and Description
void	addHFileRefs(org.apache.hadoop.hbase.TableName tableName, byte[] family, List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> files)
void	enqueueLog(org.apache.hadoop.fs.Path log)
org.apache.hadoop.fs.Path	getCurrentPath()
String	getPeerId()
String	getQueueId()
org.apache.hadoop.hbase.replication.ReplicationEndpoint	getReplicationEndpoint()
org.apache.hadoop.hbase.replication.ReplicationQueueStorage	getReplicationQueueStorage()
org.apache.hadoop.hbase.ServerName	getServerWALsBelongTo()
org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager	getSourceManager()
org.apache.hadoop.hbase.replication.regionserver.MetricsSource	getSourceMetrics()
String	getStats()
org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider	getWALFileLengthProvider()
void	init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager, org.apache.hadoop.hbase.replication.ReplicationQueueStorage rq, org.apache.hadoop.hbase.replication.ReplicationPeer rp, org.apache.hadoop.hbase.Server server, String peerClusterId, UUID clusterId, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider, org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics)
boolean	isPeerEnabled()
boolean	isSourceActive()
boolean	isStartup()
void	postShipEdits(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int batchSize)
org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface	startup()
void	terminate(String reason)
void	terminate(String reason, Exception e)
void	terminate(String reason, Exception e, boolean clearMetrics)
void	tryThrottle(int batchSize)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getWalGroupStatus, isRecovered, logPositionAndCleanOldLogs

Field Detail

manager

org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager

peerClusterId

String peerClusterId

currentPath

org.apache.hadoop.fs.Path currentPath

metrics

org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics

walFileLengthProvider

org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider

startup

AtomicBoolean startup

Constructor Detail

ReplicationSourceDummy

public ReplicationSourceDummy()

Method Detail

init

public void init(org.apache.hadoop.conf.Configuration conf,
                 org.apache.hadoop.fs.FileSystem fs,
                 org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager,
                 org.apache.hadoop.hbase.replication.ReplicationQueueStorage rq,
                 org.apache.hadoop.hbase.replication.ReplicationPeer rp,
                 org.apache.hadoop.hbase.Server server,
                 String peerClusterId,
                 UUID clusterId,
                 org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider,
                 org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics)
          throws IOException

Specified by:

init in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

Throws:

IOException

enqueueLog

public void enqueueLog(org.apache.hadoop.fs.Path log)

Specified by:

enqueueLog in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getCurrentPath

public org.apache.hadoop.fs.Path getCurrentPath()

Specified by:

getCurrentPath in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

startup

public org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface startup()

Specified by:

startup in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

isStartup

public boolean isStartup()

terminate

public void terminate(String reason)

Specified by:

terminate in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

terminate

public void terminate(String reason,
                      Exception e)

Specified by:

terminate in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

terminate

public void terminate(String reason,
                      Exception e,
                      boolean clearMetrics)

Specified by:

terminate in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getQueueId

public String getQueueId()

Specified by:

getQueueId in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getPeerId

public String getPeerId()

Specified by:

getPeerId in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getStats

public String getStats()

Specified by:

getStats in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

addHFileRefs

public void addHFileRefs(org.apache.hadoop.hbase.TableName tableName,
                         byte[] family,
                         List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> files)
                  throws org.apache.hadoop.hbase.replication.ReplicationException

Specified by:

addHFileRefs in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

isPeerEnabled

public boolean isPeerEnabled()

Specified by:

isPeerEnabled in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

isSourceActive

public boolean isSourceActive()

Specified by:

isSourceActive in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getSourceMetrics

public org.apache.hadoop.hbase.replication.regionserver.MetricsSource getSourceMetrics()

Specified by:

getSourceMetrics in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getReplicationEndpoint

public org.apache.hadoop.hbase.replication.ReplicationEndpoint getReplicationEndpoint()

Specified by:

getReplicationEndpoint in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getSourceManager

public org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager getSourceManager()

Specified by:

getSourceManager in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

tryThrottle

public void tryThrottle(int batchSize)
                 throws InterruptedException

Specified by:

tryThrottle in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

Throws:

InterruptedException

postShipEdits

public void postShipEdits(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
                          int batchSize)

Specified by:

postShipEdits in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getWALFileLengthProvider

public org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider getWALFileLengthProvider()

Specified by:

getWALFileLengthProvider in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getServerWALsBelongTo

public org.apache.hadoop.hbase.ServerName getServerWALsBelongTo()

Specified by:

getServerWALsBelongTo in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getReplicationQueueStorage

public org.apache.hadoop.hbase.replication.ReplicationQueueStorage getReplicationQueueStorage()

Specified by:

getReplicationQueueStorage in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface