org.cloudgraph.maprdb.connect

Class MaprDBConnection

java.lang.Object

org.cloudgraph.maprdb.connect.MaprDBConnection

All Implemented Interfaces:

org.cloudgraph.core.Connection

public class MaprDBConnection
extends Object
implements org.cloudgraph.core.Connection

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
MaprDBConnection(org.apache.hadoop.hbase.client.Connection conection, org.apache.commons.pool2.ObjectPool<org.cloudgraph.core.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.cloudgraph.core.client.Admin	getAdmin()
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutatorParams params)
org.cloudgraph.core.client.BufferedMutator	getBufferedMutator(org.cloudgraph.core.client.TableName tableName)
org.apache.hadoop.conf.Configuration	getConfiguration()
org.cloudgraph.core.client.RegionLocator	getRegionLocator(org.cloudgraph.core.client.TableName tableName)
org.cloudgraph.core.client.Table	getTable(org.cloudgraph.core.client.TableName tableName)
org.cloudgraph.core.client.Table	getTable(org.cloudgraph.core.client.TableName tableName, ExecutorService pool)
boolean	isAborted()
boolean	isClosed()
boolean	tableExists(org.cloudgraph.core.client.TableName tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MaprDBConnection

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

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface org.cloudgraph.core.Connection

Throws:

IOException

destroy

public void destroy()
             throws IOException

Specified by:

destroy in interface org.cloudgraph.core.Connection

Throws:

IOException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface org.cloudgraph.core.Connection

abort

public void abort(String why,
                  Throwable e)

Specified by:

abort in interface org.cloudgraph.core.Connection

isAborted

public boolean isAborted()

Specified by:

isAborted in interface org.cloudgraph.core.Connection

getConfiguration

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

tableExists

public boolean tableExists(org.cloudgraph.core.client.TableName tableName)
                    throws IOException

Specified by:

tableExists in interface org.cloudgraph.core.Connection

Throws:

IOException

getTable

public org.cloudgraph.core.client.Table getTable(org.cloudgraph.core.client.TableName tableName)
                                          throws IOException

Specified by:

getTable in interface org.cloudgraph.core.Connection

Throws:

IOException

getTable

public org.cloudgraph.core.client.Table getTable(org.cloudgraph.core.client.TableName tableName,
                                                 ExecutorService pool)
                                          throws IOException

Specified by:

getTable in interface org.cloudgraph.core.Connection

Throws:

IOException

getBufferedMutator

public org.cloudgraph.core.client.BufferedMutator getBufferedMutator(org.cloudgraph.core.client.TableName tableName)
                                                              throws IOException

Specified by:

getBufferedMutator in interface org.cloudgraph.core.Connection

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.cloudgraph.core.client.RegionLocator getRegionLocator(org.cloudgraph.core.client.TableName tableName)
                                                          throws IOException

Specified by:

getRegionLocator in interface org.cloudgraph.core.Connection

Throws:

IOException

getAdmin

public org.cloudgraph.core.client.Admin getAdmin()
                                          throws IOException

Specified by:

getAdmin in interface org.cloudgraph.core.Connection

Throws:

IOException