org.apache.hadoop.hbase.thrift

Class ThriftHBaseServiceHandler

java.lang.Object

org.apache.hadoop.hbase.thrift.HBaseServiceHandler

org.apache.hadoop.hbase.thrift.ThriftHBaseServiceHandler

All Implemented Interfaces:

org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

@InterfaceAudience.Private
public class ThriftHBaseServiceHandler
extends HBaseServiceHandler
implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

The HBaseServiceHandler is a glue object that connects Thrift RPC calls to the HBase client API primarily defined in the Admin and Table objects.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThriftHBaseServiceHandler.IOErrorWithCause
protected static class	ThriftHBaseServiceHandler.ResultScannerWrapper

Field Summary

Fields

Modifier and Type	Field and Description
(package private) IncrementCoalescer	coalescer
static int	HREGION_VERSION
private static org.slf4j.Logger	LOG
private int	nextScannerId
private HashMap<Integer,ThriftHBaseServiceHandler.ResultScannerWrapper>	scannerMap

Fields inherited from class org.apache.hadoop.hbase.thrift.HBaseServiceHandler

CLEANUP_INTERVAL, conf, connectionCache, MAX_IDLETIME, metrics

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ThriftHBaseServiceHandler(org.apache.hadoop.conf.Configuration c, UserProvider userProvider)

Method Summary

