eu.fbk.knowledgestore.datastore.hbase.utils

Class OmidHBaseUtils

java.lang.Object

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

eu.fbk.knowledgestore.datastore.hbase.utils.OmidHBaseUtils

public class OmidHBaseUtils
extends AbstractHBaseUtils

Implements HBase operations using Yahoo!'s Omid.

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
OmidHBaseUtils(Properties properties) Constructor.

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
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
Object	getTable(String tableName) Gets a handle of a specific table.
void	processDelete(org.openrdf.model.URI id, String tabName, String famName, String quaName) Process operations on the Resource table.
void	processPut(Record record, String tabName, String famName, String quaName) Process operations on the Resource table.
void	rollback() Rollbacks work done.

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

checkAndCreateTable, createConfiguration, createDelete, createPut, 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

OmidHBaseUtils

public OmidHBaseUtils(Properties properties)

Constructor.

Parameters:

properties - the configuration properties

Method Detail

commit

public void commit()
            throws DataCorruptedException,
                   IOException,
                   IllegalStateException

Commits work done.

Specified by:

commit in class AbstractHBaseUtils

Throws:

DataCorruptedException - in case a rollback has not been successful.

IOException - in case a commit has not been successful.

IllegalStateException

rollback

public void rollback()
              throws DataCorruptedException,
                     IOException,
                     IllegalStateException

Rollbacks work done.

Specified by:

rollback in class AbstractHBaseUtils

Throws:

DataCorruptedException - in case a rollback has not been successful.

IOException - in case a commit has not been successful.

IllegalStateException

getTable

public Object 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.

processPut

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

Description copied from class: AbstractHBaseUtils

Process operations on the Resource table.

Specified by:

processPut in class AbstractHBaseUtils

Parameters:

record - to be put.

begin

public void begin()

Description copied from class: AbstractHBaseUtils

Begins a transaction.

Specified by:

begin in class AbstractHBaseUtils

processDelete

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

Description copied from class: AbstractHBaseUtils

Process operations on the Resource 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

checkForErrors

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

Description copied from class: AbstractHBaseUtils

Checking for errors after operations have been processed.

Specified by:

checkForErrors in class AbstractHBaseUtils

Returns:

count

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

Gets a number of record of tableName matching condition

Specified by:

count in class AbstractHBaseUtils

Parameters:

tableName - to scan

condition - to match

scan - to scan

Returns:

the number of records matching the optional condition and type specified

Throws:

IOException

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: