org.apache.hadoop.hbase.thrift.generated

Class Hbase.Client

java.lang.Object

org.apache.thrift.TServiceClient

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

All Implemented Interfaces:

Hbase.Iface

Enclosing class:

Hbase

public static class Hbase.Client
extends org.apache.thrift.TServiceClient
implements Hbase.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Hbase.Client.Factory

Constructor Summary

Constructors

Constructor and Description
Client(org.apache.thrift.protocol.TProtocol prot)
Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)

Method Summary

Modifier and Type	Method and Description
List<TCell>	append(TAppend append) Appends values to one or more columns within a single row.
long	atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) Atomically increment the column value specified.
boolean	checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes) Atomically checks if a row/family/qualifier value matches the expected value.
void	compact(ByteBuffer tableNameOrRegionName)
void	createTable(ByteBuffer tableName, List<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 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)
List<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.
Map<ByteBuffer,ColumnDescriptor>	getColumnDescriptors(ByteBuffer tableName) List all the column families assoicated with a table.
TRegionInfo	getRegionInfo(ByteBuffer row) Get the regininfo for the specified row.
List<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<TCell>	getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family) Get the row just before the specified one.
List<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<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<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<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<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<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<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.
List<ByteBuffer>	getTableNames() List all the userspace tables.
List<TRegionInfo>	getTableRegions(ByteBuffer tableName) List the regions associated with a table.
List<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.
List<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(TIncrement increment) Increment a cell by the ammount.
void	incrementRows(List<TIncrement> increments)
boolean	isTableEnabled(ByteBuffer tableName)
void	majorCompact(ByteBuffer tableNameOrRegionName)
void	mutateRow(ByteBuffer tableName, ByteBuffer row, List<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<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<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<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) Apply a series of mutations (updates/deletes) to a row in a single transaction.
List<TCell>	recv_append()
long	recv_atomicIncrement()
boolean	recv_checkAndPut()
void	recv_compact()
void	recv_createTable()
void	recv_deleteAll()
void	recv_deleteAllRow()
void	recv_deleteAllRowTs()
void	recv_deleteAllTs()
void	recv_deleteTable()
void	recv_disableTable()
void	recv_enableTable()
List<TCell>	recv_get()
Map<ByteBuffer,ColumnDescriptor>	recv_getColumnDescriptors()
TRegionInfo	recv_getRegionInfo()
List<TRowResult>	recv_getRow()
List<TCell>	recv_getRowOrBefore()
List<TRowResult>	recv_getRows()
List<TRowResult>	recv_getRowsTs()
List<TRowResult>	recv_getRowsWithColumns()
List<TRowResult>	recv_getRowsWithColumnsTs()
List<TRowResult>	recv_getRowTs()
List<TRowResult>	recv_getRowWithColumns()
List<TRowResult>	recv_getRowWithColumnsTs()
List<ByteBuffer>	recv_getTableNames()
List<TRegionInfo>	recv_getTableRegions()
List<TCell>	recv_getVer()
List<TCell>	recv_getVerTs()
void	recv_increment()
void	recv_incrementRows()
boolean	recv_isTableEnabled()
void	recv_majorCompact()
void	recv_mutateRow()
void	recv_mutateRows()
void	recv_mutateRowsTs()
void	recv_mutateRowTs()
void	recv_scannerClose()
List<TRowResult>	recv_scannerGet()
List<TRowResult>	recv_scannerGetList()
int	recv_scannerOpen()
int	recv_scannerOpenTs()
int	recv_scannerOpenWithPrefix()
int	recv_scannerOpenWithScan()
int	recv_scannerOpenWithStop()
int	recv_scannerOpenWithStopTs()
void	scannerClose(int id) Closes the server-state associated with an open scanner.
List<TRowResult>	scannerGet(int id) Returns the scanner's current row value and advances to the next row in the table.
List<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, TScan scan, 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.
void	send_append(TAppend append)
void	send_atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value)
void	send_checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes)
void	send_compact(ByteBuffer tableNameOrRegionName)
void	send_createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies)
void	send_deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes)
void	send_deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes)
void	send_deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_deleteTable(ByteBuffer tableName)
void	send_disableTable(ByteBuffer tableName)
void	send_enableTable(ByteBuffer tableName)
void	send_get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getColumnDescriptors(ByteBuffer tableName)
void	send_getRegionInfo(ByteBuffer row)
void	send_getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family)
void	send_getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getTableNames()
void	send_getTableRegions(ByteBuffer tableName)
void	send_getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes)
void	send_getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes)
void	send_increment(TIncrement increment)
void	send_incrementRows(List<TIncrement> increments)
void	send_isTableEnabled(ByteBuffer tableName)
void	send_majorCompact(ByteBuffer tableNameOrRegionName)
void	send_mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes)
void	send_mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes)
void	send_mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_scannerClose(int id)
void	send_scannerGet(int id)
void	send_scannerGetList(int id, int nbRows)
void	send_scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes)
void	send_scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)
void	send_scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes)
void	send_scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes)
void	send_scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes)
void	send_scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes)

