org.apache.hawq.pxf.plugins.hbase.utilities

Class HBaseUtilities

java.lang.Object

org.apache.hawq.pxf.plugins.hbase.utilities.HBaseUtilities

public class HBaseUtilities
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
HBaseUtilities()

Method Summary

Modifier and Type	Method and Description
static void	closeConnection(org.apache.hadoop.hbase.client.Admin hbaseAdmin, org.apache.hadoop.hbase.client.Connection hbaseConnection) Closes HBase admin and connection if they are open.
static org.apache.hadoop.conf.Configuration	initHBaseConfiguration() Initializes HBase configuration.
static boolean	isTableAvailable(org.apache.hadoop.hbase.client.Admin hbaseAdmin, java.lang.String tableName) Returns if given table exists and is enabled.

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseUtilities

public HBaseUtilities()

Method Detail

initHBaseConfiguration

public static org.apache.hadoop.conf.Configuration initHBaseConfiguration()

Initializes HBase configuration. The following parameters are edited: hbase.client.retries.number = 1 - tries to connect to HBase only 2 times before failing.

Returns:

HBase configuration

isTableAvailable

public static boolean isTableAvailable(org.apache.hadoop.hbase.client.Admin hbaseAdmin,
                                       java.lang.String tableName)
                                throws java.io.IOException

Returns if given table exists and is enabled.

Parameters:

hbaseAdmin - HBase admin, must be initialized

tableName - table name

Returns:

true if table exists

Throws:

java.io.IOException - if a remote or network exception occurs when connecting to HBase

closeConnection

public static void closeConnection(org.apache.hadoop.hbase.client.Admin hbaseAdmin,
                                   org.apache.hadoop.hbase.client.Connection hbaseConnection)
                            throws java.io.IOException

Closes HBase admin and connection if they are open.

Parameters:

hbaseAdmin - HBase admin

hbaseConnection - HBase connection

Throws:

java.io.IOException - if an I/O error occurs when connecting to HBase