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

java.lang.Object
  org.apache.hadoop.hbase.thrift.generated.Hbase.Client

All Implemented Interfaces:

Hbase.Iface

Enclosing class:

Hbase

public static class Hbase.Client
extends Object
implements Hbase.Iface

Field Summary

protected com.facebook.thrift.protocol.TProtocol	iprot_
protected com.facebook.thrift.protocol.TProtocol	oprot_
protected int	seqid_

Constructor Summary

Hbase.Client(com.facebook.thrift.protocol.TProtocol prot)

Hbase.Client(com.facebook.thrift.protocol.TProtocol iprot, com.facebook.thrift.protocol.TProtocol oprot)

Method Summary

void	createTable(byte[] tableName, ArrayList<ColumnDescriptor> columnFamilies) Create a table with the specified column families.
void	deleteAll(byte[] tableName, byte[] row, byte[] column) Delete all cells that match the passed row and column.
void	deleteAllRow(byte[] tableName, byte[] row) Completely delete the row's cells.
void	deleteAllRowTs(byte[] tableName, byte[] row, long timestamp) Completely delete the row's cells marked with a timestamp equal-to or older than the passed timestamp.
void	deleteAllTs(byte[] tableName, byte[] row, byte[] column, long timestamp) Delete all cells that match the passed row and column and whose timestamp is equal-to or older than the passed timestamp.
void	deleteTable(byte[] tableName) Deletes a table
byte[]	get(byte[] tableName, byte[] row, byte[] column) Get a single value for the specified table, row, and column at the latest timestamp.
AbstractMap<byte[],ColumnDescriptor>	getColumnDescriptors(byte[] tableName) List all the column families assoicated with a table.
AbstractMap<byte[],byte[]>	getRow(byte[] tableName, byte[] row) Get all the data for the specified table and row at the latest timestamp.
AbstractMap<byte[],byte[]>	getRowTs(byte[] tableName, byte[] row, long timestamp) Get all the data for the specified table and row at the specified timestamp.
ArrayList<byte[]>	getTableNames() List all the userspace tables.
ArrayList<RegionDescriptor>	getTableRegions(byte[] tableName) List the regions associated with a table.
ArrayList<byte[]>	getVer(byte[] tableName, byte[] row, byte[] column, int numVersions) Get the specified number of versions for the specified table, row, and column.
ArrayList<byte[]>	getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions) Get the specified number of versions for the specified table, row, and column.
void	mutateRow(byte[] tableName, byte[] row, ArrayList<Mutation> mutations) Apply a series of mutations (updates/deletes) to a row in a single transaction.
void	mutateRowTs(byte[] tableName, byte[] row, ArrayList<Mutation> mutations, long timestamp) Apply a series of mutations (updates/deletes) to a row in a single transaction.
void	put(byte[] tableName, byte[] row, byte[] column, byte[] value) Put a single value at the specified table, row, and column.
void	recv_createTable()
void	recv_deleteAll()
void	recv_deleteAllRow()
void	recv_deleteAllRowTs()
void	recv_deleteAllTs()
void	recv_deleteTable()
byte[]	recv_get()
AbstractMap<byte[],ColumnDescriptor>	recv_getColumnDescriptors()
AbstractMap<byte[],byte[]>	recv_getRow()
AbstractMap<byte[],byte[]>	recv_getRowTs()
ArrayList<byte[]>	recv_getTableNames()
ArrayList<RegionDescriptor>	recv_getTableRegions()
ArrayList<byte[]>	recv_getVer()
ArrayList<byte[]>	recv_getVerTs()
void	recv_mutateRow()
void	recv_mutateRowTs()
void	recv_put()
void	recv_scannerClose()
ScanEntry	recv_scannerGet()
int	recv_scannerOpen()
int	recv_scannerOpenTs()
int	recv_scannerOpenWithStop()
int	recv_scannerOpenWithStopTs()
void	scannerClose(int id) Closes the server-state associated with an open scanner.
ScanEntry	scannerGet(int id) Returns the scanner's current row value and advances to the next row in the table.
int	scannerOpen(byte[] tableName, byte[] startRow, ArrayList<byte[]> columns) Get a scanner on the current table starting at the specified row and ending at the last row in the table.
int	scannerOpenTs(byte[] tableName, byte[] startRow, ArrayList<byte[]> columns, long timestamp) Get a scanner on the current table starting at the specified row and ending at the last row in the table.
int	scannerOpenWithStop(byte[] tableName, byte[] startRow, byte[] stopRow, ArrayList<byte[]> columns) Get a scanner on the current table starting and stopping at the specified rows.
int	scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, ArrayList<byte[]> columns, long timestamp) Get a scanner on the current table starting and stopping at the specified rows.
void	send_createTable(byte[] tableName, ArrayList<ColumnDescriptor> columnFamilies)
void	send_deleteAll(byte[] tableName, byte[] row, byte[] column)
void	send_deleteAllRow(byte[] tableName, byte[] row)
void	send_deleteAllRowTs(byte[] tableName, byte[] row, long timestamp)
void	send_deleteAllTs(byte[] tableName, byte[] row, byte[] column, long timestamp)
void	send_deleteTable(byte[] tableName)
void	send_get(byte[] tableName, byte[] row, byte[] column)
void	send_getColumnDescriptors(byte[] tableName)
void	send_getRow(byte[] tableName, byte[] row)
void	send_getRowTs(byte[] tableName, byte[] row, long timestamp)
void	send_getTableNames()
void	send_getTableRegions(byte[] tableName)
void	send_getVer(byte[] tableName, byte[] row, byte[] column, int numVersions)
void	send_getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions)
void	send_mutateRow(byte[] tableName, byte[] row, ArrayList<Mutation> mutations)
void	send_mutateRowTs(byte[] tableName, byte[] row, ArrayList<Mutation> mutations, long timestamp)
void	send_put(byte[] tableName, byte[] row, byte[] column, byte[] value)
void	send_scannerClose(int id)
void	send_scannerGet(int id)
void	send_scannerOpen(byte[] tableName, byte[] startRow, ArrayList<byte[]> columns)
void	send_scannerOpenTs(byte[] tableName, byte[] startRow, ArrayList<byte[]> columns, long timestamp)
void	send_scannerOpenWithStop(byte[] tableName, byte[] startRow, byte[] stopRow, ArrayList<byte[]> columns)
void	send_scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, ArrayList<byte[]> columns, long timestamp)

