org.darkphoenixs.pool.hbase

类 HbaseConnectionPool

java.lang.Object

org.darkphoenixs.pool.PoolBase<org.apache.hadoop.hbase.client.Connection>

org.darkphoenixs.pool.hbase.HbaseConnectionPool

所有已实现的接口:

Closeable, Serializable, AutoCloseable, ConnectionPool<org.apache.hadoop.hbase.client.Connection>

public class HbaseConnectionPool
extends PoolBase<org.apache.hadoop.hbase.client.Connection>
implements ConnectionPool<org.apache.hadoop.hbase.client.Connection>

Title: HbaseConnectionPool

Description: Hbase连接池

从以下版本开始:

2015年9月19日

版本:

1.0

作者:

Victor

另请参阅:

PoolBase, ConnectionPool, 序列化表格

字段概要

字段

限定符和类型	字段和说明
private static long	serialVersionUID serialVersionUID

从类继承的字段 org.darkphoenixs.pool.PoolBase

internalPool

构造器概要

构造器

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

方法概要

方法

限定符和类型	方法和说明
org.apache.hadoop.hbase.client.Connection	getConnection() Title: getConnection Description: 获取连接
void	invalidateConnection(org.apache.hadoop.hbase.client.Connection conn) Title: invalidateConnection Description: 废弃连接
void	returnConnection(org.apache.hadoop.hbase.client.Connection conn) Title: returnConnection Description: 返回连接

从类继承的方法 org.darkphoenixs.pool.PoolBase

addObjects, clear, close, destroy, getMaxBorrowWaitTimeMillis, getMeanBorrowWaitTimeMillis, getNumActive, getNumIdle, getNumWaiters, getResource, initPool, invalidateResource, isClosed, returnResource

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

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

字段详细资料

serialVersionUID

private static final long serialVersionUID

serialVersionUID

另请参阅:

常量字段值

构造器详细资料

HbaseConnectionPool

public HbaseConnectionPool()

Title: HbaseConnectionPool

Description: 默认构造方法

HbaseConnectionPool

public HbaseConnectionPool(String host,
                   String port)

Title: HbaseConnectionPool

Description: 构造方法

参数:

host - 地址

port - 端口

HbaseConnectionPool

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

Title: HbaseConnectionPool

Description: 构造方法

参数:

host - 地址

port - 端口

master - hbase主机

rootdir - hdfs目录

HbaseConnectionPool

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

Title: HbaseConnectionPool

Description: 构造方法

参数:

hadoopConfiguration - hbase配置

HbaseConnectionPool

public HbaseConnectionPool(PoolConfig poolConfig,
                   String host,
                   String port)

Title: HbaseConnectionPool

Description: 构造方法

参数:

poolConfig - 池配置

host - 地址

port - 端口

HbaseConnectionPool

public HbaseConnectionPool(PoolConfig poolConfig,
                   org.apache.hadoop.conf.Configuration hadoopConfiguration)

Title: HbaseConnectionPool

Description: 构造方法

参数:

poolConfig - 池配置

hadoopConfiguration - hbase配置

HbaseConnectionPool

public HbaseConnectionPool(PoolConfig poolConfig,
                   String host,
                   String port,
                   String master,
                   String rootdir)

Title: HbaseConnectionPool

Description: 构造方法

参数:

poolConfig - 池配置

host - 地址

port - 端口

master - hbase主机

rootdir - hdfs目录

HbaseConnectionPool

public HbaseConnectionPool(PoolConfig poolConfig,
                   Properties properties)

参数:

poolConfig - 池配置

properties - 参数配置

从以下版本开始:

1.2.1

方法详细资料

getConnection

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

从接口复制的说明: ConnectionPool

Title: getConnection

Description: 获取连接

指定者:

getConnection 在接口中 ConnectionPool<org.apache.hadoop.hbase.client.Connection>

返回:

连接

returnConnection

public void returnConnection(org.apache.hadoop.hbase.client.Connection conn)

从接口复制的说明: ConnectionPool

Title: returnConnection

Description: 返回连接

指定者:

returnConnection 在接口中 ConnectionPool<org.apache.hadoop.hbase.client.Connection>

参数:

conn - 连接

invalidateConnection

public void invalidateConnection(org.apache.hadoop.hbase.client.Connection conn)

从接口复制的说明: ConnectionPool

Title: invalidateConnection

Description: 废弃连接

指定者:

invalidateConnection 在接口中 ConnectionPool<org.apache.hadoop.hbase.client.Connection>

参数:

conn - 连接