Methods inherited from class java.lang.Object

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

Constructor Detail

Client

public Client(org.apache.thrift.protocol.TProtocol prot)

Client

public Client(org.apache.thrift.protocol.TProtocol iprot,
              org.apache.thrift.protocol.TProtocol oprot)

Method Detail

enableTable

public void enableTable(ByteBuffer tableName)
                 throws IOError,
                        org.apache.thrift.TException

Description copied from interface: Hbase.Iface

Brings a table on-line (enables it)

Specified by:

enableTable in interface Hbase.Iface

Parameters:

tableName - name of the table

Throws:

IOError

org.apache.thrift.TException

send_enableTable

public void send_enableTable(ByteBuffer tableName)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_enableTable

public void recv_enableTable()
                      throws IOError,
                             org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

disableTable

public void disableTable(ByteBuffer tableName)
                  throws IOError,
                         org.apache.thrift.TException

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of the table

Throws:

IOError

org.apache.thrift.TException

send_disableTable

public void send_disableTable(ByteBuffer tableName)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_disableTable

public void recv_disableTable()
                       throws IOError,
                              org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

isTableEnabled

public boolean isTableEnabled(ByteBuffer tableName)
                       throws IOError,
                              org.apache.thrift.TException

Specified by:

isTableEnabled in interface Hbase.Iface

Parameters:

tableName - name of the table to check

Returns:

true if table is on-line

Throws:

IOError

org.apache.thrift.TException

send_isTableEnabled

public void send_isTableEnabled(ByteBuffer tableName)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_isTableEnabled

public boolean recv_isTableEnabled()
                            throws IOError,
                                   org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

compact

public void compact(ByteBuffer tableNameOrRegionName)
             throws IOError,
                    org.apache.thrift.TException

Specified by:

compact in interface Hbase.Iface

Throws:

IOError

org.apache.thrift.TException

send_compact

public void send_compact(ByteBuffer tableNameOrRegionName)
                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_compact

public void recv_compact()
                  throws IOError,
                         org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

majorCompact

public void majorCompact(ByteBuffer tableNameOrRegionName)
                  throws IOError,
                         org.apache.thrift.TException

Specified by:

majorCompact in interface Hbase.Iface

Throws:

IOError

org.apache.thrift.TException

send_majorCompact

public void send_majorCompact(ByteBuffer tableNameOrRegionName)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_majorCompact

public void recv_majorCompact()
                       throws IOError,
                              org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getTableNames

public List<ByteBuffer> getTableNames()
                               throws IOError,
                                      org.apache.thrift.TException

Description copied from interface: Hbase.Iface

List all the userspace tables.

Specified by:

getTableNames in interface Hbase.Iface

Returns:

returns a list of names

Throws:

IOError

org.apache.thrift.TException

send_getTableNames

public void send_getTableNames()
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getTableNames

public List<ByteBuffer> recv_getTableNames()
                                    throws IOError,
                                           org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getColumnDescriptors

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

Description copied from interface: Hbase.Iface

List all the column families assoicated with a table.

Specified by:

getColumnDescriptors in interface Hbase.Iface

Parameters:

tableName - table name

Returns:

list of column family descriptors

Throws:

IOError

org.apache.thrift.TException

send_getColumnDescriptors

public void send_getColumnDescriptors(ByteBuffer tableName)
                               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getColumnDescriptors

public Map<ByteBuffer,ColumnDescriptor> recv_getColumnDescriptors()
                                                           throws IOError,
                                                                  org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getTableRegions

public List<TRegionInfo> getTableRegions(ByteBuffer tableName)
                                  throws IOError,
                                         org.apache.thrift.TException

Description copied from interface: Hbase.Iface