Modifier and Type	Method and Description
private static void	addAttributes(OperationWithAttributes op, Map<ByteBuffer,ByteBuffer> attributes) Adds all the attributes into the Operation object
protected int	addScanner(ResultScanner scanner, boolean sortColumns) Assigns a unique ID to the scanner and adds the mapping to an internal hash-map.
List<org.apache.hadoop.hbase.thrift.generated.TCell>	append(org.apache.hadoop.hbase.thrift.generated.TAppend tappend) Appends values to one or more columns within a single row.
protected long	atomicIncrement(ByteBuffer tableName, ByteBuffer row, byte[] family, byte[] qualifier, long amount)
long	atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long amount) Atomically increment the column value specified.
boolean	checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, org.apache.hadoop.hbase.thrift.generated.Mutation mput, Map<ByteBuffer,ByteBuffer> attributes) Atomically checks if a row/family/qualifier value matches the expected value.
private void	closeTable(Table table)
void	compact(ByteBuffer tableNameOrRegionName)
void	createTable(ByteBuffer in_tableName, List<org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor> columnFamilies) Create a table with the specified column families.
void	deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) Delete all cells that match the passed row and column.
void	deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) Completely delete the row's cells.
void	deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Completely delete the row's cells marked with a timestamp equal-to or older than the passed timestamp.
void	deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Delete all cells that match the passed row and column and whose timestamp is equal-to or older than the passed timestamp.
void	deleteTable(ByteBuffer in_tableName) Deletes a table
void	disableTable(ByteBuffer tableName) Disables a table (takes it off-line) If it is being served, the master will tell the servers to stop serving it.
void	enableTable(ByteBuffer tableName) Brings a table on-line (enables it)
protected List<org.apache.hadoop.hbase.thrift.generated.TCell>	get(ByteBuffer tableName, ByteBuffer row, byte[] family, byte[] qualifier, Map<ByteBuffer,ByteBuffer> attributes) Note: this internal interface is slightly different from public APIs in regard to handling of the qualifier.
List<org.apache.hadoop.hbase.thrift.generated.TCell>	get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) Get a single TCell for the specified table, row, and column at the latest timestamp.
(package private) byte[][]	getAllColumns(Table table) Returns a list of all the column families for a given Table.
Map<ByteBuffer,org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor>	getColumnDescriptors(ByteBuffer tableName) List all the column families assoicated with a table.
private static org.apache.hadoop.hbase.thrift.generated.IOError	getIOError(Throwable throwable)
org.apache.hadoop.hbase.thrift.generated.TRegionInfo	getRegionInfo(ByteBuffer searchRow) Get the regininfo for the specified row.
private Result	getReverseScanResult(byte[] tableName, byte[] row, byte[] family)
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) Get all the data for the specified table and row at the latest timestamp.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes) Get all the data for the specified table and rows at the latest timestamp.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Get all the data for the specified table and rows at the specified timestamp.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) Get the specified columns for the specified table and rows at the latest timestamp.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Get the specified columns for the specified table and rows at the specified timestamp.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Get all the data for the specified table and row at the specified timestamp.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) Get the specified columns for the specified table and row at the latest timestamp.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Get the specified columns for the specified table and row at the specified timestamp.
private ThriftHBaseServiceHandler.ResultScannerWrapper	getScanner(int id) Returns the scanner associated with the specified ID.
private static TableName	getTableName(ByteBuffer buffer)
List<ByteBuffer>	getTableNames() List all the userspace tables.
List<org.apache.hadoop.hbase.thrift.generated.TRegionInfo>	getTableRegions(ByteBuffer tableName) List the regions associated with a table.
List<org.apache.hadoop.hbase.thrift.generated.TCell>	getVer(ByteBuffer tableName, ByteBuffer row, byte[] family, byte[] qualifier, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) Note: this public interface is slightly different from public Java APIs in regard to handling of the qualifier.
List<org.apache.hadoop.hbase.thrift.generated.TCell>	getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) Get the specified number of versions for the specified table, row, and column.
protected List<org.apache.hadoop.hbase.thrift.generated.TCell>	getVerTs(ByteBuffer tableName, ByteBuffer row, byte[] family, byte[] qualifier, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) Note: this internal interface is slightly different from public APIs in regard to handling of the qualifier.
List<org.apache.hadoop.hbase.thrift.generated.TCell>	getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) Get the specified number of versions for the specified table, row, and column.
void	increment(org.apache.hadoop.hbase.thrift.generated.TIncrement tincrement) Increment a cell by the ammount.
void	incrementRows(List<org.apache.hadoop.hbase.thrift.generated.TIncrement> tincrements)
boolean	isTableEnabled(ByteBuffer tableName)
void	majorCompact(ByteBuffer tableNameOrRegionName)
void	mutateRow(ByteBuffer tableName, ByteBuffer row, List<org.apache.hadoop.hbase.thrift.generated.Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes) Apply a series of mutations (updates/deletes) to a row in a single transaction.
void	mutateRows(ByteBuffer tableName, List<org.apache.hadoop.hbase.thrift.generated.BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes) Apply a series of batches (each a series of mutations on a single row) in a single transaction.
void	mutateRowsTs(ByteBuffer tableName, List<org.apache.hadoop.hbase.thrift.generated.BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Apply a series of batches (each a series of mutations on a single row) in a single transaction.
void	mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<org.apache.hadoop.hbase.thrift.generated.Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Apply a series of mutations (updates/deletes) to a row in a single transaction.
private ThriftHBaseServiceHandler.ResultScannerWrapper	removeScanner(int id) Removes the scanner associated with the specified ID from the internal id->scanner hash-map.
void	scannerClose(int id) Closes the server-state associated with an open scanner.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	scannerGet(int id) Returns the scanner's current row value and advances to the next row in the table.
List<org.apache.hadoop.hbase.thrift.generated.TRowResult>	scannerGetList(int id, int nbRows) Returns, starting at the scanner's current row value nbRows worth of rows and advances to the next row in the table.
int	scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) Get a scanner on the current table starting at the specified row and ending at the last row in the table.
int	scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Get a scanner on the current table starting at the specified row and ending at the last row in the table.
int	scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) Open a scanner for a given prefix.
int	scannerOpenWithScan(ByteBuffer tableName, org.apache.hadoop.hbase.thrift.generated.TScan tScan, Map<ByteBuffer,ByteBuffer> attributes) Get a scanner on the current table, using the Scan instance for the scan parameters.
int	scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) Get a scanner on the current table starting and stopping at the specified rows.
int	scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Get a scanner on the current table starting and stopping at the specified rows.

Methods inherited from class org.apache.hadoop.hbase.thrift.HBaseServiceHandler

getAdmin, getTable, getTable, initMetrics, setEffectiveUser

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

HREGION_VERSION

public static final int HREGION_VERSION

See Also:

Constant Field Values

nextScannerId

private int nextScannerId

scannerMap

private HashMap<Integer,ThriftHBaseServiceHandler.ResultScannerWrapper> scannerMap

coalescer

IncrementCoalescer coalescer

Constructor Detail

ThriftHBaseServiceHandler

protected ThriftHBaseServiceHandler(org.apache.hadoop.conf.Configuration c,
                                    UserProvider userProvider)
                             throws IOException

Throws:

IOException

Method Detail

getAllColumns

