org.springframework.data.hadoop.hbase

Class HbaseUtils

java.lang.Object

org.springframework.data.hadoop.hbase.HbaseUtils

public class HbaseUtils
extends java.lang.Object

Helper class featuring methods for Hbase table handling and exception translation.

Author:

Costin Leau

Constructor Summary

Constructors

Constructor and Description
HbaseUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static org.springframework.dao.DataAccessException	convertHbaseException(java.lang.Exception ex) Converts the given (Hbase) exception to an appropriate exception from org.springframework.dao hierarchy.
static org.apache.hadoop.hbase.client.HTableInterface	getHTable(java.lang.String tableName, org.apache.hadoop.conf.Configuration configuration) Retrieves an Hbase table instance identified by its name.
static org.apache.hadoop.hbase.client.HTableInterface	getHTable(java.lang.String tableName, org.apache.hadoop.conf.Configuration configuration, java.nio.charset.Charset charset, org.apache.hadoop.hbase.client.HTableInterfaceFactory tableFactory) Retrieves an Hbase table instance identified by its name and charset using the given table factory.
static void	releaseTable(java.lang.String tableName, org.apache.hadoop.hbase.client.HTableInterface table) Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).
static void	releaseTable(java.lang.String tableName, org.apache.hadoop.hbase.client.HTableInterface table, org.apache.hadoop.hbase.client.HTableInterfaceFactory tableFactory) Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).

Methods inherited from class java.lang.Object

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

Constructor Detail

HbaseUtils

public HbaseUtils()

Method Detail

convertHbaseException

public static org.springframework.dao.DataAccessException convertHbaseException(java.lang.Exception ex)

Converts the given (Hbase) exception to an appropriate exception from org.springframework.dao hierarchy.

Parameters:

ex - Hbase exception that occurred

Returns:

the corresponding DataAccessException instance

getHTable

public static org.apache.hadoop.hbase.client.HTableInterface getHTable(java.lang.String tableName,
                                                       org.apache.hadoop.conf.Configuration configuration)

Retrieves an Hbase table instance identified by its name.

Parameters:

configuration - Hbase configuration object

tableName - table name

Returns:

table instance

getHTable

public static org.apache.hadoop.hbase.client.HTableInterface getHTable(java.lang.String tableName,
                                                       org.apache.hadoop.conf.Configuration configuration,
                                                       java.nio.charset.Charset charset,
                                                       org.apache.hadoop.hbase.client.HTableInterfaceFactory tableFactory)

Retrieves an Hbase table instance identified by its name and charset using the given table factory.

Parameters:

tableName - table name

configuration - Hbase configuration object

charset - name charset (may be null)

tableFactory - table factory (may be null)

Returns:

table instance

releaseTable

public static void releaseTable(java.lang.String tableName,
                org.apache.hadoop.hbase.client.HTableInterface table)

Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).

Parameters:

tableName - table name

table - table

releaseTable

public static void releaseTable(java.lang.String tableName,
                org.apache.hadoop.hbase.client.HTableInterface table,
                org.apache.hadoop.hbase.client.HTableInterfaceFactory tableFactory)

Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).

Parameters:

tableName - table name

table - table

tableFactory - table factory