Methods inherited from class java.lang.Object

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

Field Detail

iprot_

protected com.facebook.thrift.protocol.TProtocol iprot_

oprot_

protected com.facebook.thrift.protocol.TProtocol oprot_

seqid_

protected int seqid_

Constructor Detail

Hbase.Client

public Hbase.Client(com.facebook.thrift.protocol.TProtocol prot)

Hbase.Client

public Hbase.Client(com.facebook.thrift.protocol.TProtocol iprot,
                    com.facebook.thrift.protocol.TProtocol oprot)

Method Detail

getTableNames

public ArrayList<byte[]> getTableNames()
                                throws IOError,
                                       com.facebook.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

com.facebook.thrift.TException

send_getTableNames

public void send_getTableNames()
                        throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_getTableNames

public ArrayList<byte[]> recv_getTableNames()
                                     throws IOError,
                                            com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

getColumnDescriptors

public AbstractMap<byte[],ColumnDescriptor> getColumnDescriptors(byte[] tableName)
                                                          throws IOError,
                                                                 com.facebook.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

com.facebook.thrift.TException

send_getColumnDescriptors

public void send_getColumnDescriptors(byte[] tableName)
                               throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_getColumnDescriptors

public AbstractMap<byte[],ColumnDescriptor> recv_getColumnDescriptors()
                                                               throws IOError,
                                                                      com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

getTableRegions

public ArrayList<RegionDescriptor> getTableRegions(byte[] tableName)
                                            throws IOError,
                                                   com.facebook.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

com.facebook.thrift.TException

send_getTableRegions

public void send_getTableRegions(byte[] tableName)
                          throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_getTableRegions

public ArrayList<RegionDescriptor> recv_getTableRegions()
                                                 throws IOError,
                                                        com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

createTable

public void createTable(byte[] tableName,
                        ArrayList<ColumnDescriptor> columnFamilies)
                 throws IOError,
                        IllegalArgument,
                        AlreadyExists,
                        com.facebook.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

