org.apache.hadoop.hbase.thrift.generated

Class Hbase.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

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

All Implemented Interfaces:

Hbase.AsyncIface

Enclosing class:

Hbase

public static class Hbase.AsyncClient
extends org.apache.thrift.async.TAsyncClient
implements Hbase.AsyncIface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Hbase.AsyncClient.append_call
static class	Hbase.AsyncClient.atomicIncrement_call
static class	Hbase.AsyncClient.checkAndPut_call
static class	Hbase.AsyncClient.compact_call
static class	Hbase.AsyncClient.createTable_call
static class	Hbase.AsyncClient.deleteAll_call
static class	Hbase.AsyncClient.deleteAllRow_call
static class	Hbase.AsyncClient.deleteAllRowTs_call
static class	Hbase.AsyncClient.deleteAllTs_call
static class	Hbase.AsyncClient.deleteTable_call
static class	Hbase.AsyncClient.disableTable_call
static class	Hbase.AsyncClient.enableTable_call
static class	Hbase.AsyncClient.Factory
static class	Hbase.AsyncClient.get_call
static class	Hbase.AsyncClient.getColumnDescriptors_call
static class	Hbase.AsyncClient.getRegionInfo_call
static class	Hbase.AsyncClient.getRow_call
static class	Hbase.AsyncClient.getRowOrBefore_call
static class	Hbase.AsyncClient.getRows_call
static class	Hbase.AsyncClient.getRowsTs_call
static class	Hbase.AsyncClient.getRowsWithColumns_call
static class	Hbase.AsyncClient.getRowsWithColumnsTs_call
static class	Hbase.AsyncClient.getRowTs_call
static class	Hbase.AsyncClient.getRowWithColumns_call
static class	Hbase.AsyncClient.getRowWithColumnsTs_call
static class	Hbase.AsyncClient.getTableNames_call
static class	Hbase.AsyncClient.getTableRegions_call
static class	Hbase.AsyncClient.getVer_call
static class	Hbase.AsyncClient.getVerTs_call
static class	Hbase.AsyncClient.increment_call
static class	Hbase.AsyncClient.incrementRows_call
static class	Hbase.AsyncClient.isTableEnabled_call
static class	Hbase.AsyncClient.majorCompact_call
static class	Hbase.AsyncClient.mutateRow_call
static class	Hbase.AsyncClient.mutateRows_call
static class	Hbase.AsyncClient.mutateRowsTs_call
static class	Hbase.AsyncClient.mutateRowTs_call
static class	Hbase.AsyncClient.scannerClose_call
static class	Hbase.AsyncClient.scannerGet_call
static class	Hbase.AsyncClient.scannerGetList_call
static class	Hbase.AsyncClient.scannerOpen_call
static class	Hbase.AsyncClient.scannerOpenTs_call
static class	Hbase.AsyncClient.scannerOpenWithPrefix_call
static class	Hbase.AsyncClient.scannerOpenWithScan_call
static class	Hbase.AsyncClient.scannerOpenWithStop_call
static class	Hbase.AsyncClient.scannerOpenWithStopTs_call

Constructor Summary

Constructors

Constructor and Description
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)

Method Summary

Modifier and Type	Method and Description
void	append(TAppend append, <any> resultHandler)
void	atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, <any> resultHandler)
void	checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	compact(ByteBuffer tableNameOrRegionName, <any> resultHandler)
void	createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies, <any> resultHandler)
void	deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	deleteTable(ByteBuffer tableName, <any> resultHandler)
void	disableTable(ByteBuffer tableName, <any> resultHandler)
void	enableTable(ByteBuffer tableName, <any> resultHandler)
void	get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getColumnDescriptors(ByteBuffer tableName, <any> resultHandler)
void	getRegionInfo(ByteBuffer row, <any> resultHandler)
void	getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family, <any> resultHandler)
void	getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getTableNames(<any> resultHandler)
void	getTableRegions(ByteBuffer tableName, <any> resultHandler)
void	getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	increment(TIncrement increment, <any> resultHandler)
void	incrementRows(List<TIncrement> increments, <any> resultHandler)
void	isTableEnabled(ByteBuffer tableName, <any> resultHandler)
void	majorCompact(ByteBuffer tableNameOrRegionName, <any> resultHandler)
void	mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	scannerClose(int id, <any> resultHandler)
void	scannerGet(int id, <any> resultHandler)
void	scannerGetList(int id, int nbRows, <any> resultHandler)
void	scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)
void	scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, <any> resultHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncClient

public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
                   org.apache.thrift.async.TAsyncClientManager clientManager,
                   org.apache.thrift.transport.TNonblockingTransport transport)

Method Detail

enableTable

