Package org.apache.hadoop.hbase.replication

Class TestNonHBaseReplicationEndpoint.NonHBaseReplicationEndpoint

java.lang.Object

org.apache.hadoop.hbase.replication.TestNonHBaseReplicationEndpoint.NonHBaseReplicationEndpoint

All Implemented Interfaces:

org.apache.hadoop.hbase.replication.ReplicationEndpoint, org.apache.hadoop.hbase.replication.ReplicationPeerConfigListener

Enclosing class:

TestNonHBaseReplicationEndpoint

public static class TestNonHBaseReplicationEndpoint.NonHBaseReplicationEndpoint
extends Object
implements org.apache.hadoop.hbase.replication.ReplicationEndpoint

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context, org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	running

Constructor Summary

Constructors

Constructor	Description
NonHBaseReplicationEndpoint()

Method Summary

Modifier and Type	Method	Description
void	awaitRunning()
void	awaitRunning(long timeout, TimeUnit unit)
void	awaitTerminated()
void	awaitTerminated(long timeout, TimeUnit unit)
boolean	canReplicateToSameCluster()
Throwable	failureCause()
UUID	getPeerUUID()
org.apache.hadoop.hbase.replication.WALEntryFilter	getWALEntryfilter()
void	init(org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context context)
boolean	isRunning()
boolean	isStarting()
void	peerConfigUpdated(org.apache.hadoop.hbase.replication.ReplicationPeerConfig rpc)
boolean	replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

running

private boolean running

Constructor Details

NonHBaseReplicationEndpoint

public NonHBaseReplicationEndpoint()

Method Details

init

public void init(org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context context)
          throws IOException

Specified by:

init in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

Throws:

IOException

canReplicateToSameCluster

public boolean canReplicateToSameCluster()

Specified by:

canReplicateToSameCluster in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

getPeerUUID

public UUID getPeerUUID()

Specified by:

getPeerUUID in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

getWALEntryfilter

public org.apache.hadoop.hbase.replication.WALEntryFilter getWALEntryfilter()

Specified by:

getWALEntryfilter in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

replicate

public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)

Specified by:

replicate in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

isStarting

public boolean isStarting()

Specified by:

isStarting in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

start

public void start()

Specified by:

start in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitRunning

public void awaitRunning()

Specified by:

awaitRunning in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitRunning

public void awaitRunning(long timeout,
 TimeUnit unit)

Specified by:

awaitRunning in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

stop

public void stop()

Specified by:

stop in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitTerminated

public void awaitTerminated()

Specified by:

awaitTerminated in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitTerminated

public void awaitTerminated(long timeout,
 TimeUnit unit)

Specified by:

awaitTerminated in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

failureCause

public Throwable failureCause()

Specified by:

failureCause in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

peerConfigUpdated

public void peerConfigUpdated(org.apache.hadoop.hbase.replication.ReplicationPeerConfig rpc)

Specified by:

peerConfigUpdated in interface org.apache.hadoop.hbase.replication.ReplicationPeerConfigListener