#include <Hbase.h>
Public Member Functions | |
HbaseProcessor (boost::shared_ptr< HbaseIf > iface) | |
virtual bool | process (boost::shared_ptr< ::apache::thrift::protocol::TProtocol > piprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol > poprot, void *callContext) |
virtual | ~HbaseProcessor () |
Protected Member Functions | |
virtual bool | process_fn (::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, std::string &fname, int32_t seqid, void *callContext) |
Protected Attributes | |
boost::shared_ptr< HbaseIf > | iface_ |
Private Member Functions | |
void | process_atomicIncrement (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_compact (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_createTable (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_deleteAll (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_deleteAllRow (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_deleteAllRowTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_deleteAllTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_deleteTable (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_disableTable (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_enableTable (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_get (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getColumnDescriptors (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRegionInfo (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRow (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRowOrBefore (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRows (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRowsTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRowsWithColumns (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRowsWithColumnsTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRowTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRowWithColumns (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getRowWithColumnsTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getTableNames (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getTableRegions (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getVer (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_getVerTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_isTableEnabled (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_majorCompact (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_mutateRow (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_mutateRows (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_mutateRowsTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_mutateRowTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerClose (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerGet (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerGetList (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerOpen (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerOpenTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerOpenWithPrefix (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerOpenWithScan (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerOpenWithStop (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
void | process_scannerOpenWithStopTs (int32_t seqid,::apache::thrift::protocol::TProtocol *iprot,::apache::thrift::protocol::TProtocol *oprot, void *callContext) |
Private Attributes | |
std::map< std::string, void(HbaseProcessor::*)(int32_t,::apache::thrift::protocol::TProtocol *,::apache::thrift::protocol::TProtocol *, void *)> | processMap_ |
apache::hadoop::hbase::thrift::HbaseProcessor::HbaseProcessor | ( | boost::shared_ptr< HbaseIf > | iface | ) | [inline] |
virtual apache::hadoop::hbase::thrift::HbaseProcessor::~HbaseProcessor | ( | ) | [inline, virtual] |
bool apache::hadoop::hbase::thrift::HbaseProcessor::process | ( | boost::shared_ptr< ::apache::thrift::protocol::TProtocol > | piprot, |
boost::shared_ptr< ::apache::thrift::protocol::TProtocol > | poprot, | ||
void * | callContext | ||
) | [virtual] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_atomicIncrement | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_compact | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_createTable | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_deleteAll | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_deleteAllRow | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_deleteAllRowTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_deleteAllTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_deleteTable | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_disableTable | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_enableTable | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
bool apache::hadoop::hbase::thrift::HbaseProcessor::process_fn | ( | ::apache::thrift::protocol::TProtocol * | iprot, |
::apache::thrift::protocol::TProtocol * | oprot, | ||
std::string & | fname, | ||
int32_t | seqid, | ||
void * | callContext | ||
) | [protected, virtual] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_get | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getColumnDescriptors | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRegionInfo | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRow | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRowOrBefore | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRows | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRowsTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRowsWithColumns | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRowsWithColumnsTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRowTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRowWithColumns | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getRowWithColumnsTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getTableNames | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getTableRegions | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getVer | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_getVerTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_isTableEnabled | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_majorCompact | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_mutateRow | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_mutateRows | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_mutateRowsTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_mutateRowTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerClose | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerGet | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerGetList | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerOpen | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerOpenTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerOpenWithPrefix | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerOpenWithScan | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerOpenWithStop | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
void apache::hadoop::hbase::thrift::HbaseProcessor::process_scannerOpenWithStopTs | ( | int32_t | seqid, |
::apache::thrift::protocol::TProtocol * | iprot, | ||
::apache::thrift::protocol::TProtocol * | oprot, | ||
void * | callContext | ||
) | [private] |
boost::shared_ptr<HbaseIf> apache::hadoop::hbase::thrift::HbaseProcessor::iface_ [protected] |
std::map<std::string, void (HbaseProcessor::*)(int32_t, ::apache::thrift::protocol::TProtocol*, ::apache::thrift::protocol::TProtocol*, void*)> apache::hadoop::hbase::thrift::HbaseProcessor::processMap_ [private] |