eu.fbk.knowledgestore.datastore.hbase.utils

Class HBaseUtils

java.lang.Object

eu.fbk.knowledgestore.datastore.hbase.utils.AbstractHBaseUtils

eu.fbk.knowledgestore.datastore.hbase.utils.HBaseUtils

public class HBaseUtils
extends AbstractHBaseUtils

Field Summary

Fields inherited from class eu.fbk.knowledgestore.datastore.hbase.utils.AbstractHBaseUtils

logger

Constructor Summary

Constructors

Constructor and Description
HBaseUtils(Properties properties)

Method Summary

Modifier and Type	Method and Description
void	begin() Begins a transaction.
List<Object>	checkForErrors(Object[] objs) Checking for errors after operations have been processed.
void	commit() Commits work done.
long	count(String tableName, String familyName, XPath condition) Gets a number of record of tableName matching condition
Delete	createDelete(org.openrdf.model.URI id, String tableName) Creates deletes for HBase tables
Put	createPut(Record record, String tableName, String famName, String quaName) Creates puts for HBase
List<Record>	get(String tableName, List<org.openrdf.model.URI> ids) Gets a resource based on information passed.
Record	get(String tableName, org.openrdf.model.URI id) Gets a Record based on information passed.
ResultScanner	getScanner(String tableName, Scan scan) Gets a scanner for a specific table
HTable	getTable(String tableName) Gets a handle of a specific table.
void	processDelete(org.openrdf.model.URI id, String tabName, String famName, String quaName) Process delete operations on an HBase table.
void	processPut(Record record, String tabName, String famName, String quaName) Process put operations on an HBase table.
void	rollback() Rollbacks work done.

Methods inherited from class eu.fbk.knowledgestore.datastore.hbase.utils.AbstractHBaseUtils

checkAndCreateTable, createConfiguration, factoryHBaseUtils, getFilter, getHbaseTableNamePrefix, getHbcfg, getLogger, getResultScan, getScan, getSerializer, getServerFilterFlag, initHbaseTableNamePrefix, initSerializer, initServerFilterFlag, setHbcfg, setLogger

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseUtils

public HBaseUtils(Properties properties)

Method Detail

getTable

public HTable getTable(String tableName)

Gets a handle of a specific table.

Specified by:

getTable in class AbstractHBaseUtils

Parameters:

tableName - of the table to be accessed.

Returns:

HTable of the table found.

commit

public void commit()

Commits work done.

Specified by:

commit in class AbstractHBaseUtils

rollback

public void rollback()

Rollbacks work done.

Specified by:

rollback in class AbstractHBaseUtils

getScanner

public ResultScanner getScanner(String tableName,
                                Scan scan)

Gets a scanner for a specific table

Specified by:

getScanner in class AbstractHBaseUtils

Parameters:

tableName - to get the scanner from

scan - for the specific table

conf - object to get a hold of an HBase table

Returns:

processPut

public void processPut(Record record,
                       String tabName,
                       String famName,
                       String quaName)

Process put operations on an HBase table.

Specified by:

processPut in class AbstractHBaseUtils

Parameters:

record - to be put.

processDelete

public void processDelete(org.openrdf.model.URI id,
                          String tabName,
                          String famName,
                          String quaName)

Process delete operations on an HBase table.

Specified by:

processDelete in class AbstractHBaseUtils

tabName - where operations will be performed.

famName - where operation will be performed.

quaName - where operation will be performed.

get

public Record get(String tableName,
                  org.openrdf.model.URI id)
           throws IOException

Gets a Record based on information passed.

Specified by:

get in class AbstractHBaseUtils

Parameters:

tableName - to do the get.

id - of the Record needed

Throws:

IOException

get

public List<Record> get(String tableName,
                        List<org.openrdf.model.URI> ids)
                 throws IOException

Description copied from class: AbstractHBaseUtils

Gets a resource based on information passed.

Specified by:

get in class AbstractHBaseUtils

Parameters:

tableName - table name to get data from

ids - to be retrieved

Returns:

Throws:

IOException

createPut

public Put createPut(Record record,
                     String tableName,
                     String famName,
                     String quaName)
              throws IOException

Creates puts for HBase

Overrides:

createPut in class AbstractHBaseUtils

Parameters:

record -

Throws:

IOException

createDelete

public Delete createDelete(org.openrdf.model.URI id,
                           String tableName)
                    throws IOException

Creates deletes for HBase tables

Overrides:

createDelete in class AbstractHBaseUtils

Parameters:

record -

tableName -

conf -

Returns:

Throws:

IOException

checkForErrors

public List<Object> checkForErrors(Object[] objs)

Checking for errors after operations have been processed.

Specified by:

checkForErrors in class AbstractHBaseUtils

Parameters:

objs -

Returns:

count

public long count(String tableName,
                  String familyName,
                  XPath condition)
           throws IOException

Gets a number of record of tableName matching condition

Specified by:

count in class AbstractHBaseUtils

Parameters:

tableName - the table name

familyName - the family

condition - to match

Returns:

the number of records matching the optional condition and type specified

Throws:

IOException

begin

public void begin()

Description copied from class: AbstractHBaseUtils

Begins a transaction.

Specified by:

begin in class AbstractHBaseUtils