org.darkphoenixs.pool.hbase

类 HbaseConnectionFactory

java.lang.Object

org.darkphoenixs.pool.hbase.HbaseConnectionFactory

所有已实现的接口:

Serializable, PooledObjectFactory<org.apache.hadoop.hbase.client.Connection>, ConnectionFactory<org.apache.hadoop.hbase.client.Connection>

 class HbaseConnectionFactory
extends Object
implements ConnectionFactory<org.apache.hadoop.hbase.client.Connection>

Title: HbaseConnectionFactory

Description: Hbase连接工厂

从以下版本开始:

2015年9月19日

版本:

1.0

作者:

Victor

另请参阅:

ConnectionFactory

字段概要

字段

限定符和类型	字段和说明
private org.apache.hadoop.conf.Configuration	hadoopConfiguration hadoopConfiguration
private static long	serialVersionUID serialVersionUID

构造器概要

构造器

构造器和说明
HbaseConnectionFactory(org.apache.hadoop.conf.Configuration hadoopConfiguration) Title: HbaseConnectionFactory Description: 构造方法
HbaseConnectionFactory(Properties properties)
HbaseConnectionFactory(String host, String port, String master, String rootdir) Title: HbaseConnectionFactory Description: 构造方法

方法概要

方法

限定符和类型	方法和说明
void	activateObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)
org.apache.hadoop.hbase.client.Connection	createConnection() Title: createConnection Description: 创建连接
void	destroyObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)
PooledObject<org.apache.hadoop.hbase.client.Connection>	makeObject()
void	passivateObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)
boolean	validateObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)

从类继承的方法 java.lang.Object

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

字段详细资料

serialVersionUID

private static final long serialVersionUID

serialVersionUID

另请参阅:

常量字段值

hadoopConfiguration

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

hadoopConfiguration

构造器详细资料

HbaseConnectionFactory

public HbaseConnectionFactory(org.apache.hadoop.conf.Configuration hadoopConfiguration)

Title: HbaseConnectionFactory

Description: 构造方法

参数:

hadoopConfiguration - hbase配置

HbaseConnectionFactory

public HbaseConnectionFactory(String host,
                      String port,
                      String master,
                      String rootdir)

Title: HbaseConnectionFactory

Description: 构造方法

参数:

host - zookeeper地址

port - zookeeper端口

master - hbase主机

rootdir - hdfs数据目录

HbaseConnectionFactory

public HbaseConnectionFactory(Properties properties)

参数:

properties - 参数配置

从以下版本开始:

1.2.1

方法详细资料

makeObject

public PooledObject<org.apache.hadoop.hbase.client.Connection> makeObject()
                                                                   throws Exception

指定者:

makeObject 在接口中 PooledObjectFactory<org.apache.hadoop.hbase.client.Connection>

抛出:

Exception

destroyObject

public void destroyObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)
                   throws Exception

指定者:

destroyObject 在接口中 PooledObjectFactory<org.apache.hadoop.hbase.client.Connection>

抛出:

Exception

validateObject

public boolean validateObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)

指定者:

validateObject 在接口中 PooledObjectFactory<org.apache.hadoop.hbase.client.Connection>

activateObject

public void activateObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)
                    throws Exception

指定者:

activateObject 在接口中 PooledObjectFactory<org.apache.hadoop.hbase.client.Connection>

抛出:

Exception

passivateObject

public void passivateObject(PooledObject<org.apache.hadoop.hbase.client.Connection> p)
                     throws Exception

指定者:

passivateObject 在接口中 PooledObjectFactory<org.apache.hadoop.hbase.client.Connection>

抛出:

Exception

createConnection

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

从接口复制的说明: ConnectionFactory

Title: createConnection

Description: 创建连接

指定者:

createConnection 在接口中 ConnectionFactory<org.apache.hadoop.hbase.client.Connection>

返回:

连接

抛出:

Exception