byte[][] getAllColumns(Table table)
                throws IOException

Returns a list of all the column families for a given Table.

Parameters:

table - table

Throws:

IOException

addScanner

protected int addScanner(ResultScanner scanner,
                         boolean sortColumns)

Assigns a unique ID to the scanner and adds the mapping to an internal hash-map.

Parameters:

scanner - the ResultScanner to add

Returns:

integer scanner id

getScanner

private ThriftHBaseServiceHandler.ResultScannerWrapper getScanner(int id)

Returns the scanner associated with the specified ID.

Parameters:

id - the ID of the scanner to get

Returns:

a Scanner, or null if ID was invalid.

removeScanner

private ThriftHBaseServiceHandler.ResultScannerWrapper removeScanner(int id)

Removes the scanner associated with the specified ID from the internal id->scanner hash-map.

Parameters:

id - the ID of the scanner to remove

Returns:

a Scanner, or null if ID was invalid.

enableTable

public void enableTable(ByteBuffer tableName)
                 throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Brings a table on-line (enables it)

Specified by:

enableTable in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of the table

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

disableTable

public void disableTable(ByteBuffer tableName)
                  throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Disables a table (takes it off-line) If it is being served, the master will tell the servers to stop serving it.

Specified by:

disableTable in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of the table

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

isTableEnabled

public boolean isTableEnabled(ByteBuffer tableName)
                       throws org.apache.hadoop.hbase.thrift.generated.IOError

Specified by:

isTableEnabled in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of the table to check

Returns:

true if table is on-line

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

compact

public void compact(ByteBuffer tableNameOrRegionName)
             throws org.apache.hadoop.hbase.thrift.generated.IOError

Specified by:

compact in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

majorCompact

public void majorCompact(ByteBuffer tableNameOrRegionName)
                  throws org.apache.hadoop.hbase.thrift.generated.IOError

Specified by:

majorCompact in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getTableNames

public List<ByteBuffer> getTableNames()
                               throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

List all the userspace tables.

Specified by:

getTableNames in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Returns:

returns a list of names

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getTableRegions

public List<org.apache.hadoop.hbase.thrift.generated.TRegionInfo> getTableRegions(ByteBuffer tableName)
                                                                           throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

List the regions associated with a table.

Specified by:

getTableRegions in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - table name

Returns:

the list of regions in the given table, or an empty list if the table does not exist

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

get

public List<org.apache.hadoop.hbase.thrift.generated.TCell> get(ByteBuffer tableName,
                                                                ByteBuffer row,
                                                                ByteBuffer column,
                                                                Map<ByteBuffer,ByteBuffer> attributes)
                                                         throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get a single TCell for the specified table, row, and column at the latest timestamp. Returns an empty list if no such value exists.

Specified by:

get in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

column - column name

attributes - Get attributes

Returns:

value for specified row/column

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

get

protected List<org.apache.hadoop.hbase.thrift.generated.TCell> get(ByteBuffer tableName,
                                                                   ByteBuffer row,
                                                                   byte[] family,
                                                                   byte[] qualifier,
                                                                   Map<ByteBuffer,ByteBuffer> attributes)
                                                            throws org.apache.hadoop.hbase.thrift.generated.IOError

Note: this internal interface is slightly different from public APIs in regard to handling of the qualifier. Here we differ from the public Java API in that null != byte[0]. Rather, we respect qual == null as a request for the entire column family. The caller ( get(ByteBuffer, ByteBuffer, ByteBuffer, Map)) interface IS consistent in that the column is parse like normal.

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getVer

public List<org.apache.hadoop.hbase.thrift.generated.TCell> getVer(ByteBuffer tableName,
                                                                   ByteBuffer row,
                                                                   ByteBuffer column,
                                                                   int numVersions,
                                                                   Map<ByteBuffer,ByteBuffer> attributes)
                                                            throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get the specified number of versions for the specified table, row, and column.

Specified by:

getVer in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

column - column name

numVersions - number of versions to retrieve

attributes - Get attributes

Returns:

list of cells for specified row/column

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getVer

public List<org.apache.hadoop.hbase.thrift.generated.TCell> getVer(ByteBuffer tableName,
                                                                   ByteBuffer row,
                                                                   byte[] family,
                                                                   byte[] qualifier,
                                                                   int numVersions,
                                                                   Map<ByteBuffer,ByteBuffer> attributes)
                                                            throws org.apache.hadoop.hbase.thrift.generated.IOError