com.facebook.thrift.TException

send_createTable

public void send_createTable(byte[] tableName,
                             ArrayList<ColumnDescriptor> columnFamilies)
                      throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_createTable

public void recv_createTable()
                      throws IOError,
                             IllegalArgument,
                             AlreadyExists,
                             com.facebook.thrift.TException

Throws:

IOError

IllegalArgument

AlreadyExists

com.facebook.thrift.TException

deleteTable

public void deleteTable(byte[] tableName)
                 throws IOError,
                        NotFound,
                        com.facebook.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:

NotFound - if table doesn't exist on server

IOError

com.facebook.thrift.TException

send_deleteTable

public void send_deleteTable(byte[] tableName)
                      throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_deleteTable

public void recv_deleteTable()
                      throws IOError,
                             NotFound,
                             com.facebook.thrift.TException

Throws:

IOError

NotFound

com.facebook.thrift.TException

get

public byte[] get(byte[] tableName,
                  byte[] row,
                  byte[] column)
           throws IOError,
                  NotFound,
                  com.facebook.thrift.TException

Description copied from interface: Hbase.Iface

Get a single value for the specified table, row, and column at the latest timestamp.

Specified by:

get in interface Hbase.Iface

Parameters:

tableName - name of table

row - row key

column - column name

Returns:

value for specified row/column

Throws:

IOError

NotFound

com.facebook.thrift.TException

send_get

public void send_get(byte[] tableName,
                     byte[] row,
                     byte[] column)
              throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_get

public byte[] recv_get()
                throws IOError,
                       NotFound,
                       com.facebook.thrift.TException

Throws:

IOError

NotFound

com.facebook.thrift.TException

getVer

public ArrayList<byte[]> getVer(byte[] tableName,
                                byte[] row,
                                byte[] column,
                                int numVersions)
                         throws IOError,
                                NotFound,
                                com.facebook.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

Returns:

list of values for specified row/column

Throws:

IOError

NotFound

com.facebook.thrift.TException

send_getVer

public void send_getVer(byte[] tableName,
                        byte[] row,
                        byte[] column,
                        int numVersions)
                 throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_getVer

public ArrayList<byte[]> recv_getVer()
                              throws IOError,
                                     NotFound,
                                     com.facebook.thrift.TException

Throws:

IOError

NotFound

com.facebook.thrift.TException

getVerTs

public ArrayList<byte[]> getVerTs(byte[] tableName,
                                  byte[] row,
                                  byte[] column,
                                  long timestamp,
                                  int numVersions)
                           throws IOError,
                                  NotFound,
                                  com.facebook.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

Returns:

list of values for specified row/column

Throws:

IOError

NotFound

com.facebook.thrift.TException

send_getVerTs

public void send_getVerTs(byte[] tableName,
                          byte[] row,
                          byte[] column,
                          long timestamp,
                          int numVersions)
                   throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_getVerTs

public ArrayList<byte[]> recv_getVerTs()
                                throws IOError,
                                       NotFound,
                                       com.facebook.thrift.TException

Throws:

IOError

NotFound

com.facebook.thrift.TException

getRow

public AbstractMap<byte[],byte[]> getRow(byte[] tableName,
                                         byte[] row)
                                  throws IOError,
                                         com.facebook.thrift.TException

Description copied from interface: Hbase.Iface

Get all the data for the specified table and row at the latest timestamp.

Specified by:

getRow in interface Hbase.Iface

Parameters:

tableName - name of table

row - row key

Returns:

Map of columns to values. Map is empty if row does not exist.

Throws:

IOError

com.facebook.thrift.TException

send_getRow

public void send_getRow(byte[] tableName,
                        byte[] row)
                 throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_getRow

public AbstractMap<byte[],byte[]> recv_getRow()
                                       throws IOError,
                                              com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

getRowTs

public AbstractMap<byte[],byte[]> getRowTs(byte[] tableName,
                                           byte[] row,
                                           long timestamp)
                                    throws IOError,
                                           com.facebook.thrift.TException

Description copied from interface: Hbase.Iface

Get all the data for the specified table and row at the specified timestamp.

