org.cloudgraph.maprdb.connect

Class MaprDBPooledConnectionFactory

java.lang.Object

org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

org.cloudgraph.maprdb.connect.MaprDBPooledConnectionFactory

All Implemented Interfaces:

org.apache.commons.pool2.PooledObjectFactory<org.cloudgraph.core.Connection>

public class MaprDBPooledConnectionFactory
extends org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

Connection factory which creates pooled connections.

The new HBase 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.

Since:

0.6.3

Author:

Scott Cinnamond

Constructor Summary

Constructors

Constructor and Description
MaprDBPooledConnectionFactory(org.apache.hadoop.conf.Configuration config)

Method Summary

Modifier and Type	Method and Description
void	activateObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)
org.cloudgraph.core.Connection	create()
void	destroyObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)
void	passivateObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)
void	setPool(org.apache.commons.pool2.ObjectPool<org.cloudgraph.core.Connection> pool)
boolean	validateObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)
org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection>	wrap(org.cloudgraph.core.Connection con)

Methods inherited from class org.apache.commons.pool2.BasePooledObjectFactory

makeObject

Methods inherited from class java.lang.Object

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

Constructor Detail

MaprDBPooledConnectionFactory

public MaprDBPooledConnectionFactory(org.apache.hadoop.conf.Configuration config)

Method Detail

setPool

public void setPool(org.apache.commons.pool2.ObjectPool<org.cloudgraph.core.Connection> pool)

create

public org.cloudgraph.core.Connection create()
                                      throws Exception

Specified by:

create in class org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

Throws:

Exception

wrap

public org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> wrap(org.cloudgraph.core.Connection con)

Specified by:

wrap in class org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

destroyObject

public void destroyObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool2.PooledObjectFactory<org.cloudgraph.core.Connection>

Overrides:

destroyObject in class org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

Throws:

Exception

validateObject

public boolean validateObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)

Specified by:

validateObject in interface org.apache.commons.pool2.PooledObjectFactory<org.cloudgraph.core.Connection>

Overrides:

validateObject in class org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

activateObject

public void activateObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)
                    throws Exception

Specified by:

activateObject in interface org.apache.commons.pool2.PooledObjectFactory<org.cloudgraph.core.Connection>

Overrides:

activateObject in class org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

Throws:

Exception

passivateObject

public void passivateObject(org.apache.commons.pool2.PooledObject<org.cloudgraph.core.Connection> p)
                     throws Exception

Specified by:

passivateObject in interface org.apache.commons.pool2.PooledObjectFactory<org.cloudgraph.core.Connection>

Overrides:

passivateObject in class org.apache.commons.pool2.BasePooledObjectFactory<org.cloudgraph.core.Connection>

Throws:

Exception