Note: this public interface is slightly different from public Java APIs in regard to handling of the qualifier. Here we differ from the public Java API in that null != byte[0]. Rather, we respect qual == null as a request for the entire column family. If you want to access the entire column family, use getVer(ByteBuffer, ByteBuffer, ByteBuffer, int, Map) with a column value that lacks a ':'.

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getVerTs

public List<org.apache.hadoop.hbase.thrift.generated.TCell> getVerTs(ByteBuffer tableName,
                                                                     ByteBuffer row,
                                                                     ByteBuffer column,
                                                                     long timestamp,
                                                                     int numVersions,
                                                                     Map<ByteBuffer,ByteBuffer> attributes)
                                                              throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get the specified number of versions for the specified table, row, and column. Only versions less than or equal to the specified timestamp will be returned.

Specified by:

getVerTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

column - column name

timestamp - timestamp

numVersions - number of versions to retrieve

attributes - Get attributes

Returns:

list of cells for specified row/column

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getVerTs

protected List<org.apache.hadoop.hbase.thrift.generated.TCell> getVerTs(ByteBuffer tableName,
                                                                        ByteBuffer row,
                                                                        byte[] family,
                                                                        byte[] qualifier,
                                                                        long timestamp,
                                                                        int numVersions,
                                                                        Map<ByteBuffer,ByteBuffer> attributes)
                                                                 throws org.apache.hadoop.hbase.thrift.generated.IOError

Note: this internal interface is slightly different from public APIs in regard to handling of the qualifier. Here we differ from the public Java API in that null != byte[0]. Rather, we respect qual == null as a request for the entire column family. The caller ( getVerTs(ByteBuffer, ByteBuffer, ByteBuffer, long, int, Map)) interface IS consistent in that the column is parse like normal.

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRow

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRow(ByteBuffer tableName,
                                                                        ByteBuffer row,
                                                                        Map<ByteBuffer,ByteBuffer> attributes)
                                                                 throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get all the data for the specified table and row at the latest timestamp. Returns an empty list if the row does not exist.

Specified by:

getRow in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

attributes - Get attributes

Returns:

TRowResult containing the row and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRowWithColumns

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRowWithColumns(ByteBuffer tableName,
                                                                                   ByteBuffer row,
                                                                                   List<ByteBuffer> columns,
                                                                                   Map<ByteBuffer,ByteBuffer> attributes)
                                                                            throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get the specified columns for the specified table and row at the latest timestamp. Returns an empty list if the row does not exist.

Specified by:

getRowWithColumns in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

columns - List of columns to return, null for all columns

attributes - Get attributes

Returns:

TRowResult containing the row and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRowTs

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRowTs(ByteBuffer tableName,
                                                                          ByteBuffer row,
                                                                          long timestamp,
                                                                          Map<ByteBuffer,ByteBuffer> attributes)
                                                                   throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get all the data for the specified table and row at the specified timestamp. Returns an empty list if the row does not exist.

Specified by:

getRowTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of the table

row - row key

timestamp - timestamp

attributes - Get attributes

Returns:

TRowResult containing the row and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRowWithColumnsTs

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRowWithColumnsTs(ByteBuffer tableName,
                                                                                     ByteBuffer row,
                                                                                     List<ByteBuffer> columns,
                                                                                     long timestamp,
                                                                                     Map<ByteBuffer,ByteBuffer> attributes)
                                                                              throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get the specified columns for the specified table and row at the specified timestamp. Returns an empty list if the row does not exist.

Specified by:

getRowWithColumnsTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

columns - List of columns to return, null for all columns

attributes - Get attributes

Returns:

TRowResult containing the row and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRows

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRows(ByteBuffer tableName,
                                                                         List<ByteBuffer> rows,
                                                                         Map<ByteBuffer,ByteBuffer> attributes)
                                                                  throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get all the data for the specified table and rows at the latest timestamp. Returns an empty list if no rows exist.

Specified by:

getRows in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

rows - row keys

attributes - Get attributes

Returns:

TRowResult containing the rows and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRowsWithColumns

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRowsWithColumns(ByteBuffer tableName,
                                                                                    List<ByteBuffer> rows,
                                                                                    List<ByteBuffer> columns,
                                                                                    Map<ByteBuffer,ByteBuffer> attributes)
                                                                             throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get the specified columns for the specified table and rows at the latest timestamp. Returns an empty list if no rows exist.

