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

java.lang.Object
  extended by 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  org.apache.thrift.protocol.TProtocol iprot_
           
protected  org.apache.thrift.protocol.TProtocol oprot_
           
protected  int seqid_
           
 
Constructor Summary
Hbase.Client(org.apache.thrift.protocol.TProtocol prot)
           
Hbase.Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)
           
 
Method Summary
 long atomicIncrement(byte[] tableName, byte[] row, byte[] column, long value)
          Atomically increment the column value specified.
 void compact(byte[] tableNameOrRegionName)
           
 void createTable(byte[] tableName, List<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
 void disableTable(byte[] 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(byte[] tableName)
          Brings a table on-line (enables it)
 List<TCell> get(byte[] tableName, byte[] row, byte[] column)
          Get a single TCell for the specified table, row, and column at the latest timestamp.
 Map<byte[],ColumnDescriptor> getColumnDescriptors(byte[] tableName)
          List all the column families assoicated with a table.
 org.apache.thrift.protocol.TProtocol getInputProtocol()
           
 org.apache.thrift.protocol.TProtocol getOutputProtocol()
           
 List<TRowResult> getRow(byte[] tableName, byte[] row)
          Get all the data for the specified table and row at the latest timestamp.
 List<TRowResult> getRows(byte[] tableName, List<byte[]> rows)
          Get all the data for the specified table and rows at the latest timestamp.
 List<TRowResult> getRowsTs(byte[] tableName, List<byte[]> rows, long timestamp)
          Get all the data for the specified table and rows at the specified timestamp.
 List<TRowResult> getRowsWithColumns(byte[] tableName, List<byte[]> rows, List<byte[]> columns)
          Get the specified columns for the specified table and rows at the latest timestamp.
 List<TRowResult> getRowsWithColumnsTs(byte[] tableName, List<byte[]> rows, List<byte[]> columns, long timestamp)
          Get the specified columns for the specified table and rows at the specified timestamp.
 List<TRowResult> getRowTs(byte[] tableName, byte[] row, long timestamp)
          Get all the data for the specified table and row at the specified timestamp.
 List<TRowResult> getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns)
          Get the specified columns for the specified table and row at the latest timestamp.
 List<TRowResult> getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, long timestamp)
          Get the specified columns for the specified table and row at the specified timestamp.
 List<byte[]> getTableNames()
          List all the userspace tables.
 List<TRegionInfo> getTableRegions(byte[] tableName)
          List the regions associated with a table.
 List<TCell> getVer(byte[] tableName, byte[] row, byte[] column, int numVersions)
          Get the specified number of versions for the specified table, row, and column.
 List<TCell> getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions)
          Get the specified number of versions for the specified table, row, and column.
 boolean isTableEnabled(byte[] tableName)
           
 void majorCompact(byte[] tableNameOrRegionName)
           
 void mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations)
          Apply a series of mutations (updates/deletes) to a row in a single transaction.
 void mutateRows(byte[] tableName, List<BatchMutation> rowBatches)
          Apply a series of batches (each a series of mutations on a single row) in a single transaction.
 void mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp)
          Apply a series of batches (each a series of mutations on a single row) in a single transaction.
 void mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp)
          Apply a series of mutations (updates/deletes) to a row in a single transaction.
 long recv_atomicIncrement()
           
 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<byte[],ColumnDescriptor> recv_getColumnDescriptors()
           
 List<TRowResult> recv_getRow()
           
 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<byte[]> recv_getTableNames()
           
 List<TRegionInfo> recv_getTableRegions()
           
 List<TCell> recv_getVer()
           
 List<TCell> recv_getVerTs()
           
 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_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(byte[] tableName, byte[] startRow, List<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, List<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 scannerOpenWithPrefix(byte[] tableName, byte[] startAndPrefix, List<byte[]> columns)
          Open a scanner for a given prefix.
 int scannerOpenWithStop(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns)
          Get a scanner on the current table starting and stopping at the specified rows.
 int scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns, long timestamp)
          Get a scanner on the current table starting and stopping at the specified rows.
 void send_atomicIncrement(byte[] tableName, byte[] row, byte[] column, long value)
           
 void send_compact(byte[] tableNameOrRegionName)
           
 void send_createTable(byte[] tableName, List<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_disableTable(byte[] tableName)
           
 void send_enableTable(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_getRows(byte[] tableName, List<byte[]> rows)
           
 void send_getRowsTs(byte[] tableName, List<byte[]> rows, long timestamp)
           
 void send_getRowsWithColumns(byte[] tableName, List<byte[]> rows, List<byte[]> columns)
           
 void send_getRowsWithColumnsTs(byte[] tableName, List<byte[]> rows, List<byte[]> columns, long timestamp)
           
 void send_getRowTs(byte[] tableName, byte[] row, long timestamp)
           
 void send_getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns)
           
 void send_getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, 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_isTableEnabled(byte[] tableName)
           
 void send_majorCompact(byte[] tableNameOrRegionName)
           
 void send_mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations)
           
 void send_mutateRows(byte[] tableName, List<BatchMutation> rowBatches)
           
 void send_mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp)
           
 void send_mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp)
           
 void send_scannerClose(int id)
           
 void send_scannerGet(int id)
           
 void send_scannerGetList(int id, int nbRows)
           
 void send_scannerOpen(byte[] tableName, byte[] startRow, List<byte[]> columns)
           
 void send_scannerOpenTs(byte[] tableName, byte[] startRow, List<byte[]> columns, long timestamp)
           
 void send_scannerOpenWithPrefix(byte[] tableName, byte[] startAndPrefix, List<byte[]> columns)
           
 void send_scannerOpenWithStop(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns)
           
 void send_scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, List<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 org.apache.thrift.protocol.TProtocol iprot_