List the regions associated with a table.

Specified by:

getTableRegions in interface Hbase.Iface

Parameters:

tableName - table name

Returns:

list of region descriptors

Throws:

IOError

org.apache.thrift.TException

send_getTableRegions

public void send_getTableRegions(ByteBuffer tableName)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getTableRegions

public List<TRegionInfo> recv_getTableRegions()
                                       throws IOError,
                                              org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

createTable

public void createTable(ByteBuffer tableName,
                        List<ColumnDescriptor> columnFamilies)
                 throws IOError,
                        IllegalArgument,
                        AlreadyExists,
                        org.apache.thrift.TException

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of table to create

columnFamilies - list of column family descriptors

Throws:

IllegalArgument - if an input parameter is invalid

AlreadyExists - if the table name already exists

IOError

org.apache.thrift.TException

send_createTable

public void send_createTable(ByteBuffer tableName,
                             List<ColumnDescriptor> columnFamilies)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_createTable

public void recv_createTable()
                      throws IOError,
                             IllegalArgument,
                             AlreadyExists,
                             org.apache.thrift.TException

Throws:

IOError

IllegalArgument

AlreadyExists

org.apache.thrift.TException

deleteTable

public void deleteTable(ByteBuffer tableName)
                 throws IOError,
                        org.apache.thrift.TException

Description copied from interface: Hbase.Iface

Deletes a table

Specified by:

deleteTable in interface Hbase.Iface

Parameters:

tableName - name of table to delete

Throws:

IOError - if table doesn't exist on server or there was some other problem

org.apache.thrift.TException

send_deleteTable

public void send_deleteTable(ByteBuffer tableName)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_deleteTable

public void recv_deleteTable()
                      throws IOError,
                             org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

get

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

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of table

row - row key

column - column name

attributes - Get attributes

Returns:

value for specified row/column

Throws:

IOError

org.apache.thrift.TException

send_get

public void send_get(ByteBuffer tableName,
                     ByteBuffer row,
                     ByteBuffer column,
                     Map<ByteBuffer,ByteBuffer> attributes)
              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_get

public List<TCell> recv_get()
                     throws IOError,
                            org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getVer

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

Description copied from interface: Hbase.Iface

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

Specified by:

getVer in interface 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:

IOError

org.apache.thrift.TException

send_getVer

public void send_getVer(ByteBuffer tableName,
                        ByteBuffer row,
                        ByteBuffer column,
                        int numVersions,
                        Map<ByteBuffer,ByteBuffer> attributes)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getVer

public List<TCell> recv_getVer()
                        throws IOError,
                               org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getVerTs

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getVerTs

public void send_getVerTs(ByteBuffer tableName,
                          ByteBuffer row,
                          ByteBuffer column,
                          long timestamp,
                          int numVersions,
                          Map<ByteBuffer,ByteBuffer> attributes)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getVerTs

public List<TCell> recv_getVerTs()
                          throws IOError,
                                 org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRow

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRow

public void send_getRow(ByteBuffer tableName,
                        ByteBuffer row,
                        Map<ByteBuffer,ByteBuffer> attributes)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRow

public List<TRowResult> recv_getRow()
                             throws IOError,
                                    org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRowWithColumns

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRowWithColumns

public void send_getRowWithColumns(ByteBuffer tableName,
                                   ByteBuffer row,
                                   List<ByteBuffer> columns,
                                   Map<ByteBuffer,ByteBuffer> attributes)
                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRowWithColumns

public List<TRowResult> recv_getRowWithColumns()
                                        throws IOError,
                                               org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRowTs

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRowTs

public void send_getRowTs(ByteBuffer tableName,
                          ByteBuffer row,
                          long timestamp,
                          Map<ByteBuffer,ByteBuffer> attributes)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRowTs

public List<TRowResult> recv_getRowTs()
                               throws IOError,
                                      org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRowWithColumnsTs

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRowWithColumnsTs

public void send_getRowWithColumnsTs(ByteBuffer tableName,
                                     ByteBuffer row,
                                     List<ByteBuffer> columns,
                                     long timestamp,
                                     Map<ByteBuffer,ByteBuffer> attributes)
                              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRowWithColumnsTs

public List<TRowResult> recv_getRowWithColumnsTs()
                                          throws IOError,
                                                 org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRows

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRows

public void send_getRows(ByteBuffer tableName,
                         List<ByteBuffer> rows,
                         Map<ByteBuffer,ByteBuffer> attributes)
                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRows

public List<TRowResult> recv_getRows()
                              throws IOError,
                                     org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRowsWithColumns

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRowsWithColumns

public void send_getRowsWithColumns(ByteBuffer tableName,
                                    List<ByteBuffer> rows,
                                    List<ByteBuffer> columns,
                                    Map<ByteBuffer,ByteBuffer> attributes)
                             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRowsWithColumns

public List<TRowResult> recv_getRowsWithColumns()
                                         throws IOError,
                                                org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRowsTs

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRowsTs

public void send_getRowsTs(ByteBuffer tableName,
                           List<ByteBuffer> rows,
                           long timestamp,
                           Map<ByteBuffer,ByteBuffer> attributes)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRowsTs

public List<TRowResult> recv_getRowsTs()
                                throws IOError,
                                       org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRowsWithColumnsTs

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_getRowsWithColumnsTs

public void send_getRowsWithColumnsTs(ByteBuffer tableName,
                                      List<ByteBuffer> rows,
                                      List<ByteBuffer> columns,
                                      long timestamp,
                                      Map<ByteBuffer,ByteBuffer> attributes)
                               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRowsWithColumnsTs

public List<TRowResult> recv_getRowsWithColumnsTs()
                                           throws IOError,
                                                  org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

mutateRow

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

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of table

row - row key

mutations - list of mutation commands

attributes - Mutation attributes

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

send_mutateRow

public void send_mutateRow(ByteBuffer tableName,
                           ByteBuffer row,
                           List<Mutation> mutations,
                           Map<ByteBuffer,ByteBuffer> attributes)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_mutateRow

public void recv_mutateRow()
                    throws IOError,
                           IllegalArgument,
                           org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

mutateRowTs

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

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of table

row - row key

mutations - list of mutation commands

timestamp - timestamp

attributes - Mutation attributes

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

send_mutateRowTs

public void send_mutateRowTs(ByteBuffer tableName,
                             ByteBuffer row,
                             List<Mutation> mutations,
                             long timestamp,
                             Map<ByteBuffer,ByteBuffer> attributes)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_mutateRowTs

public void recv_mutateRowTs()
                      throws IOError,
                             IllegalArgument,
                             org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

mutateRows

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

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of table

rowBatches - list of row batches

attributes - Mutation attributes

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

send_mutateRows

public void send_mutateRows(ByteBuffer tableName,
                            List<BatchMutation> rowBatches,
                            Map<ByteBuffer,ByteBuffer> attributes)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_mutateRows

public void recv_mutateRows()
                     throws IOError,
                            IllegalArgument,
                            org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

mutateRowsTs

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

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of table

rowBatches - list of row batches

timestamp - timestamp

attributes - Mutation attributes

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

send_mutateRowsTs

public void send_mutateRowsTs(ByteBuffer tableName,
                              List<BatchMutation> rowBatches,
                              long timestamp,
                              Map<ByteBuffer,ByteBuffer> attributes)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_mutateRowsTs

public void recv_mutateRowsTs()
                       throws IOError,
                              IllegalArgument,
                              org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

atomicIncrement

public long atomicIncrement(ByteBuffer tableName,
                            ByteBuffer row,
                            ByteBuffer column,
                            long value)
                     throws IOError,
                            IllegalArgument,
                            org.apache.thrift.TException

Description copied from interface: Hbase.Iface

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

Specified by:

atomicIncrement in interface Hbase.Iface

Parameters:

tableName - name of table

row - row to increment

column - name of column

value - amount to increment by

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

send_atomicIncrement

public void send_atomicIncrement(ByteBuffer tableName,
                                 ByteBuffer row,
                                 ByteBuffer column,
                                 long value)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_atomicIncrement

public long recv_atomicIncrement()
                          throws IOError,
                                 IllegalArgument,
                                 org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

deleteAll

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

Description copied from interface: Hbase.Iface

Delete all cells that match the passed row and column.

Specified by:

deleteAll in interface 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:

IOError

org.apache.thrift.TException

send_deleteAll

public void send_deleteAll(ByteBuffer tableName,
                           ByteBuffer row,
                           ByteBuffer column,
                           Map<ByteBuffer,ByteBuffer> attributes)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_deleteAll

public void recv_deleteAll()
                    throws IOError,
                           org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

deleteAllTs

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_deleteAllTs