Specified by:

getRowsWithColumns in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

rows - row keys

columns - List of columns to return, null for all columns

attributes - Get attributes

Returns:

TRowResult containing the rows and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRowsTs

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRowsTs(ByteBuffer tableName,
                                                                           List<ByteBuffer> rows,
                                                                           long timestamp,
                                                                           Map<ByteBuffer,ByteBuffer> attributes)
                                                                    throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get all the data for the specified table and rows at the specified timestamp. Returns an empty list if no rows exist.

Specified by:

getRowsTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of the table

rows - row keys

timestamp - timestamp

attributes - Get attributes

Returns:

TRowResult containing the rows and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRowsWithColumnsTs

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> getRowsWithColumnsTs(ByteBuffer tableName,
                                                                                      List<ByteBuffer> rows,
                                                                                      List<ByteBuffer> columns,
                                                                                      long timestamp,
                                                                                      Map<ByteBuffer,ByteBuffer> attributes)
                                                                               throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get the specified columns for the specified table and rows at the specified timestamp. Returns an empty list if no rows exist.

Specified by:

getRowsWithColumnsTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

rows - row keys

columns - List of columns to return, null for all columns

attributes - Get attributes

Returns:

TRowResult containing the rows and map of columns to TCells

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

deleteAll

public void deleteAll(ByteBuffer tableName,
                      ByteBuffer row,
                      ByteBuffer column,
                      Map<ByteBuffer,ByteBuffer> attributes)
               throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Delete all cells that match the passed row and column.

Specified by:

deleteAll in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - Row to update

column - name of column whose value is to be deleted

attributes - Delete attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

deleteAllTs

public void deleteAllTs(ByteBuffer tableName,
                        ByteBuffer row,
                        ByteBuffer column,
                        long timestamp,
                        Map<ByteBuffer,ByteBuffer> attributes)
                 throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Delete all cells that match the passed row and column and whose timestamp is equal-to or older than the passed timestamp.

Specified by:

deleteAllTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - Row to update

column - name of column whose value is to be deleted

timestamp - timestamp

attributes - Delete attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

deleteAllRow

public void deleteAllRow(ByteBuffer tableName,
                         ByteBuffer row,
                         Map<ByteBuffer,ByteBuffer> attributes)
                  throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Completely delete the row's cells.

Specified by:

deleteAllRow in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - key of the row to be completely deleted.

attributes - Delete attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

deleteAllRowTs

public void deleteAllRowTs(ByteBuffer tableName,
                           ByteBuffer row,
                           long timestamp,
                           Map<ByteBuffer,ByteBuffer> attributes)
                    throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Completely delete the row's cells marked with a timestamp equal-to or older than the passed timestamp.

Specified by:

deleteAllRowTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - key of the row to be completely deleted.

timestamp - timestamp

attributes - Delete attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

createTable

public void createTable(ByteBuffer in_tableName,
                        List<org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor> columnFamilies)
                 throws org.apache.hadoop.hbase.thrift.generated.IOError,
                        org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                        org.apache.hadoop.hbase.thrift.generated.AlreadyExists

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Create a table with the specified column families. The name field for each ColumnDescriptor must be set and must end in a colon (:). All other fields are optional and will get default values if not explicitly specified.

Specified by:

createTable in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

in_tableName - name of table to create

columnFamilies - list of column family descriptors

Throws:

org.apache.hadoop.hbase.thrift.generated.IllegalArgument - if an input parameter is invalid

org.apache.hadoop.hbase.thrift.generated.AlreadyExists - if the table name already exists

org.apache.hadoop.hbase.thrift.generated.IOError

getTableName

private static TableName getTableName(ByteBuffer buffer)

deleteTable

public void deleteTable(ByteBuffer in_tableName)
                 throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Deletes a table

Specified by:

deleteTable in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

in_tableName - name of table to delete

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError - if table doesn't exist on server or there was some other problem

mutateRow