oprot_

protected org.apache.thrift.protocol.TProtocol oprot_

seqid_

protected int seqid_
Constructor Detail

Hbase.Client

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

Hbase.Client

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

getInputProtocol

public org.apache.thrift.protocol.TProtocol getInputProtocol()

getOutputProtocol

public org.apache.thrift.protocol.TProtocol getOutputProtocol()

enableTable

public void enableTable(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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<byte[]> 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<byte[]> recv_getTableNames()
                                throws IOError,
                                       org.apache.thrift.TException
Throws:
IOError
org.apache.thrift.TException

getColumnDescriptors

public Map<byte[],ColumnDescriptor> getColumnDescriptors(byte[] 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(byte[] tableName)
                               throws org.apache.thrift.TException
Throws:
org.apache.thrift.TException

recv_getColumnDescriptors

public Map<byte[],ColumnDescriptor> recv_getColumnDescriptors()
                                                       throws IOError,
                                                              org.apache.thrift.TException
Throws:
IOError
org.apache.thrift.TException

getTableRegions

public List<TRegionInfo> getTableRegions(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] 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(byte[] tableName,
                       byte[] row,
                       byte[] column)
                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
Returns:
value for specified row/column
Throws:
IOError
org.apache.thrift.TException

send_get

public void send_get(byte[] tableName,
                     byte[] row,
                     byte[] column)
              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(byte[] tableName,
                          byte[] row,
                          byte[] column,
                          int numVersions)
                   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
Returns:
list of cells for specified row/column
Throws:
IOError
org.apache.thrift.TException

send_getVer

public void send_getVer(byte[] tableName,
                        byte[] row,
                        byte[] column,
                        int numVersions)
                 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(byte[] tableName,
                            byte[] row,
                            byte[] column,
                            long timestamp,
                            int numVersions)
                     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
Returns:
list of cells for specified row/column
Throws:
IOError
org.apache.thrift.TException

send_getVerTs

public void send_getVerTs(byte[] tableName,
                          byte[] row,
                          byte[] column,
                          long timestamp,
                          int numVersions)
                   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(byte[] tableName,
                               byte[] row)
                        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
Returns:
TRowResult containing the row and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRow

public void send_getRow(byte[] tableName,
                        byte[] row)
                 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(byte[] tableName,
                                          byte[] row,
                                          List<byte[]> columns)
                                   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
Returns:
TRowResult containing the row and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRowWithColumns

public void send_getRowWithColumns(byte[] tableName,
                                   byte[] row,
                                   List<byte[]> columns)
                            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(byte[] tableName,
                                 byte[] row,
                                 long timestamp)
                          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
Returns:
TRowResult containing the row and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRowTs

public void send_getRowTs(byte[] tableName,
                          byte[] row,
                          long timestamp)
                   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(byte[] tableName,
                                            byte[] row,
                                            List<byte[]> columns,
                                            long timestamp)
                                     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
Returns:
TRowResult containing the row and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRowWithColumnsTs

public void send_getRowWithColumnsTs(byte[] tableName,
                                     byte[] row,
                                     List<byte[]> columns,
                                     long timestamp)
                              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(byte[] tableName,
                                List<byte[]> rows)
                         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
Returns:
TRowResult containing the rows and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRows

public void send_getRows(byte[] tableName,
                         List<byte[]> rows)
                  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(byte[] tableName,
                                           List<byte[]> rows,
                                           List<byte[]> columns)
                                    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
Returns:
TRowResult containing the rows and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRowsWithColumns

public void send_getRowsWithColumns(byte[] tableName,
                                    List<byte[]> rows,
                                    List<byte[]> columns)
                             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(byte[] tableName,
                                  List<byte[]> rows,
                                  long timestamp)
                           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
Returns:
TRowResult containing the rows and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRowsTs

public void send_getRowsTs(byte[] tableName,
                           List<byte[]> rows,
                           long timestamp)
                    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(byte[] tableName,
                                             List<byte[]> rows,
                                             List<byte[]> columns,
                                             long timestamp)
                                      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
Returns:
TRowResult containing the rows and map of columns to TCells
Throws:
IOError
org.apache.thrift.TException

send_getRowsWithColumnsTs

public void send_getRowsWithColumnsTs(byte[] tableName,
                                      List<byte[]> rows,
                                      List<byte[]> columns,
                                      long timestamp)
                               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(byte[] tableName,
                      byte[] row,
                      List<Mutation> mutations)
               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
Throws:
IOError
IllegalArgument
org.apache.thrift.TException

send_mutateRow

public void send_mutateRow(byte[] tableName,
                           byte[] row,
                           List<Mutation> mutations)
                    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(byte[] tableName,
                        byte[] row,
                        List<Mutation> mutations,
                        long timestamp)
                 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
Throws:
IOError
IllegalArgument
org.apache.thrift.TException

send_mutateRowTs

public void send_mutateRowTs(byte[] tableName,
                             byte[] row,
                             List<Mutation> mutations,
                             long timestamp)
                      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(byte[] tableName,
                       List<BatchMutation> rowBatches)
                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
Throws:
IOError
IllegalArgument
org.apache.thrift.TException

send_mutateRows

public void send_mutateRows(byte[] tableName,
                            List<BatchMutation> rowBatches)
                     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(byte[] tableName,
                         List<BatchMutation> rowBatches,
                         long timestamp)
                  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
Throws:
IOError
IllegalArgument
org.apache.thrift.TException

send_mutateRowsTs

public void send_mutateRowsTs(byte[] tableName,
                              List<BatchMutation> rowBatches,
                              long timestamp)
                       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(byte[] tableName,
                            byte[] row,
                            byte[] 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(byte[] tableName,
                                 byte[] row,
                                 byte[] 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(byte[] tableName,
                      byte[] row,
                      byte[] column)
               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
Throws:
IOError
org.apache.thrift.TException

send_deleteAll

public void send_deleteAll(byte[] tableName,
                           byte[] row,
                           byte[] column)
                    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(byte[] tableName,
                        byte[] row,
                        byte[] column,
                        long timestamp)
                 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
Throws:
IOError
org.apache.thrift.TException

send_deleteAllTs

public void send_deleteAllTs(byte[] tableName,
                             byte[] row,
                             byte[] column,
                             long timestamp)
                      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(byte[] tableName,
                         byte[] row)
                  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.
Throws:
IOError
org.apache.thrift.TException

send_deleteAllRow

public void send_deleteAllRow(byte[] tableName,
                              byte[] row)
                       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

deleteAllRowTs

public void deleteAllRowTs(byte[] tableName,
                           byte[] row,
                           long timestamp)
                    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
Throws:
IOError
org.apache.thrift.TException

send_deleteAllRowTs

public void send_deleteAllRowTs(byte[] tableName,
                                byte[] row,
                                long timestamp)
                         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

scannerOpen

public int scannerOpen(byte[] tableName,
                       byte[] startRow,
                       List<byte[]> columns)
                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.
Returns:
scanner id to be used with other scanner procedures
Throws:
IOError
org.apache.thrift.TException

send_scannerOpen

public void send_scannerOpen(byte[] tableName,
                             byte[] startRow,
                             List<byte[]> columns)
                      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(byte[] tableName,
                               byte[] startRow,
                               byte[] stopRow,
                               List<byte[]> columns)
                        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.
Returns:
scanner id to be used with other scanner procedures
Throws:
IOError
org.apache.thrift.TException

send_scannerOpenWithStop

public void send_scannerOpenWithStop(byte[] tableName,
                                     byte[] startRow,
                                     byte[] stopRow,
                                     List<byte[]> columns)
                              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(byte[] tableName,
                                 byte[] startAndPrefix,
                                 List<byte[]> columns)
                          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
Returns:
scanner id to use with other scanner calls
Throws:
IOError
org.apache.thrift.TException

send_scannerOpenWithPrefix

public void send_scannerOpenWithPrefix(byte[] tableName,
                                       byte[] startAndPrefix,
                                       List<byte[]> columns)
                                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(byte[] tableName,
                         byte[] startRow,
                         List<byte[]> columns,
                         long timestamp)
                  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
Returns:
scanner id to be used with other scanner procedures
Throws:
IOError
org.apache.thrift.TException

send_scannerOpenTs

public void send_scannerOpenTs(byte[] tableName,
                               byte[] startRow,
                               List<byte[]> columns,
                               long timestamp)
                        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(byte[] tableName,
                                 byte[] startRow,
                                 byte[] stopRow,
                                 List<byte[]> columns,
                                 long timestamp)
                          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
Returns:
scanner id to be used with other scanner procedures
Throws:
IOError
org.apache.thrift.TException

send_scannerOpenWithStopTs

public void send_scannerOpenWithStopTs(byte[] tableName,
                                       byte[] startRow,
                                       byte[] stopRow,
                                       List<byte[]> columns,
                                       long timestamp)
                                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


Copyright © 2011 The Apache Software Foundation. All Rights Reserved.