public void send_deleteAllTs(ByteBuffer tableName,
                             ByteBuffer row,
                             ByteBuffer column,
                             long timestamp,
                             Map<ByteBuffer,ByteBuffer> attributes)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_deleteAllTs

public void recv_deleteAllTs()
                      throws IOError,
                             org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

deleteAllRow

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

Description copied from interface: Hbase.Iface

Completely delete the row's cells.

Specified by:

deleteAllRow in interface Hbase.Iface

Parameters:

tableName - name of table

row - key of the row to be completely deleted.

attributes - Delete attributes

Throws:

IOError

org.apache.thrift.TException

send_deleteAllRow

public void send_deleteAllRow(ByteBuffer tableName,
                              ByteBuffer row,
                              Map<ByteBuffer,ByteBuffer> attributes)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_deleteAllRow

public void recv_deleteAllRow()
                       throws IOError,
                              org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

increment

public void increment(TIncrement increment)
               throws IOError,
                      org.apache.thrift.TException

Description copied from interface: 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 Hbase.Iface

Parameters:

increment - The single increment to apply

Throws:

IOError

org.apache.thrift.TException

send_increment

public void send_increment(TIncrement increment)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_increment

public void recv_increment()
                    throws IOError,
                           org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

incrementRows

public void incrementRows(List<TIncrement> increments)
                   throws IOError,
                          org.apache.thrift.TException

Specified by:

incrementRows in interface Hbase.Iface

Throws:

IOError

org.apache.thrift.TException

send_incrementRows

public void send_incrementRows(List<TIncrement> increments)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_incrementRows

public void recv_incrementRows()
                        throws IOError,
                               org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

deleteAllRowTs

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

Description copied from interface: 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 Hbase.Iface

Parameters:

tableName - name of table

row - key of the row to be completely deleted.

timestamp - timestamp

attributes - Delete attributes

Throws:

IOError

org.apache.thrift.TException

send_deleteAllRowTs

public void send_deleteAllRowTs(ByteBuffer tableName,
                                ByteBuffer row,
                                long timestamp,
                                Map<ByteBuffer,ByteBuffer> attributes)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_deleteAllRowTs

public void recv_deleteAllRowTs()
                         throws IOError,
                                org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

scannerOpenWithScan

public int scannerOpenWithScan(ByteBuffer tableName,
                               TScan scan,
                               Map<ByteBuffer,ByteBuffer> attributes)
                        throws IOError,
                               org.apache.thrift.TException

Description copied from interface: Hbase.Iface

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

Specified by:

scannerOpenWithScan in interface Hbase.Iface

Parameters:

tableName - name of table

scan - Scan instance

attributes - Scan attributes

Throws:

IOError

org.apache.thrift.TException

send_scannerOpenWithScan

public void send_scannerOpenWithScan(ByteBuffer tableName,
                                     TScan scan,
                                     Map<ByteBuffer,ByteBuffer> attributes)
                              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerOpenWithScan

public int recv_scannerOpenWithScan()
                             throws IOError,
                                    org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

scannerOpen

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_scannerOpen

public void send_scannerOpen(ByteBuffer tableName,
                             ByteBuffer startRow,
                             List<ByteBuffer> columns,
                             Map<ByteBuffer,ByteBuffer> attributes)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerOpen

public int recv_scannerOpen()
                     throws IOError,
                            org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

scannerOpenWithStop

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_scannerOpenWithStop

public void send_scannerOpenWithStop(ByteBuffer tableName,
                                     ByteBuffer startRow,
                                     ByteBuffer stopRow,
                                     List<ByteBuffer> columns,
                                     Map<ByteBuffer,ByteBuffer> attributes)
                              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerOpenWithStop

public int recv_scannerOpenWithStop()
                             throws IOError,
                                    org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

scannerOpenWithPrefix

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_scannerOpenWithPrefix

public void send_scannerOpenWithPrefix(ByteBuffer tableName,
                                       ByteBuffer startAndPrefix,
                                       List<ByteBuffer> columns,
                                       Map<ByteBuffer,ByteBuffer> attributes)
                                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerOpenWithPrefix

public int recv_scannerOpenWithPrefix()
                               throws IOError,
                                      org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

scannerOpenTs

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

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_scannerOpenTs

public void send_scannerOpenTs(ByteBuffer tableName,
                               ByteBuffer startRow,
                               List<ByteBuffer> columns,
                               long timestamp,
                               Map<ByteBuffer,ByteBuffer> attributes)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerOpenTs

public int recv_scannerOpenTs()
                       throws IOError,
                              org.apache.thrift.TException

Throws:

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 IOError,
                                 org.apache.thrift.TException

Description copied from interface: 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 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:

IOError

org.apache.thrift.TException

send_scannerOpenWithStopTs

public void send_scannerOpenWithStopTs(ByteBuffer tableName,
                                       ByteBuffer startRow,
                                       ByteBuffer stopRow,
                                       List<ByteBuffer> columns,
                                       long timestamp,
                                       Map<ByteBuffer,ByteBuffer> attributes)
                                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerOpenWithStopTs

public int recv_scannerOpenWithStopTs()
                               throws IOError,
                                      org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

scannerGet

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

Description copied from interface: 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 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:

IllegalArgument - if ScannerID is invalid

IOError

org.apache.thrift.TException

send_scannerGet

public void send_scannerGet(int id)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerGet

public List<TRowResult> recv_scannerGet()
                                 throws IOError,
                                        IllegalArgument,
                                        org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

scannerGetList

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

Description copied from interface: 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 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:

IllegalArgument - if ScannerID is invalid

IOError

org.apache.thrift.TException

send_scannerGetList

public void send_scannerGetList(int id,
                                int nbRows)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerGetList

public List<TRowResult> recv_scannerGetList()
                                     throws IOError,
                                            IllegalArgument,
                                            org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

scannerClose

public void scannerClose(int id)
                  throws IOError,
                         IllegalArgument,
                         org.apache.thrift.TException

Description copied from interface: Hbase.Iface

Closes the server-state associated with an open scanner.

Specified by:

scannerClose in interface Hbase.Iface

Parameters:

id - id of a scanner returned by scannerOpen

Throws:

IllegalArgument - if ScannerID is invalid

IOError

org.apache.thrift.TException

send_scannerClose

public void send_scannerClose(int id)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_scannerClose

public void recv_scannerClose()
                       throws IOError,
                              IllegalArgument,
                              org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException

getRowOrBefore

public List<TCell> getRowOrBefore(ByteBuffer tableName,
                                  ByteBuffer row,
                                  ByteBuffer family)
                           throws IOError,
                                  org.apache.thrift.TException

Description copied from interface: Hbase.Iface

Get the row just before the specified one.

Specified by:

getRowOrBefore in interface Hbase.Iface

Parameters:

tableName - name of table

row - row key

family - column name

Returns:

value for specified row/column

Throws:

IOError

org.apache.thrift.TException

send_getRowOrBefore

public void send_getRowOrBefore(ByteBuffer tableName,
                                ByteBuffer row,
                                ByteBuffer family)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRowOrBefore

public List<TCell> recv_getRowOrBefore()
                                throws IOError,
                                       org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

getRegionInfo

public TRegionInfo getRegionInfo(ByteBuffer row)
                          throws IOError,
                                 org.apache.thrift.TException

Description copied from interface: 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 Hbase.Iface

Parameters:

row - row key

Returns:

value for specified row/column

Throws:

IOError

org.apache.thrift.TException

send_getRegionInfo

public void send_getRegionInfo(ByteBuffer row)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getRegionInfo

public TRegionInfo recv_getRegionInfo()
                               throws IOError,
                                      org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

append

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

Description copied from interface: Hbase.Iface

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

Specified by:

append in interface Hbase.Iface

Parameters:

append - The single append operation to apply

Returns:

values of columns after the append operation.

Throws:

IOError

org.apache.thrift.TException

send_append

public void send_append(TAppend append)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_append

public List<TCell> recv_append()
                        throws IOError,
                               org.apache.thrift.TException

Throws:

IOError

org.apache.thrift.TException

checkAndPut

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

Description copied from interface: 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 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:

IOError

IllegalArgument

org.apache.thrift.TException

send_checkAndPut

public void send_checkAndPut(ByteBuffer tableName,
                             ByteBuffer row,
                             ByteBuffer column,
                             ByteBuffer value,
                             Mutation mput,
                             Map<ByteBuffer,ByteBuffer> attributes)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_checkAndPut

public boolean recv_checkAndPut()
                         throws IOError,
                                IllegalArgument,
                                org.apache.thrift.TException

Throws:

IOError

IllegalArgument

org.apache.thrift.TException