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