org.darkphoenixs.pool.hbase

类 HbaseSharedConnPool

java.lang.Object

org.darkphoenixs.pool.hbase.HbaseSharedConnPool

所有已实现的接口:

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

public class HbaseSharedConnPool
extends Object
implements ConnectionPool<org.apache.hadoop.hbase.client.Connection>

Title: HbaseSharedConnPool

Description: Hbase共享连接池（单例）

从以下版本开始:

2016 /8/25

版本:

1.2.3

作者:

Victor.Zxy

另请参阅:

ConnectionPool, 序列化表格

字段概要

字段

限定符和类型	字段和说明
private org.apache.hadoop.hbase.client.Connection	connection
private static AtomicReference<HbaseSharedConnPool>	pool

构造器概要

构造器

限定符	构造器和说明
private	HbaseSharedConnPool(org.apache.hadoop.conf.Configuration configuration)

方法概要

方法

限定符和类型	方法和说明
void	close() Close.
org.apache.hadoop.hbase.client.Connection	getConnection() Title: getConnection Description: 获取连接
static HbaseSharedConnPool	getInstance(org.apache.hadoop.conf.Configuration configuration) Gets instance.
static HbaseSharedConnPool	getInstance(Properties properties) Gets instance.
static HbaseSharedConnPool	getInstance(String host, String port, String master, String rootdir) Gets instance.
void	invalidateConnection(org.apache.hadoop.hbase.client.Connection conn) Title: invalidateConnection Description: 废弃连接
void	returnConnection(org.apache.hadoop.hbase.client.Connection conn) Title: returnConnection Description: 返回连接

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

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

字段详细资料

pool

private static final AtomicReference<HbaseSharedConnPool> pool

connection

private final org.apache.hadoop.hbase.client.Connection connection

构造器详细资料

HbaseSharedConnPool

private HbaseSharedConnPool(org.apache.hadoop.conf.Configuration configuration)
                     throws IOException

抛出:

IOException

方法详细资料

getInstance

public static HbaseSharedConnPool getInstance(String host,
                              String port,
                              String master,
                              String rootdir)

Gets instance.

参数:

host - the host

port - the port

master - the master

rootdir - the rootdir

返回:

the instance

getInstance

public static HbaseSharedConnPool getInstance(Properties properties)

Gets instance.

参数:

properties - the properties

返回:

the instance

getInstance

public static HbaseSharedConnPool getInstance(org.apache.hadoop.conf.Configuration configuration)

Gets instance.

参数:

configuration - the configuration

返回:

the instance

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 - 连接

close

public void close()

Close.