public void mutateRow(ByteBuffer tableName,
                      ByteBuffer row,
                      List<org.apache.hadoop.hbase.thrift.generated.Mutation> mutations,
                      Map<ByteBuffer,ByteBuffer> attributes)
               throws org.apache.hadoop.hbase.thrift.generated.IOError,
                      org.apache.hadoop.hbase.thrift.generated.IllegalArgument

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Apply a series of mutations (updates/deletes) to a row in a single transaction. If an exception is thrown, then the transaction is aborted. Default current timestamp is used, and all entries will have an identical timestamp.

Specified by:

mutateRow in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

mutations - list of mutation commands

attributes - Mutation attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.hadoop.hbase.thrift.generated.IllegalArgument

mutateRowTs

public void mutateRowTs(ByteBuffer tableName,
                        ByteBuffer row,
                        List<org.apache.hadoop.hbase.thrift.generated.Mutation> mutations,
                        long timestamp,
                        Map<ByteBuffer,ByteBuffer> attributes)
                 throws org.apache.hadoop.hbase.thrift.generated.IOError,
                        org.apache.hadoop.hbase.thrift.generated.IllegalArgument

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Apply a series of mutations (updates/deletes) to a row in a single transaction. If an exception is thrown, then the transaction is aborted. The specified timestamp is used, and all entries will have an identical timestamp.

Specified by:

mutateRowTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

mutations - list of mutation commands

timestamp - timestamp

attributes - Mutation attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.hadoop.hbase.thrift.generated.IllegalArgument

mutateRows

public void mutateRows(ByteBuffer tableName,
                       List<org.apache.hadoop.hbase.thrift.generated.BatchMutation> rowBatches,
                       Map<ByteBuffer,ByteBuffer> attributes)
                throws org.apache.hadoop.hbase.thrift.generated.IOError,
                       org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                       org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Apply a series of batches (each a series of mutations on a single row) in a single transaction. If an exception is thrown, then the transaction is aborted. Default current timestamp is used, and all entries will have an identical timestamp.

Specified by:

mutateRows in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

rowBatches - list of row batches

attributes - Mutation attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.hadoop.hbase.thrift.generated.IllegalArgument

org.apache.thrift.TException

mutateRowsTs

public void mutateRowsTs(ByteBuffer tableName,
                         List<org.apache.hadoop.hbase.thrift.generated.BatchMutation> rowBatches,
                         long timestamp,
                         Map<ByteBuffer,ByteBuffer> attributes)
                  throws org.apache.hadoop.hbase.thrift.generated.IOError,
                         org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                         org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Apply a series of batches (each a series of mutations on a single row) in a single transaction. If an exception is thrown, then the transaction is aborted. The specified timestamp is used, and all entries will have an identical timestamp.

Specified by:

mutateRowsTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

rowBatches - list of row batches

timestamp - timestamp

attributes - Mutation attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.hadoop.hbase.thrift.generated.IllegalArgument

org.apache.thrift.TException

atomicIncrement

public long atomicIncrement(ByteBuffer tableName,
                            ByteBuffer row,
                            ByteBuffer column,
                            long amount)
                     throws org.apache.hadoop.hbase.thrift.generated.IOError,
                            org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                            org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Atomically increment the column value specified. Returns the next value post increment.

Specified by:

atomicIncrement in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row to increment

column - name of column

amount - amount to increment by

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.hadoop.hbase.thrift.generated.IllegalArgument

org.apache.thrift.TException

atomicIncrement

protected long atomicIncrement(ByteBuffer tableName,
                               ByteBuffer row,
                               byte[] family,
                               byte[] qualifier,
                               long amount)
                        throws org.apache.hadoop.hbase.thrift.generated.IOError,
                               org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                               org.apache.thrift.TException

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.hadoop.hbase.thrift.generated.IllegalArgument

org.apache.thrift.TException

scannerClose

public void scannerClose(int id)
                  throws org.apache.hadoop.hbase.thrift.generated.IOError,
                         org.apache.hadoop.hbase.thrift.generated.IllegalArgument

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Closes the server-state associated with an open scanner.

Specified by:

scannerClose in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

id - id of a scanner returned by scannerOpen

Throws:

org.apache.hadoop.hbase.thrift.generated.IllegalArgument - if ScannerID is invalid

org.apache.hadoop.hbase.thrift.generated.IOError

scannerGetList

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> scannerGetList(int id,
                                                                                int nbRows)
                                                                         throws org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                                                                                org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Returns, starting at the scanner's current row value nbRows worth of rows and advances to the next row in the table. When there are no more rows in the table, or a key greater-than-or-equal-to the scanner's specified stopRow is reached, an empty list is returned.

