org.apache.hadoop.hbase.test

Class IntegrationTestReplication.ClusterID

java.lang.Object

org.apache.hadoop.hbase.test.IntegrationTestReplication.ClusterID

Enclosing class:

IntegrationTestReplication

protected class IntegrationTestReplication.ClusterID
extends Object

Wrapper around an HBase ClusterID allowing us to get admin connections and configurations for it

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	configuration
private org.apache.hadoop.hbase.client.Connection	connection

Constructor Summary

Constructors

Constructor and Description
ClusterID(org.apache.hadoop.conf.Configuration base, String key) This creates a new ClusterID wrapper that will automatically build connections and configurations to be able to talk to the specified cluster

Method Summary

Modifier and Type	Method and Description
void	closeConnection()
boolean	equals(IntegrationTestReplication.ClusterID other)
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.client.Connection	getConnection()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

configuration

private final org.apache.hadoop.conf.Configuration configuration

connection

private org.apache.hadoop.hbase.client.Connection connection

Constructor Detail

ClusterID

public ClusterID(org.apache.hadoop.conf.Configuration base,
                 String key)

This creates a new ClusterID wrapper that will automatically build connections and configurations to be able to talk to the specified cluster

Parameters:

base - the base configuration that this class will add to

key - the cluster key in the form of zk_quorum:zk_port:zk_parent_node

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

getConnection

public org.apache.hadoop.hbase.client.Connection getConnection()
                                                        throws Exception

Throws:

Exception

closeConnection

public void closeConnection()
                     throws Exception

Throws:

Exception

equals

public boolean equals(IntegrationTestReplication.ClusterID other)