public void enableTable(ByteBuffer tableName,
                        <any> resultHandler)
                 throws org.apache.thrift.TException

Specified by:

enableTable in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

disableTable

public void disableTable(ByteBuffer tableName,
                         <any> resultHandler)
                  throws org.apache.thrift.TException

Specified by:

disableTable in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

isTableEnabled

public void isTableEnabled(ByteBuffer tableName,
                           <any> resultHandler)
                    throws org.apache.thrift.TException

Specified by:

isTableEnabled in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

compact

public void compact(ByteBuffer tableNameOrRegionName,
                    <any> resultHandler)
             throws org.apache.thrift.TException

Specified by:

compact in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

majorCompact

public void majorCompact(ByteBuffer tableNameOrRegionName,
                         <any> resultHandler)
                  throws org.apache.thrift.TException

Specified by:

majorCompact in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getTableNames

public void getTableNames(<any> resultHandler)
                   throws org.apache.thrift.TException

Specified by:

getTableNames in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getColumnDescriptors

public void getColumnDescriptors(ByteBuffer tableName,
                                 <any> resultHandler)
                          throws org.apache.thrift.TException

Specified by:

getColumnDescriptors in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getTableRegions

public void getTableRegions(ByteBuffer tableName,
                            <any> resultHandler)
                     throws org.apache.thrift.TException

Specified by:

getTableRegions in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

createTable

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

Specified by:

createTable in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

deleteTable

public void deleteTable(ByteBuffer tableName,
                        <any> resultHandler)
                 throws org.apache.thrift.TException

Specified by:

deleteTable in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

get

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

Specified by:

get in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getVer

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

Specified by:

getVer in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getVerTs

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

Specified by:

getVerTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRow

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

Specified by:

getRow in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRowWithColumns

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

Specified by:

getRowWithColumns in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRowTs

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

Specified by:

getRowTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRowWithColumnsTs

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

Specified by:

getRowWithColumnsTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRows

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

Specified by:

getRows in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRowsWithColumns

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

Specified by:

getRowsWithColumns in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRowsTs

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

Specified by:

getRowsTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRowsWithColumnsTs

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

Specified by:

getRowsWithColumnsTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

mutateRow

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

Specified by:

mutateRow in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

mutateRowTs

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

Specified by:

mutateRowTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

mutateRows

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

Specified by:

mutateRows in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

mutateRowsTs

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

Specified by:

mutateRowsTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

atomicIncrement

public void atomicIncrement(ByteBuffer tableName,
                            ByteBuffer row,
                            ByteBuffer column,
                            long value,
                            <any> resultHandler)
                     throws org.apache.thrift.TException

Specified by:

atomicIncrement in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

deleteAll

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

Specified by:

deleteAll in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

deleteAllTs

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

Specified by:

deleteAllTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

deleteAllRow

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

Specified by:

deleteAllRow in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

increment

public void increment(TIncrement increment,
                      <any> resultHandler)
               throws org.apache.thrift.TException

Specified by:

increment in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

incrementRows

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

Specified by:

incrementRows in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

deleteAllRowTs

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

Specified by:

deleteAllRowTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerOpenWithScan

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

Specified by:

scannerOpenWithScan in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerOpen

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

Specified by:

scannerOpen in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerOpenWithStop

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

Specified by:

scannerOpenWithStop in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerOpenWithPrefix

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

Specified by:

scannerOpenWithPrefix in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerOpenTs

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

Specified by:

scannerOpenTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerOpenWithStopTs

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

Specified by:

scannerOpenWithStopTs in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerGet

public void scannerGet(int id,
                       <any> resultHandler)
                throws org.apache.thrift.TException

Specified by:

scannerGet in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerGetList

public void scannerGetList(int id,
                           int nbRows,
                           <any> resultHandler)
                    throws org.apache.thrift.TException

Specified by:

scannerGetList in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

scannerClose

public void scannerClose(int id,
                         <any> resultHandler)
                  throws org.apache.thrift.TException

Specified by:

scannerClose in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRowOrBefore

public void getRowOrBefore(ByteBuffer tableName,
                           ByteBuffer row,
                           ByteBuffer family,
                           <any> resultHandler)
                    throws org.apache.thrift.TException

Specified by:

getRowOrBefore in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

getRegionInfo

public void getRegionInfo(ByteBuffer row,
                          <any> resultHandler)
                   throws org.apache.thrift.TException

Specified by:

getRegionInfo in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

append

public void append(TAppend append,
                   <any> resultHandler)
            throws org.apache.thrift.TException

Specified by:

append in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException

checkAndPut

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

Specified by:

checkAndPut in interface Hbase.AsyncIface

Throws:

org.apache.thrift.TException