Specified by:

scannerGetList in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

id - id of a scanner returned by scannerOpen

nbRows - number of results to return

Returns:

a TRowResult containing the current row and a map of the columns to TCells.

Throws:

org.apache.hadoop.hbase.thrift.generated.IllegalArgument - if ScannerID is invalid

org.apache.hadoop.hbase.thrift.generated.IOError

scannerGet

public List<org.apache.hadoop.hbase.thrift.generated.TRowResult> scannerGet(int id)
                                                                     throws org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                                                                            org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Returns the scanner's current row value and advances to the next row in the table. When there are no more rows in the table, or a key greater-than-or-equal-to the scanner's specified stopRow is reached, an empty list is returned.

Specified by:

scannerGet in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

id - id of a scanner returned by scannerOpen

Returns:

a TRowResult containing the current row and a map of the columns to TCells.

Throws:

org.apache.hadoop.hbase.thrift.generated.IllegalArgument - if ScannerID is invalid

org.apache.hadoop.hbase.thrift.generated.IOError

scannerOpenWithScan

public int scannerOpenWithScan(ByteBuffer tableName,
                               org.apache.hadoop.hbase.thrift.generated.TScan tScan,
                               Map<ByteBuffer,ByteBuffer> attributes)
                        throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get a scanner on the current table, using the Scan instance for the scan parameters.

Specified by:

scannerOpenWithScan in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

tScan - Scan instance

attributes - Scan attributes

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

scannerOpen

public int scannerOpen(ByteBuffer tableName,
                       ByteBuffer startRow,
                       List<ByteBuffer> columns,
                       Map<ByteBuffer,ByteBuffer> attributes)
                throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get a scanner on the current table starting at the specified row and ending at the last row in the table. Return the specified columns.

Specified by:

scannerOpen in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

startRow - Starting row in table to scan. Send "" (empty string) to start at the first row.

columns - columns to scan. If column name is a column family, all columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

attributes - Scan attributes

Returns:

scanner id to be used with other scanner procedures

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

scannerOpenWithStop

public int scannerOpenWithStop(ByteBuffer tableName,
                               ByteBuffer startRow,
                               ByteBuffer stopRow,
                               List<ByteBuffer> columns,
                               Map<ByteBuffer,ByteBuffer> attributes)
                        throws org.apache.hadoop.hbase.thrift.generated.IOError,
                               org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get a scanner on the current table starting and stopping at the specified rows. ending at the last row in the table. Return the specified columns.

Specified by:

scannerOpenWithStop in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

startRow - Starting row in table to scan. Send "" (empty string) to start at the first row.

stopRow - row to stop scanning on. This row is *not* included in the scanner's results

columns - columns to scan. If column name is a column family, all columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

attributes - Scan attributes

Returns:

scanner id to be used with other scanner procedures

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

scannerOpenWithPrefix

public int scannerOpenWithPrefix(ByteBuffer tableName,
                                 ByteBuffer startAndPrefix,
                                 List<ByteBuffer> columns,
                                 Map<ByteBuffer,ByteBuffer> attributes)
                          throws org.apache.hadoop.hbase.thrift.generated.IOError,
                                 org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Open a scanner for a given prefix. That is all rows will have the specified prefix. No other rows will be returned.

Specified by:

scannerOpenWithPrefix in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

startAndPrefix - the prefix (and thus start row) of the keys you want

columns - the columns you want returned

attributes - Scan attributes

Returns:

scanner id to use with other scanner calls

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

scannerOpenTs

public int scannerOpenTs(ByteBuffer tableName,
                         ByteBuffer startRow,
                         List<ByteBuffer> columns,
                         long timestamp,
                         Map<ByteBuffer,ByteBuffer> attributes)
                  throws org.apache.hadoop.hbase.thrift.generated.IOError,
                         org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get a scanner on the current table starting at the specified row and ending at the last row in the table. Return the specified columns. Only values with the specified timestamp are returned.

Specified by:

scannerOpenTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

startRow - Starting row in table to scan. Send "" (empty string) to start at the first row.

columns - columns to scan. If column name is a column family, all columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

timestamp - timestamp

attributes - Scan attributes

Returns:

scanner id to be used with other scanner procedures

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

scannerOpenWithStopTs

