|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.hadoop.hbase.client.HTable
org.apache.hadoop.hbase.client.transactional.TransactionalTable
public class TransactionalTable
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 |
| Constructor Summary | |
|---|---|
TransactionalTable(HBaseConfiguration conf,
byte[] tableName)
|
|
TransactionalTable(HBaseConfiguration conf,
String tableName)
|
|
| Method Summary | |
|---|---|
void |
commit(TransactionState transactionState,
BatchUpdate batchUpdate)
Commit a BatchUpdate to the table. |
void |
deleteAll(TransactionState transactionState,
byte[] row,
long ts)
Delete all cells that match the passed row and whose timestamp is equal-to or older than the passed timestamp. |
Cell |
get(TransactionState transactionState,
byte[] row,
byte[] column)
Get a single value for the specified row and column |
Cell[] |
get(TransactionState transactionState,
byte[] row,
byte[] column,
int numVersions)
Get the specified number of versions of the specified row and column |
Cell[] |
get(TransactionState transactionState,
byte[] row,
byte[] column,
long timestamp,
int numVersions)
Get the specified number of versions of the specified row and column with the specified timestamp. |
RowResult |
getRow(TransactionState transactionState,
byte[] row)
Get all the data for the specified row at the latest timestamp |
RowResult |
getRow(TransactionState transactionState,
byte[] row,
byte[][] columns)
Get selected columns for the specified row at the latest timestamp |
RowResult |
getRow(TransactionState transactionState,
byte[] row,
byte[][] columns,
long ts)
Get selected columns for the specified row at a specified timestamp |
RowResult |
getRow(TransactionState transactionState,
byte[] row,
long ts)
Get all the data for the specified row at a specified timestamp |
Scanner |
getScanner(TransactionState transactionState,
byte[][] columns)
Get a scanner on the current table starting at first row. |
Scanner |
getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow)
Get a scanner on the current table starting at the specified row. |
Scanner |
getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow,
long timestamp)
Get a scanner on the current table starting at the specified row. |
Scanner |
getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow,
long timestamp,
RowFilterInterface filter)
Get a scanner on the current table starting at the specified row. |
Scanner |
getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow,
RowFilterInterface filter)
Get a scanner on the current table starting at the specified row. |
| Methods inherited from class org.apache.hadoop.hbase.client.HTable |
|---|
commit, commit, commit, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteAll, deleteFamily, deleteFamily, deleteFamily, deleteFamily, deleteFamily, get, get, get, get, get, get, getConnection, getRegionLocation, getRegionLocation, getRegionsInfo, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getRow, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getScanner, getStartKeys, getTableDescriptor, getTableName, isTableEnabled, isTableEnabled, isTableEnabled, isTableEnabled, lockRow, unlockRow |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public TransactionalTable(HBaseConfiguration conf,
String tableName)
throws IOException
conf - tableName -
IOException
public TransactionalTable(HBaseConfiguration conf,
byte[] tableName)
throws IOException
conf - tableName -
IOException| Method Detail |
|---|
public Cell get(TransactionState transactionState,
byte[] row,
byte[] column)
throws IOException
transactionState - row - row keycolumn - column name
IOException
public Cell[] get(TransactionState transactionState,
byte[] row,
byte[] column,
int numVersions)
throws IOException
transactionState - row - - row keycolumn - - column namenumVersions - - number of versions to retrieve
IOException
public Cell[] get(TransactionState transactionState,
byte[] row,
byte[] column,
long timestamp,
int numVersions)
throws IOException
transactionState - row - - row keycolumn - - column nametimestamp - - timestampnumVersions - - number of versions to retrieve
IOException
public RowResult getRow(TransactionState transactionState,
byte[] row)
throws IOException
transactionState - row - row key
IOException
public RowResult getRow(TransactionState transactionState,
byte[] row,
long ts)
throws IOException
transactionState - row - row keyts - timestamp
IOException
public RowResult getRow(TransactionState transactionState,
byte[] row,
byte[][] columns)
throws IOException
transactionState - row - row keycolumns - Array of column names you want to retrieve.
IOException
public RowResult getRow(TransactionState transactionState,
byte[] row,
byte[][] columns,
long ts)
throws IOException
transactionState - row - row keycolumns - Array of column names you want to retrieve.ts - timestamp
IOException
public void deleteAll(TransactionState transactionState,
byte[] row,
long ts)
throws IOException
transactionState - row - Row to updatets - Delete all cells of the same timestamp or older.
IOException
public Scanner getScanner(TransactionState transactionState,
byte[][] columns)
throws IOException
transactionState - columns - columns to scan. If column name is a column family, all
columns of the specified column family are returned. Its also possible to
pass a regex in the column qualifier. A column qualifier is judged to be a
regex if it contains at least one of the following characters:
\+|^&*$[]]}{)(.
IOException
public Scanner getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow)
throws IOException
transactionState - columns - columns to scan. If column name is a column family, all
columns of the specified column family are returned. Its also possible to
pass a regex in the column qualifier. A column qualifier is judged to be a
regex if it contains at least one of the following characters:
\+|^&*$[]]}{)(.startRow - starting row in table to scan
IOException
public Scanner getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow,
long timestamp)
throws IOException
transactionState - columns - columns to scan. If column name is a column family, all
columns of the specified column family are returned. Its also possible to
pass a regex in the column qualifier. A column qualifier is judged to be a
regex if it contains at least one of the following characters:
\+|^&*$[]]}{)(.startRow - starting row in table to scantimestamp - only return results whose timestamp <= this value
IOException
public Scanner getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow,
RowFilterInterface filter)
throws IOException
transactionState - columns - columns to scan. If column name is a column family, all
columns of the specified column family are returned. Its also possible to
pass a regex in the column qualifier. A column qualifier is judged to be a
regex if it contains at least one of the following characters:
\+|^&*$[]]}{)(.startRow - starting row in table to scanfilter - a row filter using row-key regexp and/or column data filter.
IOException
public Scanner getScanner(TransactionState transactionState,
byte[][] columns,
byte[] startRow,
long timestamp,
RowFilterInterface filter)
throws IOException
transactionState - columns - columns to scan. If column name is a column family, all
columns of the specified column family are returned. Its also possible to
pass a regex in the column qualifier. A column qualifier is judged to be a
regex if it contains at least one of the following characters:
\+|^&*$[]]}{)(.startRow - starting row in table to scantimestamp - only return results whose timestamp <= this valuefilter - a row filter using row-key regexp and/or column data filter.
IOException
public void commit(TransactionState transactionState,
BatchUpdate batchUpdate)
throws IOException
transactionState - batchUpdate -
IOException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||