public class ReplicationSourceDummy
extends java.lang.Object
Constructor and Description |
---|
ReplicationSourceDummy() |
Modifier and Type | Method and Description |
---|---|
void |
addHFileRefs(TableName tableName,
byte[] family,
java.util.List<<any>> files) |
void |
enqueueLog(Path log) |
Path |
getCurrentPath() |
java.lang.String |
getPeerClusterId() |
java.lang.String |
getPeerClusterZnode() |
java.lang.String |
getStats() |
void |
init(Configuration conf,
FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueues rq,
ReplicationPeers rp,
Stoppable stopper,
java.lang.String peerClusterId,
java.util.UUID clusterId,
ReplicationEndpoint replicationEndpoint,
MetricsSource metrics) |
void |
startup() |
void |
terminate(java.lang.String reason) |
void |
terminate(java.lang.String reason,
java.lang.Exception e) |
public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager, ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, java.lang.String peerClusterId, java.util.UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics) throws java.io.IOException
java.io.IOException
public void enqueueLog(Path log)
public Path getCurrentPath()
public void startup()
public void terminate(java.lang.String reason)
public void terminate(java.lang.String reason, java.lang.Exception e)
public java.lang.String getPeerClusterZnode()
public java.lang.String getPeerClusterId()
public java.lang.String getStats()
public void addHFileRefs(TableName tableName, byte[] family, java.util.List<<any>> files) throws ReplicationException
ReplicationException