org.cloudgraph.hbase.connect

Class Connection

java.lang.Object

org.cloudgraph.hbase.connect.Connection

public class Connection
extends Object

Pooled HBase connection wrapper which complies with Apache pool semantics and maintains a cache or table handles for each connection. Depending in the complexity of a particular application, there may be many tables needed, for example some tables for actual data and some for metadata or other application data. Caching table API handles greatly reduces round trips and resource costs for some HBase implementations.

The new HBase 1.x Client API changes removed the existing connection pool implementation and placed the responsibility of managing the lifecycle of connections on the caller. A pool is necessary as creating connections to the cluster via. zookeeper is fairly expensive.

For some HBase implementations, e.g. MAPR, the management of connections and table handles is super critical, as the API is extremely performance and resource costly at scale.

Since:

0.6.3

Author:

Scott Cinnamond

Constructor Summary

Constructors

Constructor and Description
Connection(org.apache.hadoop.hbase.client.Connection conection, org.apache.commons.pool2.ObjectPool<Connection> pool, org.apache.hadoop.conf.Configuration config)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e)
void	close()
void	destroy()
org.apache.hadoop.hbase.client.Admin	getAdmin()
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutatorParams params)
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.client.RegionLocator	getRegionLocator(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.Table	getTable(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.Table	getTable(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
boolean	isAborted()
boolean	isClosed()
boolean	tableExists(org.apache.hadoop.hbase.TableName tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

Connection

public Connection(org.apache.hadoop.hbase.client.Connection conection,
                  org.apache.commons.pool2.ObjectPool<Connection> pool,
                  org.apache.hadoop.conf.Configuration config)

Method Detail

close

public void close()
           throws IOException

Throws:

IOException

destroy

public void destroy()
             throws IOException

Throws:

IOException

isClosed

public boolean isClosed()

abort

public void abort(String why,
                  Throwable e)

isAborted

public boolean isAborted()

getConfiguration

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

tableExists

public boolean tableExists(org.apache.hadoop.hbase.TableName tableName)
                    throws IOException

Throws:

IOException

getTable

public org.apache.hadoop.hbase.client.Table getTable(org.apache.hadoop.hbase.TableName tableName)
                                              throws IOException

Throws:

IOException

getTable

public org.apache.hadoop.hbase.client.Table getTable(org.apache.hadoop.hbase.TableName tableName,
                                                     ExecutorService pool)
                                              throws IOException

Throws:

IOException

getBufferedMutator

public org.apache.hadoop.hbase.client.BufferedMutator getBufferedMutator(org.apache.hadoop.hbase.TableName tableName)
                                                                  throws IOException

Throws:

IOException

getBufferedMutator

public org.apache.hadoop.hbase.client.BufferedMutator getBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutatorParams params)
                                                                  throws IOException

Throws:

IOException

getRegionLocator

public org.apache.hadoop.hbase.client.RegionLocator getRegionLocator(org.apache.hadoop.hbase.TableName tableName)
                                                              throws IOException

Throws:

IOException

getAdmin

public org.apache.hadoop.hbase.client.Admin getAdmin()
                                              throws IOException

Throws:

IOException