Specified by:

getRowTs in interface Hbase.Iface

Parameters:

tableName - of table

row - row key

timestamp - timestamp

Returns:

Map of columns to values. Map is empty if row does not exist.

Throws:

IOError

com.facebook.thrift.TException

send_getRowTs

public void send_getRowTs(byte[] tableName,
                          byte[] row,
                          long timestamp)
                   throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_getRowTs

public AbstractMap<byte[],byte[]> recv_getRowTs()
                                         throws IOError,
                                                com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

put

public void put(byte[] tableName,
                byte[] row,
                byte[] column,
                byte[] value)
         throws IOError,
                com.facebook.thrift.TException

Description copied from interface: Hbase.Iface

Put a single value at the specified table, row, and column. To put muliple values in a single transaction, or to specify a non-default timestamp, use Hbase.Iface.mutateRow(byte[], byte[], java.util.ArrayList) and/or Hbase.Iface.mutateRowTs(byte[], byte[], java.util.ArrayList, long)

Specified by:

put in interface Hbase.Iface

Parameters:

tableName - name of table

row - row key

column - column name

Throws:

IOError

com.facebook.thrift.TException

send_put

public void send_put(byte[] tableName,
                     byte[] row,
                     byte[] column,
                     byte[] value)
              throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_put

public void recv_put()
              throws IOError,
                     com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

mutateRow

public void mutateRow(byte[] tableName,
                      byte[] row,
                      ArrayList<Mutation> mutations)
               throws IOError,
                      com.facebook.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

Throws:

IOError

com.facebook.thrift.TException

send_mutateRow

public void send_mutateRow(byte[] tableName,
                           byte[] row,
                           ArrayList<Mutation> mutations)
                    throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_mutateRow

public void recv_mutateRow()
                    throws IOError,
                           com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

mutateRowTs

public void mutateRowTs(byte[] tableName,
                        byte[] row,
                        ArrayList<Mutation> mutations,
                        long timestamp)
                 throws IOError,
                        com.facebook.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

Throws:

IOError

com.facebook.thrift.TException

send_mutateRowTs

public void send_mutateRowTs(byte[] tableName,
                             byte[] row,
                             ArrayList<Mutation> mutations,
                             long timestamp)
                      throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_mutateRowTs

public void recv_mutateRowTs()
                      throws IOError,
                             com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

deleteAll

public void deleteAll(byte[] tableName,
                      byte[] row,
                      byte[] column)
               throws IOError,
                      com.facebook.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

Throws:

IOError

com.facebook.thrift.TException

send_deleteAll

public void send_deleteAll(byte[] tableName,
                           byte[] row,
                           byte[] column)
                    throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_deleteAll

public void recv_deleteAll()
                    throws IOError,
                           com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

deleteAllTs

public void deleteAllTs(byte[] tableName,
                        byte[] row,
                        byte[] column,
                        long timestamp)
                 throws IOError,
                        com.facebook.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

Throws:

IOError

com.facebook.thrift.TException

send_deleteAllTs

public void send_deleteAllTs(byte[] tableName,
                             byte[] row,
                             byte[] column,
                             long timestamp)
                      throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_deleteAllTs

public void recv_deleteAllTs()
                      throws IOError,
                             com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

deleteAllRow

public void deleteAllRow(byte[] tableName,
                         byte[] row)
                  throws IOError,
                         com.facebook.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.

Throws:

IOError

com.facebook.thrift.TException

send_deleteAllRow

public void send_deleteAllRow(byte[] tableName,
                              byte[] row)
                       throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_deleteAllRow

public void recv_deleteAllRow()
                       throws IOError,
                              com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

deleteAllRowTs

public void deleteAllRowTs(byte[] tableName,
                           byte[] row,
                           long timestamp)
                    throws IOError,
                           com.facebook.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

Throws:

IOError

com.facebook.thrift.TException

send_deleteAllRowTs

public void send_deleteAllRowTs(byte[] tableName,
                                byte[] row,
                                long timestamp)
                         throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_deleteAllRowTs

public void recv_deleteAllRowTs()
                         throws IOError,
                                com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

scannerOpen

