org.apache.hadoop.hbase.client.transactional
Class TransactionalTable

java.lang.Object
  org.apache.hadoop.hbase.client.HTable
      org.apache.hadoop.hbase.client.transactional.TransactionalTable

Direct Known Subclasses:

IndexedTable

public class TransactionalTable
extends HTable

Table with transactional support.

Nested Class Summary

protected class

TransactionalTable.TransactionalClientScanner

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.client.HTable

HTable.ClientScanner, HTable.OldClientScanner

Field Summary

Fields inherited from class org.apache.hadoop.hbase.client.HTable

scannerCaching, scannerTimeout

Constructor Summary

TransactionalTable(HBaseConfiguration conf, byte[] tableName)

TransactionalTable(HBaseConfiguration conf, String tableName)

Method Summary

void	delete(TransactionState transactionState, Delete delete)
Result	get(TransactionState transactionState, Get get) Method for getting data from a row
ResultScanner	getScanner(TransactionState transactionState, Scan scan)
void	put(TransactionState transactionState, Put put) Commit a Put to the table.

Methods inherited from class org.apache.hadoop.hbase.client.HTable

checkAndPut, checkAndSave, close, commit, commit, commit, delete, delete, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAllByRegex, deleteAllByRegex, deleteAllByRegex, deleteAllByRegex, deleteFamily, deleteFamily, deleteFamily, deleteFamily, deleteFamily, deleteFamilyByRegex, deleteFamilyByRegex, deleteFamilyByRegex, deleteFamilyByRegex, deleteFamilyByRegex, exists, exists, exists, exists, exists, flushCommits, get, get, get, get, get, get, get, getClosestRowBefore, getConnection, getEndKeys, getRegionLocation, getRegionLocation, getRegionsInfo, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRowOrBefore, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScannerCaching, getStartEndKeys, getStartKeys, getTableDescriptor, getTableName, getWriteBufferSize, incrementColumnValue, incrementColumnValue, isAutoFlush, isTableEnabled, isTableEnabled, isTableEnabled, isTableEnabled, lockRow, put, put, setAutoFlush, setScannerCaching, setWriteBufferSize, unlockRow

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionalTable

public TransactionalTable(HBaseConfiguration conf,
                          String tableName)
                   throws IOException

Parameters:

conf -

tableName -

Throws:

IOException

TransactionalTable

public TransactionalTable(HBaseConfiguration conf,
                          byte[] tableName)
                   throws IOException

Parameters:

conf -

tableName -

Throws:

IOException

Method Detail

get

public Result get(TransactionState transactionState,
                  Get get)
           throws IOException

Method for getting data from a row

Parameters:

get - the Get to fetch

Returns:

the result

Throws:

IOException

Since:

0.20.0

delete

public void delete(TransactionState transactionState,
                   Delete delete)
            throws IOException

Parameters:

delete -

Throws:

IOException

Since:

0.20.0

put

public void put(TransactionState transactionState,
                Put put)
         throws IOException

Commit a Put to the table.

If autoFlush is false, the update is buffered.

Parameters:

put -

Throws:

IOException

Since:

0.20.0

getScanner

public ResultScanner getScanner(TransactionState transactionState,
                                Scan scan)
                         throws IOException

Throws:

IOException