org.apache.hadoop.hbase.client

Class ConnectionFactory

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionFactory

@InterfaceAudience.Public
public class ConnectionFactory
extends Object

A non-instantiable class that manages creation of Connections. Managing the lifecycle of the Connections to the cluster is the responsibility of the caller. From a Connection, Table implementations are retrieved with Connection.getTable(org.apache.hadoop.hbase.TableName). Example:

 Connection connection = ConnectionFactory.createConnection(config);
 Table table = connection.getTable(TableName.valueOf("table1"));
 try {
   // Use the table as needed, for a single operation and a single thread
 } finally {
   table.close();
   connection.close();
 }
 

Since 2.2.0, Connection created by ConnectionFactory can contain user-specified kerberos credentials if caller has following two configurations set:

• hbase.client.keytab.file, points to a valid keytab on the local filesystem
• hbase.client.kerberos.principal, gives the Kerberos principal to use

By this way, caller can directly connect to kerberized cluster without caring login and credentials renewal logic in application.

Similarly, Connection also returns Admin and RegionLocator implementations.

Since:

0.99.0

See Also:

Connection

Field Summary

Fields

Modifier and Type	Field and Description
static String	HBASE_CLIENT_ASYNC_CONNECTION_IMPL

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ConnectionFactory() No public c.tors

Method Summary

Modifier and Type	Method and Description
static CompletableFuture<AsyncConnection>	createAsyncConnection() Call createAsyncConnection(Configuration) using default HBaseConfiguration.
static CompletableFuture<AsyncConnection>	createAsyncConnection(org.apache.hadoop.conf.Configuration conf) Call createAsyncConnection(Configuration, User) using the given conf and a User object created by UserProvider.
static CompletableFuture<AsyncConnection>	createAsyncConnection(org.apache.hadoop.conf.Configuration conf, User user) Create a new AsyncConnection instance using the passed conf and user.
static Connection	createConnection() Create a new Connection instance using default HBaseConfiguration.
static Connection	createConnection(org.apache.hadoop.conf.Configuration conf) Create a new Connection instance using the passed conf instance.
static Connection	createConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool) Create a new Connection instance using the passed conf instance.
static Connection	createConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user) Create a new Connection instance using the passed conf instance.
static Connection	createConnection(org.apache.hadoop.conf.Configuration conf, User user) Create a new Connection instance using the passed conf instance.

Methods inherited from class java.lang.Object

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

Field Detail

HBASE_CLIENT_ASYNC_CONNECTION_IMPL

public static final String HBASE_CLIENT_ASYNC_CONNECTION_IMPL

See Also:

Constant Field Values

Constructor Detail

ConnectionFactory

protected ConnectionFactory()

No public c.tors

Method Detail

createConnection

public static Connection createConnection()
                                   throws IOException

Create a new Connection instance using default HBaseConfiguration. Connection encapsulates all housekeeping for a connection to the cluster. All tables and interfaces created from returned connection share zookeeper connection, meta cache, and connections to region servers and masters.
The caller is responsible for calling Connection.close() on the returned connection instance. Typical usage:

 Connection connection = ConnectionFactory.createConnection();
 Table table = connection.getTable(TableName.valueOf("mytable"));
 try {
   table.get(...);
   ...
 } finally {
   table.close();
   connection.close();
 }
 

Returns:

Connection object for conf

Throws:

IOException

createConnection

public static Connection createConnection(org.apache.hadoop.conf.Configuration conf)
                                   throws IOException

Create a new Connection instance using the passed conf instance. Connection encapsulates all housekeeping for a connection to the cluster. All tables and interfaces created from returned connection share zookeeper connection, meta cache, and connections to region servers and masters.
The caller is responsible for calling Connection.close() on the returned connection instance. Typical usage:

 Connection connection = ConnectionFactory.createConnection(conf);
 Table table = connection.getTable(TableName.valueOf("mytable"));
 try {
   table.get(...);
   ...
 } finally {
   table.close();
   connection.close();
 }
 

Parameters:

conf - configuration

Returns:

Connection object for conf

Throws:

IOException

createConnection

public static Connection createConnection(org.apache.hadoop.conf.Configuration conf,
                                          ExecutorService pool)
                                   throws IOException

Create a new Connection instance using the passed conf instance. Connection encapsulates all housekeeping for a connection to the cluster. All tables and interfaces created from returned connection share zookeeper connection, meta cache, and connections to region servers and masters.
The caller is responsible for calling Connection.close() on the returned connection instance. Typical usage:

 Connection connection = ConnectionFactory.createConnection(conf);
 Table table = connection.getTable(TableName.valueOf("mytable"));
 try {
   table.get(...);
   ...
 } finally {
   table.close();
   connection.close();
 }
 

Parameters:

conf - configuration

pool - the thread pool to use for batch operations

Returns:

Connection object for conf

Throws:

IOException

createConnection

public static Connection createConnection(org.apache.hadoop.conf.Configuration conf,
                                          User user)
                                   throws IOException

Create a new Connection instance using the passed conf instance. Connection encapsulates all housekeeping for a connection to the cluster. All tables and interfaces created from returned connection share zookeeper connection, meta cache, and connections to region servers and masters.
The caller is responsible for calling Connection.close() on the returned connection instance. Typical usage:

 Connection connection = ConnectionFactory.createConnection(conf);
 Table table = connection.getTable(TableName.valueOf("table1"));
 try {
   table.get(...);
   ...
 } finally {
   table.close();
   connection.close();
 }
 

Parameters:

conf - configuration

user - the user the connection is for

Returns:

Connection object for conf

Throws:

IOException

createConnection

public static Connection createConnection(org.apache.hadoop.conf.Configuration conf,
                                          ExecutorService pool,
                                          User user)
                                   throws IOException

Create a new Connection instance using the passed conf instance. Connection encapsulates all housekeeping for a connection to the cluster. All tables and interfaces created from returned connection share zookeeper connection, meta cache, and connections to region servers and masters.
The caller is responsible for calling Connection.close() on the returned connection instance. Typical usage:

 Connection connection = ConnectionFactory.createConnection(conf);
 Table table = connection.getTable(TableName.valueOf("table1"));
 try {
   table.get(...);
   ...
 } finally {
   table.close();
   connection.close();
 }
 

Parameters:

conf - configuration

user - the user the connection is for

pool - the thread pool to use for batch operations

Returns:

Connection object for conf

Throws:

IOException

createAsyncConnection

public static CompletableFuture<AsyncConnection> createAsyncConnection()

Call createAsyncConnection(Configuration) using default HBaseConfiguration.

Returns:

AsyncConnection object wrapped by CompletableFuture

See Also:

createAsyncConnection(Configuration)

createAsyncConnection

public static CompletableFuture<AsyncConnection> createAsyncConnection(org.apache.hadoop.conf.Configuration conf)

Call createAsyncConnection(Configuration, User) using the given conf and a User object created by UserProvider. The given conf will also be used to initialize the UserProvider.

Parameters:

conf - configuration

Returns:

AsyncConnection object wrapped by CompletableFuture

See Also:

createAsyncConnection(Configuration, User), UserProvider

createAsyncConnection

public static CompletableFuture<AsyncConnection> createAsyncConnection(org.apache.hadoop.conf.Configuration conf,
                                                                       User user)

Create a new AsyncConnection instance using the passed conf and user. AsyncConnection encapsulates all housekeeping for a connection to the cluster. All tables and interfaces created from returned connection share zookeeper connection, meta cache, and connections to region servers and masters.

The caller is responsible for calling Closeable.close() on the returned connection instance.

Usually you should only create one AsyncConnection instance in your code and use it everywhere as it is thread safe.

Parameters:

conf - configuration

user - the user the asynchronous connection is for

Returns:

AsyncConnection object wrapped by CompletableFuture