public int scannerOpen(byte[] tableName,
                       byte[] startRow,
                       ArrayList<byte[]> columns)
                throws IOError,
                       com.facebook.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. Its also possible to pass a regex in the column qualifier.

Returns:

scanner id to be used with other scanner procedures

Throws:

IOError

com.facebook.thrift.TException

send_scannerOpen

public void send_scannerOpen(byte[] tableName,
                             byte[] startRow,
                             ArrayList<byte[]> columns)
                      throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_scannerOpen

public int recv_scannerOpen()
                     throws IOError,
                            com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

scannerOpenWithStop

public int scannerOpenWithStop(byte[] tableName,
                               byte[] startRow,
                               byte[] stopRow,
                               ArrayList<byte[]> columns)
                        throws IOError,
                               com.facebook.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. Its also possible to pass a regex in the column qualifier.

Returns:

scanner id to be used with other scanner procedures

Throws:

IOError

com.facebook.thrift.TException

send_scannerOpenWithStop

public void send_scannerOpenWithStop(byte[] tableName,
                                     byte[] startRow,
                                     byte[] stopRow,
                                     ArrayList<byte[]> columns)
                              throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_scannerOpenWithStop

public int recv_scannerOpenWithStop()
                             throws IOError,
                                    com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

scannerOpenTs

public int scannerOpenTs(byte[] tableName,
                         byte[] startRow,
                         ArrayList<byte[]> columns,
                         long timestamp)
                  throws IOError,
                         com.facebook.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. Its also possible to pass a regex in the column qualifier.

timestamp - timestamp

Returns:

scanner id to be used with other scanner procedures

Throws:

IOError

com.facebook.thrift.TException

send_scannerOpenTs

public void send_scannerOpenTs(byte[] tableName,
                               byte[] startRow,
                               ArrayList<byte[]> columns,
                               long timestamp)
                        throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_scannerOpenTs

public int recv_scannerOpenTs()
                       throws IOError,
                              com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

scannerOpenWithStopTs

public int scannerOpenWithStopTs(byte[] tableName,
                                 byte[] startRow,
                                 byte[] stopRow,
                                 ArrayList<byte[]> columns,
                                 long timestamp)
                          throws IOError,
                                 com.facebook.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. Its also possible to pass a regex in the column qualifier.

timestamp - timestamp

Returns:

scanner id to be used with other scanner procedures

Throws:

IOError

com.facebook.thrift.TException

send_scannerOpenWithStopTs

public void send_scannerOpenWithStopTs(byte[] tableName,
                                       byte[] startRow,
                                       byte[] stopRow,
                                       ArrayList<byte[]> columns,
                                       long timestamp)
                                throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_scannerOpenWithStopTs

public int recv_scannerOpenWithStopTs()
                               throws IOError,
                                      com.facebook.thrift.TException

Throws:

IOError

com.facebook.thrift.TException

scannerGet

public ScanEntry scannerGet(int id)
                     throws IOError,
                            IllegalArgument,
                            NotFound,
                            com.facebook.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, a NotFound exception is returned.

Specified by:

scannerGet in interface Hbase.Iface

Parameters:

id - id of a scanner returned by scannerOpen

Returns:

a ScanEntry object representing the current row's values

Throws:

IllegalArgument - if ScannerID is invalid

NotFound - when the scanner reaches the end

IOError

com.facebook.thrift.TException

send_scannerGet

public void send_scannerGet(int id)
                     throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_scannerGet

public ScanEntry recv_scannerGet()
                          throws IOError,
                                 IllegalArgument,
                                 NotFound,
                                 com.facebook.thrift.TException

Throws:

IOError

IllegalArgument

NotFound

com.facebook.thrift.TException

scannerClose

public void scannerClose(int id)
                  throws IOError,
                         IllegalArgument,
                         com.facebook.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

com.facebook.thrift.TException

send_scannerClose

public void send_scannerClose(int id)
                       throws com.facebook.thrift.TException

Throws:

com.facebook.thrift.TException

recv_scannerClose

public void recv_scannerClose()
                       throws IOError,
                              IllegalArgument,
                              com.facebook.thrift.TException

Throws:

IOError

IllegalArgument

com.facebook.thrift.TException