public int scannerOpenWithStopTs(ByteBuffer tableName,
                                 ByteBuffer startRow,
                                 ByteBuffer stopRow,
                                 List<ByteBuffer> columns,
                                 long timestamp,
                                 Map<ByteBuffer,ByteBuffer> attributes)
                          throws org.apache.hadoop.hbase.thrift.generated.IOError,
                                 org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get a scanner on the current table starting and stopping at the specified rows. ending at the last row in the table. Return the specified columns. Only values with the specified timestamp are returned.

Specified by:

scannerOpenWithStopTs in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

startRow - Starting row in table to scan. Send "" (empty string) to start at the first row.

stopRow - row to stop scanning on. This row is *not* included in the scanner's results

columns - columns to scan. If column name is a column family, all columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

timestamp - timestamp

attributes - Scan attributes

Returns:

scanner id to be used with other scanner procedures

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

getColumnDescriptors

public Map<ByteBuffer,org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName)
                                                                                               throws org.apache.hadoop.hbase.thrift.generated.IOError,
                                                                                                      org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

List all the column families assoicated with a table.

Specified by:

getColumnDescriptors in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - table name

Returns:

list of column family descriptors

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

closeTable

private void closeTable(Table table)
                 throws org.apache.hadoop.hbase.thrift.generated.IOError

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getRegionInfo

public org.apache.hadoop.hbase.thrift.generated.TRegionInfo getRegionInfo(ByteBuffer searchRow)
                                                                   throws org.apache.hadoop.hbase.thrift.generated.IOError

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Get the regininfo for the specified row. It scans the metatable to find region's start and end keys.

Specified by:

getRegionInfo in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

searchRow - row key

Returns:

value for specified row/column

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

getReverseScanResult

private Result getReverseScanResult(byte[] tableName,
                                    byte[] row,
                                    byte[] family)
                             throws IOException

Throws:

IOException

increment

public void increment(org.apache.hadoop.hbase.thrift.generated.TIncrement tincrement)
               throws org.apache.hadoop.hbase.thrift.generated.IOError,
                      org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Increment a cell by the ammount. Increments can be applied async if hbase.regionserver.thrift.coalesceIncrement is set to true. False is the default. Turn to true if you need the extra performance and can accept some data loss if a thrift server dies with increments still in the queue.

Specified by:

increment in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tincrement - The single increment to apply

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

incrementRows

public void incrementRows(List<org.apache.hadoop.hbase.thrift.generated.TIncrement> tincrements)
                   throws org.apache.hadoop.hbase.thrift.generated.IOError,
                          org.apache.thrift.TException

Specified by:

incrementRows in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

append

public List<org.apache.hadoop.hbase.thrift.generated.TCell> append(org.apache.hadoop.hbase.thrift.generated.TAppend tappend)
                                                            throws org.apache.hadoop.hbase.thrift.generated.IOError,
                                                                   org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Appends values to one or more columns within a single row.

Specified by:

append in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tappend - The single append operation to apply

Returns:

values of columns after the append operation.

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.thrift.TException

checkAndPut

public boolean checkAndPut(ByteBuffer tableName,
                           ByteBuffer row,
                           ByteBuffer column,
                           ByteBuffer value,
                           org.apache.hadoop.hbase.thrift.generated.Mutation mput,
                           Map<ByteBuffer,ByteBuffer> attributes)
                    throws org.apache.hadoop.hbase.thrift.generated.IOError,
                           org.apache.hadoop.hbase.thrift.generated.IllegalArgument,
                           org.apache.thrift.TException

Description copied from interface: org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the corresponding mutation operation for put.

Specified by:

checkAndPut in interface org.apache.hadoop.hbase.thrift.generated.Hbase.Iface

Parameters:

tableName - name of table

row - row key

column - column name

value - the expected value for the column parameter, if not provided the check is for the non-existence of the column in question

mput - mutation for the put

attributes - Mutation attributes

Returns:

true if the new put was executed, false otherwise

Throws:

org.apache.hadoop.hbase.thrift.generated.IOError

org.apache.hadoop.hbase.thrift.generated.IllegalArgument

org.apache.thrift.TException

getIOError

private static org.apache.hadoop.hbase.thrift.generated.IOError getIOError(Throwable throwable)

addAttributes

private static void addAttributes(OperationWithAttributes op,
                                  Map<ByteBuffer,ByteBuffer> attributes)

Adds all the attributes into the Operation object