1.由于郭海龙修改了提供的库,导致增加了大量南瑞的头文件, 所以新建include目录用于存放所有的南瑞提供的同文件。 2. 修复sys_nicmonitor进程重启后,调用接口告警问题。 3. 增加USER_NUSP宏,用于nusp用户。 4. 由于新增了许多头文件且需交接给郭海龙,所以独立了一版2.0版本以用于区分。 修改: code/README 新文件: code/dep/42/dotconf#1.0.13-1.pkg.tar.gz 新文件: code/dep/42/run.sh 新文件: code/dep/90/libdotconf-dev_1.3-0.2_amd64.deb 新文件: code/dep/90/libdotconf-dev_1.3-0.2_arm64.deb 新文件: code/dep/90/libdotconf0_1.3-0.2_amd64.deb 新文件: code/dep/90/libdotconf0_1.3-0.2_arm64.deb 新文件: code/dep/90/run.sh 新文件: code/dep/libproc_common.so 新文件: code/dep/old/libman.so 新文件: code/dep/proc_common.cpp 新文件: code/sys_nicmonitor-code.tar.gz 修改: code/sys_nicmonitor/Makefile 修改: code/sys_nicmonitor/README 新文件: code/sys_nicmonitor/include/common_types.h 新文件: code/sys_nicmonitor/include/d5000_err.h 新文件: code/sys_nicmonitor/include/db_api/DeleteRecorder.h 新文件: code/sys_nicmonitor/include/db_api/codb_net.h 新文件: code/sys_nicmonitor/include/db_api/mc_rtdb_m.h 新文件: code/sys_nicmonitor/include/db_api/mc_rtdb_mng.h 新文件: code/sys_nicmonitor/include/db_api/odb_apinet.h 新文件: code/sys_nicmonitor/include/db_api/odb_apinet_rtdb_key.h 新文件: code/sys_nicmonitor/include/db_api/odb_apiop.h 新文件: code/sys_nicmonitor/include/db_api/odb_apiop.h.old 新文件: code/sys_nicmonitor/include/db_api/odb_app2id.h 新文件: code/sys_nicmonitor/include/db_api/odb_autolock.h 新文件: code/sys_nicmonitor/include/db_api/odb_baseindex.h 新文件: code/sys_nicmonitor/include/db_api/odb_ckeymanager.h 新文件: code/sys_nicmonitor/include/db_api/odb_common.h 新文件: code/sys_nicmonitor/include/db_api/odb_define.h 新文件: code/sys_nicmonitor/include/db_api/odb_double_overflow_hashindex.h 新文件: code/sys_nicmonitor/include/db_api/odb_field.h 新文件: code/sys_nicmonitor/include/db_api/odb_hashindex.h 新文件: code/sys_nicmonitor/include/db_api/odb_hashpk.h 新文件: code/sys_nicmonitor/include/db_api/odb_intel_ptr.h 新文件: code/sys_nicmonitor/include/db_api/odb_lock.h 新文件: code/sys_nicmonitor/include/db_api/odb_net.h 新文件: code/sys_nicmonitor/include/db_api/odb_net_m.h 新文件: code/sys_nicmonitor/include/db_api/odb_netfactory.h 新文件: code/sys_nicmonitor/include/db_api/odb_nooverflow_pk.h 新文件: code/sys_nicmonitor/include/db_api/odb_orbmgr.h 新文件: code/sys_nicmonitor/include/db_api/odb_profile.h 新文件: code/sys_nicmonitor/include/db_api/odb_prv_struct.h 新文件: code/sys_nicmonitor/include/db_api/odb_public.h 新文件: code/sys_nicmonitor/include/db_api/odb_rtdbbase.h 新文件: code/sys_nicmonitor/include/db_api/odb_rtdbfactory.h 新文件: code/sys_nicmonitor/include/db_api/odb_rtdbop.h 新文件: code/sys_nicmonitor/include/db_api/odb_rtdbtable.h 新文件: code/sys_nicmonitor/include/db_api/odb_struct.h 新文件: code/sys_nicmonitor/include/db_api/odb_system.h 新文件: code/sys_nicmonitor/include/db_api/odb_table.h 新文件: code/sys_nicmonitor/include/db_api/odb_tablebase.h 新文件: code/sys_nicmonitor/include/db_api/odb_tablemgr.h 新文件: code/sys_nicmonitor/include/db_api/odb_tablenet.h 新文件: code/sys_nicmonitor/include/db_api/odb_tableop.h 新文件: code/sys_nicmonitor/include/db_api/odb_where.h 新文件: code/sys_nicmonitor/include/db_api/pub_buf.h 新文件: code/sys_nicmonitor/include/db_api/rtdb_graph_name_list.h 新文件: code/sys_nicmonitor/include/db_api/server2proto.h 新文件: code/sys_nicmonitor/include/db_api/tab2idx.h 新文件: code/sys_nicmonitor/include/db_api/vl_get_data.h 新文件: code/sys_nicmonitor/include/db_api/vl_struct.h 新文件: code/sys_nicmonitor/include/db_api/vl_struct_m.cpp 新文件: code/sys_nicmonitor/include/db_api/vl_struct_m.h 新文件: code/sys_nicmonitor/include/db_com/CAppNo.h 新文件: code/sys_nicmonitor/include/db_com/CCharArray.h 新文件: code/sys_nicmonitor/include/db_com/CDataStream.h 新文件: code/sys_nicmonitor/include/db_com/CDbCommitClient.h 新文件: code/sys_nicmonitor/include/db_com/CDbMonitorClient.h 新文件: code/sys_nicmonitor/include/db_com/CDbMonitorLocal.h 新文件: code/sys_nicmonitor/include/db_com/CDbMonitorShm.h 新文件: code/sys_nicmonitor/include/db_com/CDbRepSet.h 新文件: code/sys_nicmonitor/include/db_com/CDbSem.h 新文件: code/sys_nicmonitor/include/db_com/CDbSemUse.h 新文件: code/sys_nicmonitor/include/db_com/CDbShm.h 新文件: code/sys_nicmonitor/include/db_com/CDyCfgLocal.h 新文件: code/sys_nicmonitor/include/db_com/CDyCommitClient.h 新文件: code/sys_nicmonitor/include/db_com/CDyMonitorClient.h 新文件: code/sys_nicmonitor/include/db_com/CDyMonitorLocal.h 新文件: code/sys_nicmonitor/include/db_com/CDyMonitorShm.h 新文件: code/sys_nicmonitor/include/db_com/CDySem.h 新文件: code/sys_nicmonitor/include/db_com/CDySemUse.h 新文件: code/sys_nicmonitor/include/db_com/CDyShm.h 新文件: code/sys_nicmonitor/include/db_com/CDyTagShmInfo.h 新文件: code/sys_nicmonitor/include/db_com/CErrorLog.h 新文件: code/sys_nicmonitor/include/db_com/CFindFile.h 新文件: code/sys_nicmonitor/include/db_com/CPrecTime.h 新文件: code/sys_nicmonitor/include/db_com/CRecordSet.h 新文件: code/sys_nicmonitor/include/db_com/CRedisAccess.h 新文件: code/sys_nicmonitor/include/db_com/CRepSet.h 新文件: code/sys_nicmonitor/include/db_com/CSaveReCommitSql.h 新文件: code/sys_nicmonitor/include/db_com/CSqlResultAlign.h 新文件: code/sys_nicmonitor/include/db_com/CSqlResultAlignClient.h 新文件: code/sys_nicmonitor/include/db_com/CSqlResultAlignClient2.h 新文件: code/sys_nicmonitor/include/db_com/DBAccess.h 新文件: code/sys_nicmonitor/include/db_com/DBCipher.h 新文件: code/sys_nicmonitor/include/db_com/DBConnectPool.h 新文件: code/sys_nicmonitor/include/db_com/DbFileNetIf.h 新文件: code/sys_nicmonitor/include/db_com/Hbase.h 新文件: code/sys_nicmonitor/include/db_com/Hbase_constants.h 新文件: code/sys_nicmonitor/include/db_com/Hbase_types.h 新文件: code/sys_nicmonitor/include/db_com/MyMutex.h 新文件: code/sys_nicmonitor/include/db_com/cross_region_sync_client.h 新文件: code/sys_nicmonitor/include/db_com/database_rep_m.h 新文件: code/sys_nicmonitor/include/db_com/db_commit_define.h 新文件: code/sys_nicmonitor/include/db_com/db_commit_m.h 新文件: code/sys_nicmonitor/include/db_com/db_error_define.h 新文件: code/sys_nicmonitor/include/db_com/db_extern.h 新文件: code/sys_nicmonitor/include/db_com/db_global.h 新文件: code/sys_nicmonitor/include/db_com/db_micro_define.h 新文件: code/sys_nicmonitor/include/db_com/db_monitor_define.h 新文件: code/sys_nicmonitor/include/db_com/db_monitor_define.h.old 新文件: code/sys_nicmonitor/include/db_com/db_monitor_extern.h 新文件: code/sys_nicmonitor/include/db_com/db_monitor_global.h 新文件: code/sys_nicmonitor/include/db_com/db_monitor_m.h 新文件: code/sys_nicmonitor/include/db_com/db_monitor_m.h.old 新文件: code/sys_nicmonitor/include/db_com/db_rep_lib_define.h 新文件: code/sys_nicmonitor/include/db_com/db_stat_m.h 新文件: code/sys_nicmonitor/include/db_com/db_stat_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/ds_log.h 新文件: code/sys_nicmonitor/include/db_com/dy_commit_m.h 新文件: code/sys_nicmonitor/include/db_com/dy_monitor_define.h 新文件: code/sys_nicmonitor/include/db_com/dy_monitor_m.h 新文件: code/sys_nicmonitor/include/db_com/dy_public_m.h 新文件: code/sys_nicmonitor/include/db_com/dy_sample_define_m.h 新文件: code/sys_nicmonitor/include/db_com/dy_sample_define_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/dy_stat_m.h 新文件: code/sys_nicmonitor/include/db_com/dy_stat_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/hiredis.h 新文件: code/sys_nicmonitor/include/db_com/interpreter_define.h 新文件: code/sys_nicmonitor/include/db_com/interpreter_struct.h 新文件: code/sys_nicmonitor/include/db_com/lexical_anls.h 新文件: code/sys_nicmonitor/include/db_com/public_m.h 新文件: code/sys_nicmonitor/include/db_com/query_sample_m.h 新文件: code/sys_nicmonitor/include/db_com/query_sample_pi.h 新文件: code/sys_nicmonitor/include/db_com/query_sample_pi_m.h 新文件: code/sys_nicmonitor/include/db_com/query_sample_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/query_sample_service_pi_interface.h 新文件: code/sys_nicmonitor/include/db_com/query_stat_m.h 新文件: code/sys_nicmonitor/include/db_com/query_stat_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/rdb_commit_client.h 新文件: code/sys_nicmonitor/include/db_com/rdb_commit_m.h 新文件: code/sys_nicmonitor/include/db_com/rdb_define.pb.h 新文件: code/sys_nicmonitor/include/db_com/read.h 新文件: code/sys_nicmonitor/include/db_com/rtdbkey_defs.h 新文件: code/sys_nicmonitor/include/db_com/sample_data_client_base.h 新文件: code/sys_nicmonitor/include/db_com/sample_data_m.h 新文件: code/sys_nicmonitor/include/db_com/sample_define_m.h 新文件: code/sys_nicmonitor/include/db_com/sample_define_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/sample_modify_m.h 新文件: code/sys_nicmonitor/include/db_com/sample_modify_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/sds.h 新文件: code/sys_nicmonitor/include/db_com/server_define.h 新文件: code/sys_nicmonitor/include/db_com/sheetdataclient.h 新文件: code/sys_nicmonitor/include/db_com/sheetdataclient.h0604 新文件: code/sys_nicmonitor/include/db_com/sql_sp_client_base.h 新文件: code/sys_nicmonitor/include/db_com/sql_sp_define.h 新文件: code/sys_nicmonitor/include/db_com/sql_sp_m.h 新文件: code/sys_nicmonitor/include/db_com/sql_sp_send_client_base.h 新文件: code/sys_nicmonitor/include/db_com/sql_syntax_anls.h 新文件: code/sys_nicmonitor/include/db_com/sql_to_cime.h 新文件: code/sys_nicmonitor/include/db_com/sqlite_access.h 新文件: code/sys_nicmonitor/include/db_com/sqlite_server_client.h 新文件: code/sys_nicmonitor/include/db_com/sqlite_srv_m.h 新文件: code/sys_nicmonitor/include/db_com/store_access_client.h 新文件: code/sys_nicmonitor/include/db_com/trigger_sample_m.h 新文件: code/sys_nicmonitor/include/db_com/trigger_sample_service_interface.h 新文件: code/sys_nicmonitor/include/db_com/wholepubtools.h 新文件: code/sys_nicmonitor/include/db_com/wholesampledata.h 新文件: code/sys_nicmonitor/include/db_com/wholesqlsp.h 新文件: code/sys_nicmonitor/include/log_api.h 新文件: code/sys_nicmonitor/include/log_define.h 新文件: code/sys_nicmonitor/include/logclient.h 新文件: code/sys_nicmonitor/include/port_def.h 新文件: code/sys_nicmonitor/include/proc_common.h 新文件: code/sys_nicmonitor/include/scn_common.h 新文件: code/sys_nicmonitor/include/sysadm/proc_define.h 新文件: code/sys_nicmonitor/include/sysadm/scn_define.h 新文件: code/sys_nicmonitor/include/system.h 修改: code/sys_nicmonitor/mnic.c 修改: code/sys_nicmonitor/nicinfo_shm.c 修改: code/sys_nicmonitor/test.c 修改: code/sys_nicmonitor/version.h 新文件: code/test/test_nic 新文件: code/test/test_nic.cpp 新文件: packages/sys_nicmonitor-2.0-linx90-aarch64-bin-d5000.tar.gz 新文件: packages/sys_nicmonitor-2.0-linx90-aarch64-bin-nusp.tar.gz 新文件: packages/sys_nicmonitor-2.0-linx90-x86_64-bin-d5000.tar.gz 新文件: packages/sys_nicmonitor-2.0-linx90-x86_64-bin-nusp.tar.gz 重命名: sys_nicmonitor-arm-bin.tar.gz -> packages/sys_nicmonitor-arm-bin.tar.gz 重命名: sys_nicmonitor-arm.tar.gz -> packages/sys_nicmonitor-arm.tar.gz 新文件: packages/sys_nicmonitor-mips64-bin.tar.gz 新文件: packages/sys_nicmonitor-mips64.tar.gz Signed-off-by: Wei, Jing <jwei@linx-info.com>
6702 lines
176 KiB
C++
6702 lines
176 KiB
C++
/**
|
|
* Autogenerated by Thrift Compiler (0.9.0)
|
|
*
|
|
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
|
* @generated
|
|
*/
|
|
#ifndef Hbase_H
|
|
#define Hbase_H
|
|
|
|
#include <thrift/TDispatchProcessor.h>
|
|
#include "Hbase_types.h"
|
|
|
|
namespace apache { namespace hadoop { namespace hbase { namespace thrift {
|
|
|
|
class HbaseIf {
|
|
public:
|
|
virtual ~HbaseIf() {}
|
|
virtual void enableTable(const Bytes& tableName) = 0;
|
|
virtual void disableTable(const Bytes& tableName) = 0;
|
|
virtual bool isTableEnabled(const Bytes& tableName) = 0;
|
|
virtual void compact(const Bytes& tableNameOrRegionName) = 0;
|
|
virtual void majorCompact(const Bytes& tableNameOrRegionName) = 0;
|
|
virtual void getTableNames(std::vector<Text> & _return) = 0;
|
|
virtual void getColumnDescriptors(std::map<Text, ColumnDescriptor> & _return, const Text& tableName) = 0;
|
|
virtual void getTableRegions(std::vector<TRegionInfo> & _return, const Text& tableName) = 0;
|
|
virtual void createTable(const Text& tableName, const std::vector<ColumnDescriptor> & columnFamilies) = 0;
|
|
virtual void deleteTable(const Text& tableName) = 0;
|
|
virtual void get(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getVer(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int32_t numVersions, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getVerTs(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const int32_t numVersions, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRow(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRowWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRowTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRowWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRows(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRowsWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRowsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void getRowsWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void mutateRow(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void mutateRowTs(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void mutateRows(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void mutateRowsTs(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual int64_t atomicIncrement(const Text& tableName, const Text& row, const Text& column, const int64_t value) = 0;
|
|
virtual void deleteAll(const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void deleteAllTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void deleteAllRow(const Text& tableName, const Text& row, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void increment(const TIncrement& increment) = 0;
|
|
virtual void incrementRows(const std::vector<TIncrement> & increments) = 0;
|
|
virtual void deleteAllRowTs(const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual ScannerID scannerOpenWithScan(const Text& tableName, const TScan& scan, const std::map<Text, Text> & attributes) = 0;
|
|
virtual ScannerID scannerOpen(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) = 0;
|
|
virtual ScannerID scannerOpenWithStop(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) = 0;
|
|
virtual ScannerID scannerOpenWithPrefix(const Text& tableName, const Text& startAndPrefix, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) = 0;
|
|
virtual ScannerID scannerOpenTs(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual ScannerID scannerOpenWithStopTs(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) = 0;
|
|
virtual void scannerGet(std::vector<TRowResult> & _return, const ScannerID id) = 0;
|
|
virtual void scannerGetList(std::vector<TRowResult> & _return, const ScannerID id, const int32_t nbRows) = 0;
|
|
virtual void scannerClose(const ScannerID id) = 0;
|
|
virtual void getRowOrBefore(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& family) = 0;
|
|
virtual void getRegionInfo(TRegionInfo& _return, const Text& row) = 0;
|
|
};
|
|
|
|
class HbaseIfFactory {
|
|
public:
|
|
typedef HbaseIf Handler;
|
|
|
|
virtual ~HbaseIfFactory() {}
|
|
|
|
virtual HbaseIf* getHandler(const ::apache::thrift::TConnectionInfo& connInfo) = 0;
|
|
virtual void releaseHandler(HbaseIf* /* handler */) = 0;
|
|
};
|
|
|
|
class HbaseIfSingletonFactory : virtual public HbaseIfFactory {
|
|
public:
|
|
HbaseIfSingletonFactory(const boost::shared_ptr<HbaseIf>& iface) : iface_(iface) {}
|
|
virtual ~HbaseIfSingletonFactory() {}
|
|
|
|
virtual HbaseIf* getHandler(const ::apache::thrift::TConnectionInfo&) {
|
|
return iface_.get();
|
|
}
|
|
virtual void releaseHandler(HbaseIf* /* handler */) {}
|
|
|
|
protected:
|
|
boost::shared_ptr<HbaseIf> iface_;
|
|
};
|
|
|
|
class HbaseNull : virtual public HbaseIf {
|
|
public:
|
|
virtual ~HbaseNull() {}
|
|
void enableTable(const Bytes& /* tableName */) {
|
|
return;
|
|
}
|
|
void disableTable(const Bytes& /* tableName */) {
|
|
return;
|
|
}
|
|
bool isTableEnabled(const Bytes& /* tableName */) {
|
|
bool _return = false;
|
|
return _return;
|
|
}
|
|
void compact(const Bytes& /* tableNameOrRegionName */) {
|
|
return;
|
|
}
|
|
void majorCompact(const Bytes& /* tableNameOrRegionName */) {
|
|
return;
|
|
}
|
|
void getTableNames(std::vector<Text> & /* _return */) {
|
|
return;
|
|
}
|
|
void getColumnDescriptors(std::map<Text, ColumnDescriptor> & /* _return */, const Text& /* tableName */) {
|
|
return;
|
|
}
|
|
void getTableRegions(std::vector<TRegionInfo> & /* _return */, const Text& /* tableName */) {
|
|
return;
|
|
}
|
|
void createTable(const Text& /* tableName */, const std::vector<ColumnDescriptor> & /* columnFamilies */) {
|
|
return;
|
|
}
|
|
void deleteTable(const Text& /* tableName */) {
|
|
return;
|
|
}
|
|
void get(std::vector<TCell> & /* _return */, const Text& /* tableName */, const Text& /* row */, const Text& /* column */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getVer(std::vector<TCell> & /* _return */, const Text& /* tableName */, const Text& /* row */, const Text& /* column */, const int32_t /* numVersions */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getVerTs(std::vector<TCell> & /* _return */, const Text& /* tableName */, const Text& /* row */, const Text& /* column */, const int64_t /* timestamp */, const int32_t /* numVersions */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRow(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const Text& /* row */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRowWithColumns(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const Text& /* row */, const std::vector<Text> & /* columns */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRowTs(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const Text& /* row */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRowWithColumnsTs(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const Text& /* row */, const std::vector<Text> & /* columns */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRows(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const std::vector<Text> & /* rows */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRowsWithColumns(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const std::vector<Text> & /* rows */, const std::vector<Text> & /* columns */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRowsTs(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const std::vector<Text> & /* rows */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void getRowsWithColumnsTs(std::vector<TRowResult> & /* _return */, const Text& /* tableName */, const std::vector<Text> & /* rows */, const std::vector<Text> & /* columns */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void mutateRow(const Text& /* tableName */, const Text& /* row */, const std::vector<Mutation> & /* mutations */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void mutateRowTs(const Text& /* tableName */, const Text& /* row */, const std::vector<Mutation> & /* mutations */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void mutateRows(const Text& /* tableName */, const std::vector<BatchMutation> & /* rowBatches */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void mutateRowsTs(const Text& /* tableName */, const std::vector<BatchMutation> & /* rowBatches */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
int64_t atomicIncrement(const Text& /* tableName */, const Text& /* row */, const Text& /* column */, const int64_t /* value */) {
|
|
int64_t _return = 0;
|
|
return _return;
|
|
}
|
|
void deleteAll(const Text& /* tableName */, const Text& /* row */, const Text& /* column */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void deleteAllTs(const Text& /* tableName */, const Text& /* row */, const Text& /* column */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void deleteAllRow(const Text& /* tableName */, const Text& /* row */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
void increment(const TIncrement& /* increment */) {
|
|
return;
|
|
}
|
|
void incrementRows(const std::vector<TIncrement> & /* increments */) {
|
|
return;
|
|
}
|
|
void deleteAllRowTs(const Text& /* tableName */, const Text& /* row */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
return;
|
|
}
|
|
ScannerID scannerOpenWithScan(const Text& /* tableName */, const TScan& /* scan */, const std::map<Text, Text> & /* attributes */) {
|
|
ScannerID _return = 0;
|
|
return _return;
|
|
}
|
|
ScannerID scannerOpen(const Text& /* tableName */, const Text& /* startRow */, const std::vector<Text> & /* columns */, const std::map<Text, Text> & /* attributes */) {
|
|
ScannerID _return = 0;
|
|
return _return;
|
|
}
|
|
ScannerID scannerOpenWithStop(const Text& /* tableName */, const Text& /* startRow */, const Text& /* stopRow */, const std::vector<Text> & /* columns */, const std::map<Text, Text> & /* attributes */) {
|
|
ScannerID _return = 0;
|
|
return _return;
|
|
}
|
|
ScannerID scannerOpenWithPrefix(const Text& /* tableName */, const Text& /* startAndPrefix */, const std::vector<Text> & /* columns */, const std::map<Text, Text> & /* attributes */) {
|
|
ScannerID _return = 0;
|
|
return _return;
|
|
}
|
|
ScannerID scannerOpenTs(const Text& /* tableName */, const Text& /* startRow */, const std::vector<Text> & /* columns */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
ScannerID _return = 0;
|
|
return _return;
|
|
}
|
|
ScannerID scannerOpenWithStopTs(const Text& /* tableName */, const Text& /* startRow */, const Text& /* stopRow */, const std::vector<Text> & /* columns */, const int64_t /* timestamp */, const std::map<Text, Text> & /* attributes */) {
|
|
ScannerID _return = 0;
|
|
return _return;
|
|
}
|
|
void scannerGet(std::vector<TRowResult> & /* _return */, const ScannerID /* id */) {
|
|
return;
|
|
}
|
|
void scannerGetList(std::vector<TRowResult> & /* _return */, const ScannerID /* id */, const int32_t /* nbRows */) {
|
|
return;
|
|
}
|
|
void scannerClose(const ScannerID /* id */) {
|
|
return;
|
|
}
|
|
void getRowOrBefore(std::vector<TCell> & /* _return */, const Text& /* tableName */, const Text& /* row */, const Text& /* family */) {
|
|
return;
|
|
}
|
|
void getRegionInfo(TRegionInfo& /* _return */, const Text& /* row */) {
|
|
return;
|
|
}
|
|
};
|
|
|
|
typedef struct _Hbase_enableTable_args__isset {
|
|
_Hbase_enableTable_args__isset() : tableName(false) {}
|
|
bool tableName;
|
|
} _Hbase_enableTable_args__isset;
|
|
|
|
class Hbase_enableTable_args {
|
|
public:
|
|
|
|
Hbase_enableTable_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_enableTable_args() throw() {}
|
|
|
|
Bytes tableName;
|
|
|
|
_Hbase_enableTable_args__isset __isset;
|
|
|
|
void __set_tableName(const Bytes& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_enableTable_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_enableTable_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_enableTable_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_enableTable_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_enableTable_pargs() throw() {}
|
|
|
|
const Bytes* tableName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_enableTable_result__isset {
|
|
_Hbase_enableTable_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_enableTable_result__isset;
|
|
|
|
class Hbase_enableTable_result {
|
|
public:
|
|
|
|
Hbase_enableTable_result() {
|
|
}
|
|
|
|
virtual ~Hbase_enableTable_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_enableTable_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_enableTable_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_enableTable_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_enableTable_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_enableTable_presult__isset {
|
|
_Hbase_enableTable_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_enableTable_presult__isset;
|
|
|
|
class Hbase_enableTable_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_enableTable_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_enableTable_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_disableTable_args__isset {
|
|
_Hbase_disableTable_args__isset() : tableName(false) {}
|
|
bool tableName;
|
|
} _Hbase_disableTable_args__isset;
|
|
|
|
class Hbase_disableTable_args {
|
|
public:
|
|
|
|
Hbase_disableTable_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_disableTable_args() throw() {}
|
|
|
|
Bytes tableName;
|
|
|
|
_Hbase_disableTable_args__isset __isset;
|
|
|
|
void __set_tableName(const Bytes& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_disableTable_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_disableTable_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_disableTable_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_disableTable_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_disableTable_pargs() throw() {}
|
|
|
|
const Bytes* tableName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_disableTable_result__isset {
|
|
_Hbase_disableTable_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_disableTable_result__isset;
|
|
|
|
class Hbase_disableTable_result {
|
|
public:
|
|
|
|
Hbase_disableTable_result() {
|
|
}
|
|
|
|
virtual ~Hbase_disableTable_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_disableTable_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_disableTable_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_disableTable_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_disableTable_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_disableTable_presult__isset {
|
|
_Hbase_disableTable_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_disableTable_presult__isset;
|
|
|
|
class Hbase_disableTable_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_disableTable_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_disableTable_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_isTableEnabled_args__isset {
|
|
_Hbase_isTableEnabled_args__isset() : tableName(false) {}
|
|
bool tableName;
|
|
} _Hbase_isTableEnabled_args__isset;
|
|
|
|
class Hbase_isTableEnabled_args {
|
|
public:
|
|
|
|
Hbase_isTableEnabled_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_isTableEnabled_args() throw() {}
|
|
|
|
Bytes tableName;
|
|
|
|
_Hbase_isTableEnabled_args__isset __isset;
|
|
|
|
void __set_tableName(const Bytes& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_isTableEnabled_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_isTableEnabled_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_isTableEnabled_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_isTableEnabled_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_isTableEnabled_pargs() throw() {}
|
|
|
|
const Bytes* tableName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_isTableEnabled_result__isset {
|
|
_Hbase_isTableEnabled_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_isTableEnabled_result__isset;
|
|
|
|
class Hbase_isTableEnabled_result {
|
|
public:
|
|
|
|
Hbase_isTableEnabled_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_isTableEnabled_result() throw() {}
|
|
|
|
bool success;
|
|
IOError io;
|
|
|
|
_Hbase_isTableEnabled_result__isset __isset;
|
|
|
|
void __set_success(const bool val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_isTableEnabled_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_isTableEnabled_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_isTableEnabled_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_isTableEnabled_presult__isset {
|
|
_Hbase_isTableEnabled_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_isTableEnabled_presult__isset;
|
|
|
|
class Hbase_isTableEnabled_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_isTableEnabled_presult() throw() {}
|
|
|
|
bool* success;
|
|
IOError io;
|
|
|
|
_Hbase_isTableEnabled_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_compact_args__isset {
|
|
_Hbase_compact_args__isset() : tableNameOrRegionName(false) {}
|
|
bool tableNameOrRegionName;
|
|
} _Hbase_compact_args__isset;
|
|
|
|
class Hbase_compact_args {
|
|
public:
|
|
|
|
Hbase_compact_args() : tableNameOrRegionName() {
|
|
}
|
|
|
|
virtual ~Hbase_compact_args() throw() {}
|
|
|
|
Bytes tableNameOrRegionName;
|
|
|
|
_Hbase_compact_args__isset __isset;
|
|
|
|
void __set_tableNameOrRegionName(const Bytes& val) {
|
|
tableNameOrRegionName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_compact_args & rhs) const
|
|
{
|
|
if (!(tableNameOrRegionName == rhs.tableNameOrRegionName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_compact_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_compact_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_compact_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_compact_pargs() throw() {}
|
|
|
|
const Bytes* tableNameOrRegionName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_compact_result__isset {
|
|
_Hbase_compact_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_compact_result__isset;
|
|
|
|
class Hbase_compact_result {
|
|
public:
|
|
|
|
Hbase_compact_result() {
|
|
}
|
|
|
|
virtual ~Hbase_compact_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_compact_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_compact_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_compact_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_compact_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_compact_presult__isset {
|
|
_Hbase_compact_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_compact_presult__isset;
|
|
|
|
class Hbase_compact_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_compact_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_compact_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_majorCompact_args__isset {
|
|
_Hbase_majorCompact_args__isset() : tableNameOrRegionName(false) {}
|
|
bool tableNameOrRegionName;
|
|
} _Hbase_majorCompact_args__isset;
|
|
|
|
class Hbase_majorCompact_args {
|
|
public:
|
|
|
|
Hbase_majorCompact_args() : tableNameOrRegionName() {
|
|
}
|
|
|
|
virtual ~Hbase_majorCompact_args() throw() {}
|
|
|
|
Bytes tableNameOrRegionName;
|
|
|
|
_Hbase_majorCompact_args__isset __isset;
|
|
|
|
void __set_tableNameOrRegionName(const Bytes& val) {
|
|
tableNameOrRegionName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_majorCompact_args & rhs) const
|
|
{
|
|
if (!(tableNameOrRegionName == rhs.tableNameOrRegionName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_majorCompact_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_majorCompact_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_majorCompact_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_majorCompact_pargs() throw() {}
|
|
|
|
const Bytes* tableNameOrRegionName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_majorCompact_result__isset {
|
|
_Hbase_majorCompact_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_majorCompact_result__isset;
|
|
|
|
class Hbase_majorCompact_result {
|
|
public:
|
|
|
|
Hbase_majorCompact_result() {
|
|
}
|
|
|
|
virtual ~Hbase_majorCompact_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_majorCompact_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_majorCompact_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_majorCompact_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_majorCompact_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_majorCompact_presult__isset {
|
|
_Hbase_majorCompact_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_majorCompact_presult__isset;
|
|
|
|
class Hbase_majorCompact_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_majorCompact_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_majorCompact_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getTableNames_args {
|
|
public:
|
|
|
|
Hbase_getTableNames_args() {
|
|
}
|
|
|
|
virtual ~Hbase_getTableNames_args() throw() {}
|
|
|
|
|
|
bool operator == (const Hbase_getTableNames_args & /* rhs */) const
|
|
{
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getTableNames_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getTableNames_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getTableNames_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getTableNames_pargs() throw() {}
|
|
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getTableNames_result__isset {
|
|
_Hbase_getTableNames_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getTableNames_result__isset;
|
|
|
|
class Hbase_getTableNames_result {
|
|
public:
|
|
|
|
Hbase_getTableNames_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getTableNames_result() throw() {}
|
|
|
|
std::vector<Text> success;
|
|
IOError io;
|
|
|
|
_Hbase_getTableNames_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<Text> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getTableNames_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getTableNames_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getTableNames_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getTableNames_presult__isset {
|
|
_Hbase_getTableNames_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getTableNames_presult__isset;
|
|
|
|
class Hbase_getTableNames_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getTableNames_presult() throw() {}
|
|
|
|
std::vector<Text> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getTableNames_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getColumnDescriptors_args__isset {
|
|
_Hbase_getColumnDescriptors_args__isset() : tableName(false) {}
|
|
bool tableName;
|
|
} _Hbase_getColumnDescriptors_args__isset;
|
|
|
|
class Hbase_getColumnDescriptors_args {
|
|
public:
|
|
|
|
Hbase_getColumnDescriptors_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_getColumnDescriptors_args() throw() {}
|
|
|
|
Text tableName;
|
|
|
|
_Hbase_getColumnDescriptors_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getColumnDescriptors_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getColumnDescriptors_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getColumnDescriptors_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getColumnDescriptors_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getColumnDescriptors_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getColumnDescriptors_result__isset {
|
|
_Hbase_getColumnDescriptors_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getColumnDescriptors_result__isset;
|
|
|
|
class Hbase_getColumnDescriptors_result {
|
|
public:
|
|
|
|
Hbase_getColumnDescriptors_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getColumnDescriptors_result() throw() {}
|
|
|
|
std::map<Text, ColumnDescriptor> success;
|
|
IOError io;
|
|
|
|
_Hbase_getColumnDescriptors_result__isset __isset;
|
|
|
|
void __set_success(const std::map<Text, ColumnDescriptor> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getColumnDescriptors_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getColumnDescriptors_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getColumnDescriptors_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getColumnDescriptors_presult__isset {
|
|
_Hbase_getColumnDescriptors_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getColumnDescriptors_presult__isset;
|
|
|
|
class Hbase_getColumnDescriptors_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getColumnDescriptors_presult() throw() {}
|
|
|
|
std::map<Text, ColumnDescriptor> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getColumnDescriptors_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getTableRegions_args__isset {
|
|
_Hbase_getTableRegions_args__isset() : tableName(false) {}
|
|
bool tableName;
|
|
} _Hbase_getTableRegions_args__isset;
|
|
|
|
class Hbase_getTableRegions_args {
|
|
public:
|
|
|
|
Hbase_getTableRegions_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_getTableRegions_args() throw() {}
|
|
|
|
Text tableName;
|
|
|
|
_Hbase_getTableRegions_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getTableRegions_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getTableRegions_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getTableRegions_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getTableRegions_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getTableRegions_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getTableRegions_result__isset {
|
|
_Hbase_getTableRegions_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getTableRegions_result__isset;
|
|
|
|
class Hbase_getTableRegions_result {
|
|
public:
|
|
|
|
Hbase_getTableRegions_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getTableRegions_result() throw() {}
|
|
|
|
std::vector<TRegionInfo> success;
|
|
IOError io;
|
|
|
|
_Hbase_getTableRegions_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRegionInfo> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getTableRegions_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getTableRegions_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getTableRegions_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getTableRegions_presult__isset {
|
|
_Hbase_getTableRegions_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getTableRegions_presult__isset;
|
|
|
|
class Hbase_getTableRegions_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getTableRegions_presult() throw() {}
|
|
|
|
std::vector<TRegionInfo> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getTableRegions_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_createTable_args__isset {
|
|
_Hbase_createTable_args__isset() : tableName(false), columnFamilies(false) {}
|
|
bool tableName;
|
|
bool columnFamilies;
|
|
} _Hbase_createTable_args__isset;
|
|
|
|
class Hbase_createTable_args {
|
|
public:
|
|
|
|
Hbase_createTable_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_createTable_args() throw() {}
|
|
|
|
Text tableName;
|
|
std::vector<ColumnDescriptor> columnFamilies;
|
|
|
|
_Hbase_createTable_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_columnFamilies(const std::vector<ColumnDescriptor> & val) {
|
|
columnFamilies = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_createTable_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(columnFamilies == rhs.columnFamilies))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_createTable_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_createTable_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_createTable_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_createTable_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const std::vector<ColumnDescriptor> * columnFamilies;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_createTable_result__isset {
|
|
_Hbase_createTable_result__isset() : io(false), ia(false), exist(false) {}
|
|
bool io;
|
|
bool ia;
|
|
bool exist;
|
|
} _Hbase_createTable_result__isset;
|
|
|
|
class Hbase_createTable_result {
|
|
public:
|
|
|
|
Hbase_createTable_result() {
|
|
}
|
|
|
|
virtual ~Hbase_createTable_result() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
AlreadyExists exist;
|
|
|
|
_Hbase_createTable_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
void __set_exist(const AlreadyExists& val) {
|
|
exist = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_createTable_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
if (!(exist == rhs.exist))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_createTable_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_createTable_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_createTable_presult__isset {
|
|
_Hbase_createTable_presult__isset() : io(false), ia(false), exist(false) {}
|
|
bool io;
|
|
bool ia;
|
|
bool exist;
|
|
} _Hbase_createTable_presult__isset;
|
|
|
|
class Hbase_createTable_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_createTable_presult() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
AlreadyExists exist;
|
|
|
|
_Hbase_createTable_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteTable_args__isset {
|
|
_Hbase_deleteTable_args__isset() : tableName(false) {}
|
|
bool tableName;
|
|
} _Hbase_deleteTable_args__isset;
|
|
|
|
class Hbase_deleteTable_args {
|
|
public:
|
|
|
|
Hbase_deleteTable_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteTable_args() throw() {}
|
|
|
|
Text tableName;
|
|
|
|
_Hbase_deleteTable_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteTable_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteTable_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteTable_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_deleteTable_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteTable_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteTable_result__isset {
|
|
_Hbase_deleteTable_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteTable_result__isset;
|
|
|
|
class Hbase_deleteTable_result {
|
|
public:
|
|
|
|
Hbase_deleteTable_result() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteTable_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteTable_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteTable_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteTable_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteTable_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteTable_presult__isset {
|
|
_Hbase_deleteTable_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteTable_presult__isset;
|
|
|
|
class Hbase_deleteTable_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteTable_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteTable_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_get_args__isset {
|
|
_Hbase_get_args__isset() : tableName(false), row(false), column(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool column;
|
|
bool attributes;
|
|
} _Hbase_get_args__isset;
|
|
|
|
class Hbase_get_args {
|
|
public:
|
|
|
|
Hbase_get_args() : tableName(), row(), column() {
|
|
}
|
|
|
|
virtual ~Hbase_get_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
Text column;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_get_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_column(const Text& val) {
|
|
column = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_get_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(column == rhs.column))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_get_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_get_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_get_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_get_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const Text* column;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_get_result__isset {
|
|
_Hbase_get_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_get_result__isset;
|
|
|
|
class Hbase_get_result {
|
|
public:
|
|
|
|
Hbase_get_result() {
|
|
}
|
|
|
|
virtual ~Hbase_get_result() throw() {}
|
|
|
|
std::vector<TCell> success;
|
|
IOError io;
|
|
|
|
_Hbase_get_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TCell> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_get_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_get_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_get_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_get_presult__isset {
|
|
_Hbase_get_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_get_presult__isset;
|
|
|
|
class Hbase_get_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_get_presult() throw() {}
|
|
|
|
std::vector<TCell> * success;
|
|
IOError io;
|
|
|
|
_Hbase_get_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getVer_args__isset {
|
|
_Hbase_getVer_args__isset() : tableName(false), row(false), column(false), numVersions(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool column;
|
|
bool numVersions;
|
|
bool attributes;
|
|
} _Hbase_getVer_args__isset;
|
|
|
|
class Hbase_getVer_args {
|
|
public:
|
|
|
|
Hbase_getVer_args() : tableName(), row(), column(), numVersions(0) {
|
|
}
|
|
|
|
virtual ~Hbase_getVer_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
Text column;
|
|
int32_t numVersions;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getVer_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_column(const Text& val) {
|
|
column = val;
|
|
}
|
|
|
|
void __set_numVersions(const int32_t val) {
|
|
numVersions = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getVer_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(column == rhs.column))
|
|
return false;
|
|
if (!(numVersions == rhs.numVersions))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getVer_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getVer_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getVer_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getVer_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const Text* column;
|
|
const int32_t* numVersions;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getVer_result__isset {
|
|
_Hbase_getVer_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getVer_result__isset;
|
|
|
|
class Hbase_getVer_result {
|
|
public:
|
|
|
|
Hbase_getVer_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getVer_result() throw() {}
|
|
|
|
std::vector<TCell> success;
|
|
IOError io;
|
|
|
|
_Hbase_getVer_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TCell> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getVer_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getVer_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getVer_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getVer_presult__isset {
|
|
_Hbase_getVer_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getVer_presult__isset;
|
|
|
|
class Hbase_getVer_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getVer_presult() throw() {}
|
|
|
|
std::vector<TCell> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getVer_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getVerTs_args__isset {
|
|
_Hbase_getVerTs_args__isset() : tableName(false), row(false), column(false), timestamp(false), numVersions(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool column;
|
|
bool timestamp;
|
|
bool numVersions;
|
|
bool attributes;
|
|
} _Hbase_getVerTs_args__isset;
|
|
|
|
class Hbase_getVerTs_args {
|
|
public:
|
|
|
|
Hbase_getVerTs_args() : tableName(), row(), column(), timestamp(0), numVersions(0) {
|
|
}
|
|
|
|
virtual ~Hbase_getVerTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
Text column;
|
|
int64_t timestamp;
|
|
int32_t numVersions;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getVerTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_column(const Text& val) {
|
|
column = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_numVersions(const int32_t val) {
|
|
numVersions = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getVerTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(column == rhs.column))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(numVersions == rhs.numVersions))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getVerTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getVerTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getVerTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getVerTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const Text* column;
|
|
const int64_t* timestamp;
|
|
const int32_t* numVersions;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getVerTs_result__isset {
|
|
_Hbase_getVerTs_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getVerTs_result__isset;
|
|
|
|
class Hbase_getVerTs_result {
|
|
public:
|
|
|
|
Hbase_getVerTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getVerTs_result() throw() {}
|
|
|
|
std::vector<TCell> success;
|
|
IOError io;
|
|
|
|
_Hbase_getVerTs_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TCell> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getVerTs_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getVerTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getVerTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getVerTs_presult__isset {
|
|
_Hbase_getVerTs_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getVerTs_presult__isset;
|
|
|
|
class Hbase_getVerTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getVerTs_presult() throw() {}
|
|
|
|
std::vector<TCell> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getVerTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRow_args__isset {
|
|
_Hbase_getRow_args__isset() : tableName(false), row(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool attributes;
|
|
} _Hbase_getRow_args__isset;
|
|
|
|
class Hbase_getRow_args {
|
|
public:
|
|
|
|
Hbase_getRow_args() : tableName(), row() {
|
|
}
|
|
|
|
virtual ~Hbase_getRow_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRow_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRow_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRow_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRow_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRow_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRow_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRow_result__isset {
|
|
_Hbase_getRow_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRow_result__isset;
|
|
|
|
class Hbase_getRow_result {
|
|
public:
|
|
|
|
Hbase_getRow_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRow_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRow_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRow_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRow_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRow_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRow_presult__isset {
|
|
_Hbase_getRow_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRow_presult__isset;
|
|
|
|
class Hbase_getRow_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRow_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRow_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowWithColumns_args__isset {
|
|
_Hbase_getRowWithColumns_args__isset() : tableName(false), row(false), columns(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool columns;
|
|
bool attributes;
|
|
} _Hbase_getRowWithColumns_args__isset;
|
|
|
|
class Hbase_getRowWithColumns_args {
|
|
public:
|
|
|
|
Hbase_getRowWithColumns_args() : tableName(), row() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowWithColumns_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
std::vector<Text> columns;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRowWithColumns_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowWithColumns_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowWithColumns_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowWithColumns_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRowWithColumns_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowWithColumns_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const std::vector<Text> * columns;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowWithColumns_result__isset {
|
|
_Hbase_getRowWithColumns_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowWithColumns_result__isset;
|
|
|
|
class Hbase_getRowWithColumns_result {
|
|
public:
|
|
|
|
Hbase_getRowWithColumns_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowWithColumns_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowWithColumns_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowWithColumns_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowWithColumns_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowWithColumns_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowWithColumns_presult__isset {
|
|
_Hbase_getRowWithColumns_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowWithColumns_presult__isset;
|
|
|
|
class Hbase_getRowWithColumns_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowWithColumns_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowWithColumns_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowTs_args__isset {
|
|
_Hbase_getRowTs_args__isset() : tableName(false), row(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_getRowTs_args__isset;
|
|
|
|
class Hbase_getRowTs_args {
|
|
public:
|
|
|
|
Hbase_getRowTs_args() : tableName(), row(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_getRowTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRowTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRowTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowTs_result__isset {
|
|
_Hbase_getRowTs_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowTs_result__isset;
|
|
|
|
class Hbase_getRowTs_result {
|
|
public:
|
|
|
|
Hbase_getRowTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowTs_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowTs_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowTs_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowTs_presult__isset {
|
|
_Hbase_getRowTs_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowTs_presult__isset;
|
|
|
|
class Hbase_getRowTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowTs_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowWithColumnsTs_args__isset {
|
|
_Hbase_getRowWithColumnsTs_args__isset() : tableName(false), row(false), columns(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool columns;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_getRowWithColumnsTs_args__isset;
|
|
|
|
class Hbase_getRowWithColumnsTs_args {
|
|
public:
|
|
|
|
Hbase_getRowWithColumnsTs_args() : tableName(), row(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_getRowWithColumnsTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
std::vector<Text> columns;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRowWithColumnsTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowWithColumnsTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowWithColumnsTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowWithColumnsTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRowWithColumnsTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowWithColumnsTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const std::vector<Text> * columns;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowWithColumnsTs_result__isset {
|
|
_Hbase_getRowWithColumnsTs_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowWithColumnsTs_result__isset;
|
|
|
|
class Hbase_getRowWithColumnsTs_result {
|
|
public:
|
|
|
|
Hbase_getRowWithColumnsTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowWithColumnsTs_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowWithColumnsTs_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowWithColumnsTs_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowWithColumnsTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowWithColumnsTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowWithColumnsTs_presult__isset {
|
|
_Hbase_getRowWithColumnsTs_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowWithColumnsTs_presult__isset;
|
|
|
|
class Hbase_getRowWithColumnsTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowWithColumnsTs_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowWithColumnsTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRows_args__isset {
|
|
_Hbase_getRows_args__isset() : tableName(false), rows(false), attributes(false) {}
|
|
bool tableName;
|
|
bool rows;
|
|
bool attributes;
|
|
} _Hbase_getRows_args__isset;
|
|
|
|
class Hbase_getRows_args {
|
|
public:
|
|
|
|
Hbase_getRows_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_getRows_args() throw() {}
|
|
|
|
Text tableName;
|
|
std::vector<Text> rows;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRows_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_rows(const std::vector<Text> & val) {
|
|
rows = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRows_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(rows == rhs.rows))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRows_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRows_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRows_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRows_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const std::vector<Text> * rows;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRows_result__isset {
|
|
_Hbase_getRows_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRows_result__isset;
|
|
|
|
class Hbase_getRows_result {
|
|
public:
|
|
|
|
Hbase_getRows_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRows_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRows_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRows_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRows_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRows_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRows_presult__isset {
|
|
_Hbase_getRows_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRows_presult__isset;
|
|
|
|
class Hbase_getRows_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRows_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRows_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsWithColumns_args__isset {
|
|
_Hbase_getRowsWithColumns_args__isset() : tableName(false), rows(false), columns(false), attributes(false) {}
|
|
bool tableName;
|
|
bool rows;
|
|
bool columns;
|
|
bool attributes;
|
|
} _Hbase_getRowsWithColumns_args__isset;
|
|
|
|
class Hbase_getRowsWithColumns_args {
|
|
public:
|
|
|
|
Hbase_getRowsWithColumns_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowsWithColumns_args() throw() {}
|
|
|
|
Text tableName;
|
|
std::vector<Text> rows;
|
|
std::vector<Text> columns;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRowsWithColumns_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_rows(const std::vector<Text> & val) {
|
|
rows = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowsWithColumns_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(rows == rhs.rows))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowsWithColumns_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowsWithColumns_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRowsWithColumns_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowsWithColumns_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const std::vector<Text> * rows;
|
|
const std::vector<Text> * columns;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsWithColumns_result__isset {
|
|
_Hbase_getRowsWithColumns_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowsWithColumns_result__isset;
|
|
|
|
class Hbase_getRowsWithColumns_result {
|
|
public:
|
|
|
|
Hbase_getRowsWithColumns_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowsWithColumns_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowsWithColumns_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowsWithColumns_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowsWithColumns_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowsWithColumns_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsWithColumns_presult__isset {
|
|
_Hbase_getRowsWithColumns_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowsWithColumns_presult__isset;
|
|
|
|
class Hbase_getRowsWithColumns_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowsWithColumns_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowsWithColumns_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsTs_args__isset {
|
|
_Hbase_getRowsTs_args__isset() : tableName(false), rows(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool rows;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_getRowsTs_args__isset;
|
|
|
|
class Hbase_getRowsTs_args {
|
|
public:
|
|
|
|
Hbase_getRowsTs_args() : tableName(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_getRowsTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
std::vector<Text> rows;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRowsTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_rows(const std::vector<Text> & val) {
|
|
rows = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowsTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(rows == rhs.rows))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowsTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowsTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRowsTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowsTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const std::vector<Text> * rows;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsTs_result__isset {
|
|
_Hbase_getRowsTs_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowsTs_result__isset;
|
|
|
|
class Hbase_getRowsTs_result {
|
|
public:
|
|
|
|
Hbase_getRowsTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowsTs_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowsTs_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowsTs_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowsTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowsTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsTs_presult__isset {
|
|
_Hbase_getRowsTs_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowsTs_presult__isset;
|
|
|
|
class Hbase_getRowsTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowsTs_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowsTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsWithColumnsTs_args__isset {
|
|
_Hbase_getRowsWithColumnsTs_args__isset() : tableName(false), rows(false), columns(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool rows;
|
|
bool columns;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_getRowsWithColumnsTs_args__isset;
|
|
|
|
class Hbase_getRowsWithColumnsTs_args {
|
|
public:
|
|
|
|
Hbase_getRowsWithColumnsTs_args() : tableName(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_getRowsWithColumnsTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
std::vector<Text> rows;
|
|
std::vector<Text> columns;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_getRowsWithColumnsTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_rows(const std::vector<Text> & val) {
|
|
rows = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowsWithColumnsTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(rows == rhs.rows))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowsWithColumnsTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowsWithColumnsTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRowsWithColumnsTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowsWithColumnsTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const std::vector<Text> * rows;
|
|
const std::vector<Text> * columns;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsWithColumnsTs_result__isset {
|
|
_Hbase_getRowsWithColumnsTs_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowsWithColumnsTs_result__isset;
|
|
|
|
class Hbase_getRowsWithColumnsTs_result {
|
|
public:
|
|
|
|
Hbase_getRowsWithColumnsTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowsWithColumnsTs_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowsWithColumnsTs_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowsWithColumnsTs_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowsWithColumnsTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowsWithColumnsTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowsWithColumnsTs_presult__isset {
|
|
_Hbase_getRowsWithColumnsTs_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowsWithColumnsTs_presult__isset;
|
|
|
|
class Hbase_getRowsWithColumnsTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowsWithColumnsTs_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowsWithColumnsTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRow_args__isset {
|
|
_Hbase_mutateRow_args__isset() : tableName(false), row(false), mutations(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool mutations;
|
|
bool attributes;
|
|
} _Hbase_mutateRow_args__isset;
|
|
|
|
class Hbase_mutateRow_args {
|
|
public:
|
|
|
|
Hbase_mutateRow_args() : tableName(), row() {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRow_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
std::vector<Mutation> mutations;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_mutateRow_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_mutations(const std::vector<Mutation> & val) {
|
|
mutations = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRow_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(mutations == rhs.mutations))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRow_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRow_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_mutateRow_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRow_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const std::vector<Mutation> * mutations;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRow_result__isset {
|
|
_Hbase_mutateRow_result__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRow_result__isset;
|
|
|
|
class Hbase_mutateRow_result {
|
|
public:
|
|
|
|
Hbase_mutateRow_result() {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRow_result() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRow_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRow_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRow_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRow_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRow_presult__isset {
|
|
_Hbase_mutateRow_presult__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRow_presult__isset;
|
|
|
|
class Hbase_mutateRow_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRow_presult() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRow_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRowTs_args__isset {
|
|
_Hbase_mutateRowTs_args__isset() : tableName(false), row(false), mutations(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool mutations;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_mutateRowTs_args__isset;
|
|
|
|
class Hbase_mutateRowTs_args {
|
|
public:
|
|
|
|
Hbase_mutateRowTs_args() : tableName(), row(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRowTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
std::vector<Mutation> mutations;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_mutateRowTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_mutations(const std::vector<Mutation> & val) {
|
|
mutations = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRowTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(mutations == rhs.mutations))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRowTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRowTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_mutateRowTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRowTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const std::vector<Mutation> * mutations;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRowTs_result__isset {
|
|
_Hbase_mutateRowTs_result__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRowTs_result__isset;
|
|
|
|
class Hbase_mutateRowTs_result {
|
|
public:
|
|
|
|
Hbase_mutateRowTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRowTs_result() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRowTs_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRowTs_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRowTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRowTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRowTs_presult__isset {
|
|
_Hbase_mutateRowTs_presult__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRowTs_presult__isset;
|
|
|
|
class Hbase_mutateRowTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRowTs_presult() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRowTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRows_args__isset {
|
|
_Hbase_mutateRows_args__isset() : tableName(false), rowBatches(false), attributes(false) {}
|
|
bool tableName;
|
|
bool rowBatches;
|
|
bool attributes;
|
|
} _Hbase_mutateRows_args__isset;
|
|
|
|
class Hbase_mutateRows_args {
|
|
public:
|
|
|
|
Hbase_mutateRows_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRows_args() throw() {}
|
|
|
|
Text tableName;
|
|
std::vector<BatchMutation> rowBatches;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_mutateRows_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_rowBatches(const std::vector<BatchMutation> & val) {
|
|
rowBatches = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRows_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(rowBatches == rhs.rowBatches))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRows_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRows_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_mutateRows_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRows_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const std::vector<BatchMutation> * rowBatches;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRows_result__isset {
|
|
_Hbase_mutateRows_result__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRows_result__isset;
|
|
|
|
class Hbase_mutateRows_result {
|
|
public:
|
|
|
|
Hbase_mutateRows_result() {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRows_result() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRows_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRows_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRows_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRows_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRows_presult__isset {
|
|
_Hbase_mutateRows_presult__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRows_presult__isset;
|
|
|
|
class Hbase_mutateRows_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRows_presult() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRows_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRowsTs_args__isset {
|
|
_Hbase_mutateRowsTs_args__isset() : tableName(false), rowBatches(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool rowBatches;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_mutateRowsTs_args__isset;
|
|
|
|
class Hbase_mutateRowsTs_args {
|
|
public:
|
|
|
|
Hbase_mutateRowsTs_args() : tableName(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRowsTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
std::vector<BatchMutation> rowBatches;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_mutateRowsTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_rowBatches(const std::vector<BatchMutation> & val) {
|
|
rowBatches = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRowsTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(rowBatches == rhs.rowBatches))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRowsTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRowsTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_mutateRowsTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRowsTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const std::vector<BatchMutation> * rowBatches;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRowsTs_result__isset {
|
|
_Hbase_mutateRowsTs_result__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRowsTs_result__isset;
|
|
|
|
class Hbase_mutateRowsTs_result {
|
|
public:
|
|
|
|
Hbase_mutateRowsTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_mutateRowsTs_result() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRowsTs_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_mutateRowsTs_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_mutateRowsTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_mutateRowsTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_mutateRowsTs_presult__isset {
|
|
_Hbase_mutateRowsTs_presult__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_mutateRowsTs_presult__isset;
|
|
|
|
class Hbase_mutateRowsTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_mutateRowsTs_presult() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_mutateRowsTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_atomicIncrement_args__isset {
|
|
_Hbase_atomicIncrement_args__isset() : tableName(false), row(false), column(false), value(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool column;
|
|
bool value;
|
|
} _Hbase_atomicIncrement_args__isset;
|
|
|
|
class Hbase_atomicIncrement_args {
|
|
public:
|
|
|
|
Hbase_atomicIncrement_args() : tableName(), row(), column(), value(0) {
|
|
}
|
|
|
|
virtual ~Hbase_atomicIncrement_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
Text column;
|
|
int64_t value;
|
|
|
|
_Hbase_atomicIncrement_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_column(const Text& val) {
|
|
column = val;
|
|
}
|
|
|
|
void __set_value(const int64_t val) {
|
|
value = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_atomicIncrement_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(column == rhs.column))
|
|
return false;
|
|
if (!(value == rhs.value))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_atomicIncrement_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_atomicIncrement_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_atomicIncrement_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_atomicIncrement_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const Text* column;
|
|
const int64_t* value;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_atomicIncrement_result__isset {
|
|
_Hbase_atomicIncrement_result__isset() : success(false), io(false), ia(false) {}
|
|
bool success;
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_atomicIncrement_result__isset;
|
|
|
|
class Hbase_atomicIncrement_result {
|
|
public:
|
|
|
|
Hbase_atomicIncrement_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_atomicIncrement_result() throw() {}
|
|
|
|
int64_t success;
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_atomicIncrement_result__isset __isset;
|
|
|
|
void __set_success(const int64_t val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_atomicIncrement_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_atomicIncrement_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_atomicIncrement_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_atomicIncrement_presult__isset {
|
|
_Hbase_atomicIncrement_presult__isset() : success(false), io(false), ia(false) {}
|
|
bool success;
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_atomicIncrement_presult__isset;
|
|
|
|
class Hbase_atomicIncrement_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_atomicIncrement_presult() throw() {}
|
|
|
|
int64_t* success;
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_atomicIncrement_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAll_args__isset {
|
|
_Hbase_deleteAll_args__isset() : tableName(false), row(false), column(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool column;
|
|
bool attributes;
|
|
} _Hbase_deleteAll_args__isset;
|
|
|
|
class Hbase_deleteAll_args {
|
|
public:
|
|
|
|
Hbase_deleteAll_args() : tableName(), row(), column() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAll_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
Text column;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_deleteAll_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_column(const Text& val) {
|
|
column = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAll_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(column == rhs.column))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAll_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAll_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_deleteAll_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAll_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const Text* column;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAll_result__isset {
|
|
_Hbase_deleteAll_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAll_result__isset;
|
|
|
|
class Hbase_deleteAll_result {
|
|
public:
|
|
|
|
Hbase_deleteAll_result() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAll_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAll_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAll_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAll_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAll_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAll_presult__isset {
|
|
_Hbase_deleteAll_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAll_presult__isset;
|
|
|
|
class Hbase_deleteAll_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAll_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAll_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllTs_args__isset {
|
|
_Hbase_deleteAllTs_args__isset() : tableName(false), row(false), column(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool column;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_deleteAllTs_args__isset;
|
|
|
|
class Hbase_deleteAllTs_args {
|
|
public:
|
|
|
|
Hbase_deleteAllTs_args() : tableName(), row(), column(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAllTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
Text column;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_deleteAllTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_column(const Text& val) {
|
|
column = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAllTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(column == rhs.column))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAllTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAllTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_deleteAllTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAllTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const Text* column;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllTs_result__isset {
|
|
_Hbase_deleteAllTs_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAllTs_result__isset;
|
|
|
|
class Hbase_deleteAllTs_result {
|
|
public:
|
|
|
|
Hbase_deleteAllTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAllTs_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAllTs_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAllTs_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAllTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAllTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllTs_presult__isset {
|
|
_Hbase_deleteAllTs_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAllTs_presult__isset;
|
|
|
|
class Hbase_deleteAllTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAllTs_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAllTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllRow_args__isset {
|
|
_Hbase_deleteAllRow_args__isset() : tableName(false), row(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool attributes;
|
|
} _Hbase_deleteAllRow_args__isset;
|
|
|
|
class Hbase_deleteAllRow_args {
|
|
public:
|
|
|
|
Hbase_deleteAllRow_args() : tableName(), row() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAllRow_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_deleteAllRow_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAllRow_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAllRow_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAllRow_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_deleteAllRow_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAllRow_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllRow_result__isset {
|
|
_Hbase_deleteAllRow_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAllRow_result__isset;
|
|
|
|
class Hbase_deleteAllRow_result {
|
|
public:
|
|
|
|
Hbase_deleteAllRow_result() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAllRow_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAllRow_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAllRow_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAllRow_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAllRow_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllRow_presult__isset {
|
|
_Hbase_deleteAllRow_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAllRow_presult__isset;
|
|
|
|
class Hbase_deleteAllRow_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAllRow_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAllRow_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_increment_args__isset {
|
|
_Hbase_increment_args__isset() : increment(false) {}
|
|
bool increment;
|
|
} _Hbase_increment_args__isset;
|
|
|
|
class Hbase_increment_args {
|
|
public:
|
|
|
|
Hbase_increment_args() {
|
|
}
|
|
|
|
virtual ~Hbase_increment_args() throw() {}
|
|
|
|
TIncrement increment;
|
|
|
|
_Hbase_increment_args__isset __isset;
|
|
|
|
void __set_increment(const TIncrement& val) {
|
|
increment = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_increment_args & rhs) const
|
|
{
|
|
if (!(increment == rhs.increment))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_increment_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_increment_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_increment_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_increment_pargs() throw() {}
|
|
|
|
const TIncrement* increment;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_increment_result__isset {
|
|
_Hbase_increment_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_increment_result__isset;
|
|
|
|
class Hbase_increment_result {
|
|
public:
|
|
|
|
Hbase_increment_result() {
|
|
}
|
|
|
|
virtual ~Hbase_increment_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_increment_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_increment_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_increment_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_increment_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_increment_presult__isset {
|
|
_Hbase_increment_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_increment_presult__isset;
|
|
|
|
class Hbase_increment_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_increment_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_increment_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_incrementRows_args__isset {
|
|
_Hbase_incrementRows_args__isset() : increments(false) {}
|
|
bool increments;
|
|
} _Hbase_incrementRows_args__isset;
|
|
|
|
class Hbase_incrementRows_args {
|
|
public:
|
|
|
|
Hbase_incrementRows_args() {
|
|
}
|
|
|
|
virtual ~Hbase_incrementRows_args() throw() {}
|
|
|
|
std::vector<TIncrement> increments;
|
|
|
|
_Hbase_incrementRows_args__isset __isset;
|
|
|
|
void __set_increments(const std::vector<TIncrement> & val) {
|
|
increments = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_incrementRows_args & rhs) const
|
|
{
|
|
if (!(increments == rhs.increments))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_incrementRows_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_incrementRows_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_incrementRows_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_incrementRows_pargs() throw() {}
|
|
|
|
const std::vector<TIncrement> * increments;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_incrementRows_result__isset {
|
|
_Hbase_incrementRows_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_incrementRows_result__isset;
|
|
|
|
class Hbase_incrementRows_result {
|
|
public:
|
|
|
|
Hbase_incrementRows_result() {
|
|
}
|
|
|
|
virtual ~Hbase_incrementRows_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_incrementRows_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_incrementRows_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_incrementRows_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_incrementRows_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_incrementRows_presult__isset {
|
|
_Hbase_incrementRows_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_incrementRows_presult__isset;
|
|
|
|
class Hbase_incrementRows_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_incrementRows_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_incrementRows_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllRowTs_args__isset {
|
|
_Hbase_deleteAllRowTs_args__isset() : tableName(false), row(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_deleteAllRowTs_args__isset;
|
|
|
|
class Hbase_deleteAllRowTs_args {
|
|
public:
|
|
|
|
Hbase_deleteAllRowTs_args() : tableName(), row(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAllRowTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_deleteAllRowTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAllRowTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAllRowTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAllRowTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_deleteAllRowTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAllRowTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllRowTs_result__isset {
|
|
_Hbase_deleteAllRowTs_result__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAllRowTs_result__isset;
|
|
|
|
class Hbase_deleteAllRowTs_result {
|
|
public:
|
|
|
|
Hbase_deleteAllRowTs_result() {
|
|
}
|
|
|
|
virtual ~Hbase_deleteAllRowTs_result() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAllRowTs_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_deleteAllRowTs_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_deleteAllRowTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_deleteAllRowTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_deleteAllRowTs_presult__isset {
|
|
_Hbase_deleteAllRowTs_presult__isset() : io(false) {}
|
|
bool io;
|
|
} _Hbase_deleteAllRowTs_presult__isset;
|
|
|
|
class Hbase_deleteAllRowTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_deleteAllRowTs_presult() throw() {}
|
|
|
|
IOError io;
|
|
|
|
_Hbase_deleteAllRowTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithScan_args__isset {
|
|
_Hbase_scannerOpenWithScan_args__isset() : tableName(false), scan(false), attributes(false) {}
|
|
bool tableName;
|
|
bool scan;
|
|
bool attributes;
|
|
} _Hbase_scannerOpenWithScan_args__isset;
|
|
|
|
class Hbase_scannerOpenWithScan_args {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithScan_args() : tableName() {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithScan_args() throw() {}
|
|
|
|
Text tableName;
|
|
TScan scan;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_scannerOpenWithScan_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_scan(const TScan& val) {
|
|
scan = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithScan_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(scan == rhs.scan))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithScan_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithScan_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerOpenWithScan_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithScan_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const TScan* scan;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithScan_result__isset {
|
|
_Hbase_scannerOpenWithScan_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithScan_result__isset;
|
|
|
|
class Hbase_scannerOpenWithScan_result {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithScan_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithScan_result() throw() {}
|
|
|
|
ScannerID success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithScan_result__isset __isset;
|
|
|
|
void __set_success(const ScannerID val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithScan_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithScan_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithScan_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithScan_presult__isset {
|
|
_Hbase_scannerOpenWithScan_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithScan_presult__isset;
|
|
|
|
class Hbase_scannerOpenWithScan_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithScan_presult() throw() {}
|
|
|
|
ScannerID* success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithScan_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpen_args__isset {
|
|
_Hbase_scannerOpen_args__isset() : tableName(false), startRow(false), columns(false), attributes(false) {}
|
|
bool tableName;
|
|
bool startRow;
|
|
bool columns;
|
|
bool attributes;
|
|
} _Hbase_scannerOpen_args__isset;
|
|
|
|
class Hbase_scannerOpen_args {
|
|
public:
|
|
|
|
Hbase_scannerOpen_args() : tableName(), startRow() {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpen_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text startRow;
|
|
std::vector<Text> columns;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_scannerOpen_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_startRow(const Text& val) {
|
|
startRow = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpen_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(startRow == rhs.startRow))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpen_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpen_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerOpen_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpen_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* startRow;
|
|
const std::vector<Text> * columns;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpen_result__isset {
|
|
_Hbase_scannerOpen_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpen_result__isset;
|
|
|
|
class Hbase_scannerOpen_result {
|
|
public:
|
|
|
|
Hbase_scannerOpen_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpen_result() throw() {}
|
|
|
|
ScannerID success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpen_result__isset __isset;
|
|
|
|
void __set_success(const ScannerID val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpen_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpen_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpen_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpen_presult__isset {
|
|
_Hbase_scannerOpen_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpen_presult__isset;
|
|
|
|
class Hbase_scannerOpen_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpen_presult() throw() {}
|
|
|
|
ScannerID* success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpen_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithStop_args__isset {
|
|
_Hbase_scannerOpenWithStop_args__isset() : tableName(false), startRow(false), stopRow(false), columns(false), attributes(false) {}
|
|
bool tableName;
|
|
bool startRow;
|
|
bool stopRow;
|
|
bool columns;
|
|
bool attributes;
|
|
} _Hbase_scannerOpenWithStop_args__isset;
|
|
|
|
class Hbase_scannerOpenWithStop_args {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithStop_args() : tableName(), startRow(), stopRow() {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithStop_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text startRow;
|
|
Text stopRow;
|
|
std::vector<Text> columns;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_scannerOpenWithStop_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_startRow(const Text& val) {
|
|
startRow = val;
|
|
}
|
|
|
|
void __set_stopRow(const Text& val) {
|
|
stopRow = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithStop_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(startRow == rhs.startRow))
|
|
return false;
|
|
if (!(stopRow == rhs.stopRow))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithStop_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithStop_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerOpenWithStop_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithStop_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* startRow;
|
|
const Text* stopRow;
|
|
const std::vector<Text> * columns;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithStop_result__isset {
|
|
_Hbase_scannerOpenWithStop_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithStop_result__isset;
|
|
|
|
class Hbase_scannerOpenWithStop_result {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithStop_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithStop_result() throw() {}
|
|
|
|
ScannerID success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithStop_result__isset __isset;
|
|
|
|
void __set_success(const ScannerID val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithStop_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithStop_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithStop_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithStop_presult__isset {
|
|
_Hbase_scannerOpenWithStop_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithStop_presult__isset;
|
|
|
|
class Hbase_scannerOpenWithStop_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithStop_presult() throw() {}
|
|
|
|
ScannerID* success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithStop_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithPrefix_args__isset {
|
|
_Hbase_scannerOpenWithPrefix_args__isset() : tableName(false), startAndPrefix(false), columns(false), attributes(false) {}
|
|
bool tableName;
|
|
bool startAndPrefix;
|
|
bool columns;
|
|
bool attributes;
|
|
} _Hbase_scannerOpenWithPrefix_args__isset;
|
|
|
|
class Hbase_scannerOpenWithPrefix_args {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithPrefix_args() : tableName(), startAndPrefix() {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithPrefix_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text startAndPrefix;
|
|
std::vector<Text> columns;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_scannerOpenWithPrefix_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_startAndPrefix(const Text& val) {
|
|
startAndPrefix = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithPrefix_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(startAndPrefix == rhs.startAndPrefix))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithPrefix_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithPrefix_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerOpenWithPrefix_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithPrefix_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* startAndPrefix;
|
|
const std::vector<Text> * columns;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithPrefix_result__isset {
|
|
_Hbase_scannerOpenWithPrefix_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithPrefix_result__isset;
|
|
|
|
class Hbase_scannerOpenWithPrefix_result {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithPrefix_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithPrefix_result() throw() {}
|
|
|
|
ScannerID success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithPrefix_result__isset __isset;
|
|
|
|
void __set_success(const ScannerID val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithPrefix_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithPrefix_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithPrefix_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithPrefix_presult__isset {
|
|
_Hbase_scannerOpenWithPrefix_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithPrefix_presult__isset;
|
|
|
|
class Hbase_scannerOpenWithPrefix_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithPrefix_presult() throw() {}
|
|
|
|
ScannerID* success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithPrefix_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenTs_args__isset {
|
|
_Hbase_scannerOpenTs_args__isset() : tableName(false), startRow(false), columns(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool startRow;
|
|
bool columns;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_scannerOpenTs_args__isset;
|
|
|
|
class Hbase_scannerOpenTs_args {
|
|
public:
|
|
|
|
Hbase_scannerOpenTs_args() : tableName(), startRow(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text startRow;
|
|
std::vector<Text> columns;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_scannerOpenTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_startRow(const Text& val) {
|
|
startRow = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(startRow == rhs.startRow))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerOpenTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* startRow;
|
|
const std::vector<Text> * columns;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenTs_result__isset {
|
|
_Hbase_scannerOpenTs_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenTs_result__isset;
|
|
|
|
class Hbase_scannerOpenTs_result {
|
|
public:
|
|
|
|
Hbase_scannerOpenTs_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenTs_result() throw() {}
|
|
|
|
ScannerID success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenTs_result__isset __isset;
|
|
|
|
void __set_success(const ScannerID val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenTs_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenTs_presult__isset {
|
|
_Hbase_scannerOpenTs_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenTs_presult__isset;
|
|
|
|
class Hbase_scannerOpenTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenTs_presult() throw() {}
|
|
|
|
ScannerID* success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithStopTs_args__isset {
|
|
_Hbase_scannerOpenWithStopTs_args__isset() : tableName(false), startRow(false), stopRow(false), columns(false), timestamp(false), attributes(false) {}
|
|
bool tableName;
|
|
bool startRow;
|
|
bool stopRow;
|
|
bool columns;
|
|
bool timestamp;
|
|
bool attributes;
|
|
} _Hbase_scannerOpenWithStopTs_args__isset;
|
|
|
|
class Hbase_scannerOpenWithStopTs_args {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithStopTs_args() : tableName(), startRow(), stopRow(), timestamp(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithStopTs_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text startRow;
|
|
Text stopRow;
|
|
std::vector<Text> columns;
|
|
int64_t timestamp;
|
|
std::map<Text, Text> attributes;
|
|
|
|
_Hbase_scannerOpenWithStopTs_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_startRow(const Text& val) {
|
|
startRow = val;
|
|
}
|
|
|
|
void __set_stopRow(const Text& val) {
|
|
stopRow = val;
|
|
}
|
|
|
|
void __set_columns(const std::vector<Text> & val) {
|
|
columns = val;
|
|
}
|
|
|
|
void __set_timestamp(const int64_t val) {
|
|
timestamp = val;
|
|
}
|
|
|
|
void __set_attributes(const std::map<Text, Text> & val) {
|
|
attributes = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithStopTs_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(startRow == rhs.startRow))
|
|
return false;
|
|
if (!(stopRow == rhs.stopRow))
|
|
return false;
|
|
if (!(columns == rhs.columns))
|
|
return false;
|
|
if (!(timestamp == rhs.timestamp))
|
|
return false;
|
|
if (!(attributes == rhs.attributes))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithStopTs_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithStopTs_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerOpenWithStopTs_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithStopTs_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* startRow;
|
|
const Text* stopRow;
|
|
const std::vector<Text> * columns;
|
|
const int64_t* timestamp;
|
|
const std::map<Text, Text> * attributes;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithStopTs_result__isset {
|
|
_Hbase_scannerOpenWithStopTs_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithStopTs_result__isset;
|
|
|
|
class Hbase_scannerOpenWithStopTs_result {
|
|
public:
|
|
|
|
Hbase_scannerOpenWithStopTs_result() : success(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerOpenWithStopTs_result() throw() {}
|
|
|
|
ScannerID success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithStopTs_result__isset __isset;
|
|
|
|
void __set_success(const ScannerID val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerOpenWithStopTs_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerOpenWithStopTs_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerOpenWithStopTs_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerOpenWithStopTs_presult__isset {
|
|
_Hbase_scannerOpenWithStopTs_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_scannerOpenWithStopTs_presult__isset;
|
|
|
|
class Hbase_scannerOpenWithStopTs_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerOpenWithStopTs_presult() throw() {}
|
|
|
|
ScannerID* success;
|
|
IOError io;
|
|
|
|
_Hbase_scannerOpenWithStopTs_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerGet_args__isset {
|
|
_Hbase_scannerGet_args__isset() : id(false) {}
|
|
bool id;
|
|
} _Hbase_scannerGet_args__isset;
|
|
|
|
class Hbase_scannerGet_args {
|
|
public:
|
|
|
|
Hbase_scannerGet_args() : id(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerGet_args() throw() {}
|
|
|
|
ScannerID id;
|
|
|
|
_Hbase_scannerGet_args__isset __isset;
|
|
|
|
void __set_id(const ScannerID val) {
|
|
id = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerGet_args & rhs) const
|
|
{
|
|
if (!(id == rhs.id))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerGet_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerGet_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerGet_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerGet_pargs() throw() {}
|
|
|
|
const ScannerID* id;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerGet_result__isset {
|
|
_Hbase_scannerGet_result__isset() : success(false), io(false), ia(false) {}
|
|
bool success;
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_scannerGet_result__isset;
|
|
|
|
class Hbase_scannerGet_result {
|
|
public:
|
|
|
|
Hbase_scannerGet_result() {
|
|
}
|
|
|
|
virtual ~Hbase_scannerGet_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_scannerGet_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerGet_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerGet_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerGet_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerGet_presult__isset {
|
|
_Hbase_scannerGet_presult__isset() : success(false), io(false), ia(false) {}
|
|
bool success;
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_scannerGet_presult__isset;
|
|
|
|
class Hbase_scannerGet_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerGet_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_scannerGet_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerGetList_args__isset {
|
|
_Hbase_scannerGetList_args__isset() : id(false), nbRows(false) {}
|
|
bool id;
|
|
bool nbRows;
|
|
} _Hbase_scannerGetList_args__isset;
|
|
|
|
class Hbase_scannerGetList_args {
|
|
public:
|
|
|
|
Hbase_scannerGetList_args() : id(0), nbRows(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerGetList_args() throw() {}
|
|
|
|
ScannerID id;
|
|
int32_t nbRows;
|
|
|
|
_Hbase_scannerGetList_args__isset __isset;
|
|
|
|
void __set_id(const ScannerID val) {
|
|
id = val;
|
|
}
|
|
|
|
void __set_nbRows(const int32_t val) {
|
|
nbRows = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerGetList_args & rhs) const
|
|
{
|
|
if (!(id == rhs.id))
|
|
return false;
|
|
if (!(nbRows == rhs.nbRows))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerGetList_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerGetList_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerGetList_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerGetList_pargs() throw() {}
|
|
|
|
const ScannerID* id;
|
|
const int32_t* nbRows;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerGetList_result__isset {
|
|
_Hbase_scannerGetList_result__isset() : success(false), io(false), ia(false) {}
|
|
bool success;
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_scannerGetList_result__isset;
|
|
|
|
class Hbase_scannerGetList_result {
|
|
public:
|
|
|
|
Hbase_scannerGetList_result() {
|
|
}
|
|
|
|
virtual ~Hbase_scannerGetList_result() throw() {}
|
|
|
|
std::vector<TRowResult> success;
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_scannerGetList_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TRowResult> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerGetList_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerGetList_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerGetList_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerGetList_presult__isset {
|
|
_Hbase_scannerGetList_presult__isset() : success(false), io(false), ia(false) {}
|
|
bool success;
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_scannerGetList_presult__isset;
|
|
|
|
class Hbase_scannerGetList_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerGetList_presult() throw() {}
|
|
|
|
std::vector<TRowResult> * success;
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_scannerGetList_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerClose_args__isset {
|
|
_Hbase_scannerClose_args__isset() : id(false) {}
|
|
bool id;
|
|
} _Hbase_scannerClose_args__isset;
|
|
|
|
class Hbase_scannerClose_args {
|
|
public:
|
|
|
|
Hbase_scannerClose_args() : id(0) {
|
|
}
|
|
|
|
virtual ~Hbase_scannerClose_args() throw() {}
|
|
|
|
ScannerID id;
|
|
|
|
_Hbase_scannerClose_args__isset __isset;
|
|
|
|
void __set_id(const ScannerID val) {
|
|
id = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerClose_args & rhs) const
|
|
{
|
|
if (!(id == rhs.id))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerClose_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerClose_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_scannerClose_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerClose_pargs() throw() {}
|
|
|
|
const ScannerID* id;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerClose_result__isset {
|
|
_Hbase_scannerClose_result__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_scannerClose_result__isset;
|
|
|
|
class Hbase_scannerClose_result {
|
|
public:
|
|
|
|
Hbase_scannerClose_result() {
|
|
}
|
|
|
|
virtual ~Hbase_scannerClose_result() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_scannerClose_result__isset __isset;
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
void __set_ia(const IllegalArgument& val) {
|
|
ia = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_scannerClose_result & rhs) const
|
|
{
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
if (!(ia == rhs.ia))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_scannerClose_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_scannerClose_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_scannerClose_presult__isset {
|
|
_Hbase_scannerClose_presult__isset() : io(false), ia(false) {}
|
|
bool io;
|
|
bool ia;
|
|
} _Hbase_scannerClose_presult__isset;
|
|
|
|
class Hbase_scannerClose_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_scannerClose_presult() throw() {}
|
|
|
|
IOError io;
|
|
IllegalArgument ia;
|
|
|
|
_Hbase_scannerClose_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowOrBefore_args__isset {
|
|
_Hbase_getRowOrBefore_args__isset() : tableName(false), row(false), family(false) {}
|
|
bool tableName;
|
|
bool row;
|
|
bool family;
|
|
} _Hbase_getRowOrBefore_args__isset;
|
|
|
|
class Hbase_getRowOrBefore_args {
|
|
public:
|
|
|
|
Hbase_getRowOrBefore_args() : tableName(), row(), family() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowOrBefore_args() throw() {}
|
|
|
|
Text tableName;
|
|
Text row;
|
|
Text family;
|
|
|
|
_Hbase_getRowOrBefore_args__isset __isset;
|
|
|
|
void __set_tableName(const Text& val) {
|
|
tableName = val;
|
|
}
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
void __set_family(const Text& val) {
|
|
family = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowOrBefore_args & rhs) const
|
|
{
|
|
if (!(tableName == rhs.tableName))
|
|
return false;
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
if (!(family == rhs.family))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowOrBefore_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowOrBefore_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRowOrBefore_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowOrBefore_pargs() throw() {}
|
|
|
|
const Text* tableName;
|
|
const Text* row;
|
|
const Text* family;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowOrBefore_result__isset {
|
|
_Hbase_getRowOrBefore_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowOrBefore_result__isset;
|
|
|
|
class Hbase_getRowOrBefore_result {
|
|
public:
|
|
|
|
Hbase_getRowOrBefore_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRowOrBefore_result() throw() {}
|
|
|
|
std::vector<TCell> success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowOrBefore_result__isset __isset;
|
|
|
|
void __set_success(const std::vector<TCell> & val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRowOrBefore_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRowOrBefore_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRowOrBefore_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRowOrBefore_presult__isset {
|
|
_Hbase_getRowOrBefore_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRowOrBefore_presult__isset;
|
|
|
|
class Hbase_getRowOrBefore_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRowOrBefore_presult() throw() {}
|
|
|
|
std::vector<TCell> * success;
|
|
IOError io;
|
|
|
|
_Hbase_getRowOrBefore_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRegionInfo_args__isset {
|
|
_Hbase_getRegionInfo_args__isset() : row(false) {}
|
|
bool row;
|
|
} _Hbase_getRegionInfo_args__isset;
|
|
|
|
class Hbase_getRegionInfo_args {
|
|
public:
|
|
|
|
Hbase_getRegionInfo_args() : row() {
|
|
}
|
|
|
|
virtual ~Hbase_getRegionInfo_args() throw() {}
|
|
|
|
Text row;
|
|
|
|
_Hbase_getRegionInfo_args__isset __isset;
|
|
|
|
void __set_row(const Text& val) {
|
|
row = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRegionInfo_args & rhs) const
|
|
{
|
|
if (!(row == rhs.row))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRegionInfo_args &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRegionInfo_args & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
|
|
class Hbase_getRegionInfo_pargs {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRegionInfo_pargs() throw() {}
|
|
|
|
const Text* row;
|
|
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRegionInfo_result__isset {
|
|
_Hbase_getRegionInfo_result__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRegionInfo_result__isset;
|
|
|
|
class Hbase_getRegionInfo_result {
|
|
public:
|
|
|
|
Hbase_getRegionInfo_result() {
|
|
}
|
|
|
|
virtual ~Hbase_getRegionInfo_result() throw() {}
|
|
|
|
TRegionInfo success;
|
|
IOError io;
|
|
|
|
_Hbase_getRegionInfo_result__isset __isset;
|
|
|
|
void __set_success(const TRegionInfo& val) {
|
|
success = val;
|
|
}
|
|
|
|
void __set_io(const IOError& val) {
|
|
io = val;
|
|
}
|
|
|
|
bool operator == (const Hbase_getRegionInfo_result & rhs) const
|
|
{
|
|
if (!(success == rhs.success))
|
|
return false;
|
|
if (!(io == rhs.io))
|
|
return false;
|
|
return true;
|
|
}
|
|
bool operator != (const Hbase_getRegionInfo_result &rhs) const {
|
|
return !(*this == rhs);
|
|
}
|
|
|
|
bool operator < (const Hbase_getRegionInfo_result & ) const;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
|
|
|
|
};
|
|
|
|
typedef struct _Hbase_getRegionInfo_presult__isset {
|
|
_Hbase_getRegionInfo_presult__isset() : success(false), io(false) {}
|
|
bool success;
|
|
bool io;
|
|
} _Hbase_getRegionInfo_presult__isset;
|
|
|
|
class Hbase_getRegionInfo_presult {
|
|
public:
|
|
|
|
|
|
virtual ~Hbase_getRegionInfo_presult() throw() {}
|
|
|
|
TRegionInfo* success;
|
|
IOError io;
|
|
|
|
_Hbase_getRegionInfo_presult__isset __isset;
|
|
|
|
uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
|
|
|
|
};
|
|
|
|
class HbaseClient : virtual public HbaseIf {
|
|
public:
|
|
HbaseClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) :
|
|
piprot_(prot),
|
|
poprot_(prot) {
|
|
iprot_ = prot.get();
|
|
oprot_ = prot.get();
|
|
}
|
|
HbaseClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) :
|
|
piprot_(iprot),
|
|
poprot_(oprot) {
|
|
iprot_ = iprot.get();
|
|
oprot_ = oprot.get();
|
|
}
|
|
boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() {
|
|
return piprot_;
|
|
}
|
|
boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getOutputProtocol() {
|
|
return poprot_;
|
|
}
|
|
void enableTable(const Bytes& tableName);
|
|
void send_enableTable(const Bytes& tableName);
|
|
void recv_enableTable();
|
|
void disableTable(const Bytes& tableName);
|
|
void send_disableTable(const Bytes& tableName);
|
|
void recv_disableTable();
|
|
bool isTableEnabled(const Bytes& tableName);
|
|
void send_isTableEnabled(const Bytes& tableName);
|
|
bool recv_isTableEnabled();
|
|
void compact(const Bytes& tableNameOrRegionName);
|
|
void send_compact(const Bytes& tableNameOrRegionName);
|
|
void recv_compact();
|
|
void majorCompact(const Bytes& tableNameOrRegionName);
|
|
void send_majorCompact(const Bytes& tableNameOrRegionName);
|
|
void recv_majorCompact();
|
|
void getTableNames(std::vector<Text> & _return);
|
|
void send_getTableNames();
|
|
void recv_getTableNames(std::vector<Text> & _return);
|
|
void getColumnDescriptors(std::map<Text, ColumnDescriptor> & _return, const Text& tableName);
|
|
void send_getColumnDescriptors(const Text& tableName);
|
|
void recv_getColumnDescriptors(std::map<Text, ColumnDescriptor> & _return);
|
|
void getTableRegions(std::vector<TRegionInfo> & _return, const Text& tableName);
|
|
void send_getTableRegions(const Text& tableName);
|
|
void recv_getTableRegions(std::vector<TRegionInfo> & _return);
|
|
void createTable(const Text& tableName, const std::vector<ColumnDescriptor> & columnFamilies);
|
|
void send_createTable(const Text& tableName, const std::vector<ColumnDescriptor> & columnFamilies);
|
|
void recv_createTable();
|
|
void deleteTable(const Text& tableName);
|
|
void send_deleteTable(const Text& tableName);
|
|
void recv_deleteTable();
|
|
void get(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes);
|
|
void send_get(const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes);
|
|
void recv_get(std::vector<TCell> & _return);
|
|
void getVer(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int32_t numVersions, const std::map<Text, Text> & attributes);
|
|
void send_getVer(const Text& tableName, const Text& row, const Text& column, const int32_t numVersions, const std::map<Text, Text> & attributes);
|
|
void recv_getVer(std::vector<TCell> & _return);
|
|
void getVerTs(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const int32_t numVersions, const std::map<Text, Text> & attributes);
|
|
void send_getVerTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const int32_t numVersions, const std::map<Text, Text> & attributes);
|
|
void recv_getVerTs(std::vector<TCell> & _return);
|
|
void getRow(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::map<Text, Text> & attributes);
|
|
void send_getRow(const Text& tableName, const Text& row, const std::map<Text, Text> & attributes);
|
|
void recv_getRow(std::vector<TRowResult> & _return);
|
|
void getRowWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
void send_getRowWithColumns(const Text& tableName, const Text& row, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
void recv_getRowWithColumns(std::vector<TRowResult> & _return);
|
|
void getRowTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_getRowTs(const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_getRowTs(std::vector<TRowResult> & _return);
|
|
void getRowWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_getRowWithColumnsTs(const Text& tableName, const Text& row, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_getRowWithColumnsTs(std::vector<TRowResult> & _return);
|
|
void getRows(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::map<Text, Text> & attributes);
|
|
void send_getRows(const Text& tableName, const std::vector<Text> & rows, const std::map<Text, Text> & attributes);
|
|
void recv_getRows(std::vector<TRowResult> & _return);
|
|
void getRowsWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
void send_getRowsWithColumns(const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
void recv_getRowsWithColumns(std::vector<TRowResult> & _return);
|
|
void getRowsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_getRowsTs(const Text& tableName, const std::vector<Text> & rows, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_getRowsTs(std::vector<TRowResult> & _return);
|
|
void getRowsWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_getRowsWithColumnsTs(const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_getRowsWithColumnsTs(std::vector<TRowResult> & _return);
|
|
void mutateRow(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const std::map<Text, Text> & attributes);
|
|
void send_mutateRow(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const std::map<Text, Text> & attributes);
|
|
void recv_mutateRow();
|
|
void mutateRowTs(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_mutateRowTs(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_mutateRowTs();
|
|
void mutateRows(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const std::map<Text, Text> & attributes);
|
|
void send_mutateRows(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const std::map<Text, Text> & attributes);
|
|
void recv_mutateRows();
|
|
void mutateRowsTs(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_mutateRowsTs(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_mutateRowsTs();
|
|
int64_t atomicIncrement(const Text& tableName, const Text& row, const Text& column, const int64_t value);
|
|
void send_atomicIncrement(const Text& tableName, const Text& row, const Text& column, const int64_t value);
|
|
int64_t recv_atomicIncrement();
|
|
void deleteAll(const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes);
|
|
void send_deleteAll(const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes);
|
|
void recv_deleteAll();
|
|
void deleteAllTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_deleteAllTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_deleteAllTs();
|
|
void deleteAllRow(const Text& tableName, const Text& row, const std::map<Text, Text> & attributes);
|
|
void send_deleteAllRow(const Text& tableName, const Text& row, const std::map<Text, Text> & attributes);
|
|
void recv_deleteAllRow();
|
|
void increment(const TIncrement& increment);
|
|
void send_increment(const TIncrement& increment);
|
|
void recv_increment();
|
|
void incrementRows(const std::vector<TIncrement> & increments);
|
|
void send_incrementRows(const std::vector<TIncrement> & increments);
|
|
void recv_incrementRows();
|
|
void deleteAllRowTs(const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_deleteAllRowTs(const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void recv_deleteAllRowTs();
|
|
ScannerID scannerOpenWithScan(const Text& tableName, const TScan& scan, const std::map<Text, Text> & attributes);
|
|
void send_scannerOpenWithScan(const Text& tableName, const TScan& scan, const std::map<Text, Text> & attributes);
|
|
ScannerID recv_scannerOpenWithScan();
|
|
ScannerID scannerOpen(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
void send_scannerOpen(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
ScannerID recv_scannerOpen();
|
|
ScannerID scannerOpenWithStop(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
void send_scannerOpenWithStop(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
ScannerID recv_scannerOpenWithStop();
|
|
ScannerID scannerOpenWithPrefix(const Text& tableName, const Text& startAndPrefix, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
void send_scannerOpenWithPrefix(const Text& tableName, const Text& startAndPrefix, const std::vector<Text> & columns, const std::map<Text, Text> & attributes);
|
|
ScannerID recv_scannerOpenWithPrefix();
|
|
ScannerID scannerOpenTs(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_scannerOpenTs(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
ScannerID recv_scannerOpenTs();
|
|
ScannerID scannerOpenWithStopTs(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
void send_scannerOpenWithStopTs(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes);
|
|
ScannerID recv_scannerOpenWithStopTs();
|
|
void scannerGet(std::vector<TRowResult> & _return, const ScannerID id);
|
|
void send_scannerGet(const ScannerID id);
|
|
void recv_scannerGet(std::vector<TRowResult> & _return);
|
|
void scannerGetList(std::vector<TRowResult> & _return, const ScannerID id, const int32_t nbRows);
|
|
void send_scannerGetList(const ScannerID id, const int32_t nbRows);
|
|
void recv_scannerGetList(std::vector<TRowResult> & _return);
|
|
void scannerClose(const ScannerID id);
|
|
void send_scannerClose(const ScannerID id);
|
|
void recv_scannerClose();
|
|
void getRowOrBefore(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& family);
|
|
void send_getRowOrBefore(const Text& tableName, const Text& row, const Text& family);
|
|
void recv_getRowOrBefore(std::vector<TCell> & _return);
|
|
void getRegionInfo(TRegionInfo& _return, const Text& row);
|
|
void send_getRegionInfo(const Text& row);
|
|
void recv_getRegionInfo(TRegionInfo& _return);
|
|
protected:
|
|
boost::shared_ptr< ::apache::thrift::protocol::TProtocol> piprot_;
|
|
boost::shared_ptr< ::apache::thrift::protocol::TProtocol> poprot_;
|
|
::apache::thrift::protocol::TProtocol* iprot_;
|
|
::apache::thrift::protocol::TProtocol* oprot_;
|
|
};
|
|
|
|
class HbaseProcessor : public ::apache::thrift::TDispatchProcessor {
|
|
protected:
|
|
boost::shared_ptr<HbaseIf> iface_;
|
|
virtual bool dispatchCall(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, const std::string& fname, int32_t seqid, void* callContext);
|
|
private:
|
|
typedef void (HbaseProcessor::*ProcessFunction)(int32_t, ::apache::thrift::protocol::TProtocol*, ::apache::thrift::protocol::TProtocol*, void*);
|
|
typedef std::map<std::string, ProcessFunction> ProcessMap;
|
|
ProcessMap processMap_;
|
|
void process_enableTable(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_isTableEnabled(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_majorCompact(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_getColumnDescriptors(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_createTable(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_get(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_getRow(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_getRowTs(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_getRows(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_getRowsTs(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_mutateRow(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_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_atomicIncrement(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_deleteAllTs(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_increment(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
|
|
void process_incrementRows(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_scannerOpenWithScan(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_scannerOpenWithStop(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_scannerOpenTs(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);
|
|
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_scannerClose(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_getRegionInfo(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
|
|
public:
|
|
HbaseProcessor(boost::shared_ptr<HbaseIf> iface) :
|
|
iface_(iface) {
|
|
processMap_["enableTable"] = &HbaseProcessor::process_enableTable;
|
|
processMap_["disableTable"] = &HbaseProcessor::process_disableTable;
|
|
processMap_["isTableEnabled"] = &HbaseProcessor::process_isTableEnabled;
|
|
processMap_["compact"] = &HbaseProcessor::process_compact;
|
|
processMap_["majorCompact"] = &HbaseProcessor::process_majorCompact;
|
|
processMap_["getTableNames"] = &HbaseProcessor::process_getTableNames;
|
|
processMap_["getColumnDescriptors"] = &HbaseProcessor::process_getColumnDescriptors;
|
|
processMap_["getTableRegions"] = &HbaseProcessor::process_getTableRegions;
|
|
processMap_["createTable"] = &HbaseProcessor::process_createTable;
|
|
processMap_["deleteTable"] = &HbaseProcessor::process_deleteTable;
|
|
processMap_["get"] = &HbaseProcessor::process_get;
|
|
processMap_["getVer"] = &HbaseProcessor::process_getVer;
|
|
processMap_["getVerTs"] = &HbaseProcessor::process_getVerTs;
|
|
processMap_["getRow"] = &HbaseProcessor::process_getRow;
|
|
processMap_["getRowWithColumns"] = &HbaseProcessor::process_getRowWithColumns;
|
|
processMap_["getRowTs"] = &HbaseProcessor::process_getRowTs;
|
|
processMap_["getRowWithColumnsTs"] = &HbaseProcessor::process_getRowWithColumnsTs;
|
|
processMap_["getRows"] = &HbaseProcessor::process_getRows;
|
|
processMap_["getRowsWithColumns"] = &HbaseProcessor::process_getRowsWithColumns;
|
|
processMap_["getRowsTs"] = &HbaseProcessor::process_getRowsTs;
|
|
processMap_["getRowsWithColumnsTs"] = &HbaseProcessor::process_getRowsWithColumnsTs;
|
|
processMap_["mutateRow"] = &HbaseProcessor::process_mutateRow;
|
|
processMap_["mutateRowTs"] = &HbaseProcessor::process_mutateRowTs;
|
|
processMap_["mutateRows"] = &HbaseProcessor::process_mutateRows;
|
|
processMap_["mutateRowsTs"] = &HbaseProcessor::process_mutateRowsTs;
|
|
processMap_["atomicIncrement"] = &HbaseProcessor::process_atomicIncrement;
|
|
processMap_["deleteAll"] = &HbaseProcessor::process_deleteAll;
|
|
processMap_["deleteAllTs"] = &HbaseProcessor::process_deleteAllTs;
|
|
processMap_["deleteAllRow"] = &HbaseProcessor::process_deleteAllRow;
|
|
processMap_["increment"] = &HbaseProcessor::process_increment;
|
|
processMap_["incrementRows"] = &HbaseProcessor::process_incrementRows;
|
|
processMap_["deleteAllRowTs"] = &HbaseProcessor::process_deleteAllRowTs;
|
|
processMap_["scannerOpenWithScan"] = &HbaseProcessor::process_scannerOpenWithScan;
|
|
processMap_["scannerOpen"] = &HbaseProcessor::process_scannerOpen;
|
|
processMap_["scannerOpenWithStop"] = &HbaseProcessor::process_scannerOpenWithStop;
|
|
processMap_["scannerOpenWithPrefix"] = &HbaseProcessor::process_scannerOpenWithPrefix;
|
|
processMap_["scannerOpenTs"] = &HbaseProcessor::process_scannerOpenTs;
|
|
processMap_["scannerOpenWithStopTs"] = &HbaseProcessor::process_scannerOpenWithStopTs;
|
|
processMap_["scannerGet"] = &HbaseProcessor::process_scannerGet;
|
|
processMap_["scannerGetList"] = &HbaseProcessor::process_scannerGetList;
|
|
processMap_["scannerClose"] = &HbaseProcessor::process_scannerClose;
|
|
processMap_["getRowOrBefore"] = &HbaseProcessor::process_getRowOrBefore;
|
|
processMap_["getRegionInfo"] = &HbaseProcessor::process_getRegionInfo;
|
|
}
|
|
|
|
virtual ~HbaseProcessor() {}
|
|
};
|
|
|
|
class HbaseProcessorFactory : public ::apache::thrift::TProcessorFactory {
|
|
public:
|
|
HbaseProcessorFactory(const ::boost::shared_ptr< HbaseIfFactory >& handlerFactory) :
|
|
handlerFactory_(handlerFactory) {}
|
|
|
|
::boost::shared_ptr< ::apache::thrift::TProcessor > getProcessor(const ::apache::thrift::TConnectionInfo& connInfo);
|
|
|
|
protected:
|
|
::boost::shared_ptr< HbaseIfFactory > handlerFactory_;
|
|
};
|
|
|
|
class HbaseMultiface : virtual public HbaseIf {
|
|
public:
|
|
HbaseMultiface(std::vector<boost::shared_ptr<HbaseIf> >& ifaces) : ifaces_(ifaces) {
|
|
}
|
|
virtual ~HbaseMultiface() {}
|
|
protected:
|
|
std::vector<boost::shared_ptr<HbaseIf> > ifaces_;
|
|
HbaseMultiface() {}
|
|
void add(boost::shared_ptr<HbaseIf> iface) {
|
|
ifaces_.push_back(iface);
|
|
}
|
|
public:
|
|
void enableTable(const Bytes& tableName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->enableTable(tableName);
|
|
}
|
|
ifaces_[i]->enableTable(tableName);
|
|
}
|
|
|
|
void disableTable(const Bytes& tableName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->disableTable(tableName);
|
|
}
|
|
ifaces_[i]->disableTable(tableName);
|
|
}
|
|
|
|
bool isTableEnabled(const Bytes& tableName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->isTableEnabled(tableName);
|
|
}
|
|
return ifaces_[i]->isTableEnabled(tableName);
|
|
}
|
|
|
|
void compact(const Bytes& tableNameOrRegionName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->compact(tableNameOrRegionName);
|
|
}
|
|
ifaces_[i]->compact(tableNameOrRegionName);
|
|
}
|
|
|
|
void majorCompact(const Bytes& tableNameOrRegionName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->majorCompact(tableNameOrRegionName);
|
|
}
|
|
ifaces_[i]->majorCompact(tableNameOrRegionName);
|
|
}
|
|
|
|
void getTableNames(std::vector<Text> & _return) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getTableNames(_return);
|
|
}
|
|
ifaces_[i]->getTableNames(_return);
|
|
return;
|
|
}
|
|
|
|
void getColumnDescriptors(std::map<Text, ColumnDescriptor> & _return, const Text& tableName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getColumnDescriptors(_return, tableName);
|
|
}
|
|
ifaces_[i]->getColumnDescriptors(_return, tableName);
|
|
return;
|
|
}
|
|
|
|
void getTableRegions(std::vector<TRegionInfo> & _return, const Text& tableName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getTableRegions(_return, tableName);
|
|
}
|
|
ifaces_[i]->getTableRegions(_return, tableName);
|
|
return;
|
|
}
|
|
|
|
void createTable(const Text& tableName, const std::vector<ColumnDescriptor> & columnFamilies) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->createTable(tableName, columnFamilies);
|
|
}
|
|
ifaces_[i]->createTable(tableName, columnFamilies);
|
|
}
|
|
|
|
void deleteTable(const Text& tableName) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->deleteTable(tableName);
|
|
}
|
|
ifaces_[i]->deleteTable(tableName);
|
|
}
|
|
|
|
void get(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->get(_return, tableName, row, column, attributes);
|
|
}
|
|
ifaces_[i]->get(_return, tableName, row, column, attributes);
|
|
return;
|
|
}
|
|
|
|
void getVer(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int32_t numVersions, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getVer(_return, tableName, row, column, numVersions, attributes);
|
|
}
|
|
ifaces_[i]->getVer(_return, tableName, row, column, numVersions, attributes);
|
|
return;
|
|
}
|
|
|
|
void getVerTs(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const int32_t numVersions, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getVerTs(_return, tableName, row, column, timestamp, numVersions, attributes);
|
|
}
|
|
ifaces_[i]->getVerTs(_return, tableName, row, column, timestamp, numVersions, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRow(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRow(_return, tableName, row, attributes);
|
|
}
|
|
ifaces_[i]->getRow(_return, tableName, row, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRowWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRowWithColumns(_return, tableName, row, columns, attributes);
|
|
}
|
|
ifaces_[i]->getRowWithColumns(_return, tableName, row, columns, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRowTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRowTs(_return, tableName, row, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->getRowTs(_return, tableName, row, timestamp, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRowWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRowWithColumnsTs(_return, tableName, row, columns, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->getRowWithColumnsTs(_return, tableName, row, columns, timestamp, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRows(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRows(_return, tableName, rows, attributes);
|
|
}
|
|
ifaces_[i]->getRows(_return, tableName, rows, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRowsWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRowsWithColumns(_return, tableName, rows, columns, attributes);
|
|
}
|
|
ifaces_[i]->getRowsWithColumns(_return, tableName, rows, columns, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRowsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRowsTs(_return, tableName, rows, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->getRowsTs(_return, tableName, rows, timestamp, attributes);
|
|
return;
|
|
}
|
|
|
|
void getRowsWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRowsWithColumnsTs(_return, tableName, rows, columns, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->getRowsWithColumnsTs(_return, tableName, rows, columns, timestamp, attributes);
|
|
return;
|
|
}
|
|
|
|
void mutateRow(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->mutateRow(tableName, row, mutations, attributes);
|
|
}
|
|
ifaces_[i]->mutateRow(tableName, row, mutations, attributes);
|
|
}
|
|
|
|
void mutateRowTs(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->mutateRowTs(tableName, row, mutations, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->mutateRowTs(tableName, row, mutations, timestamp, attributes);
|
|
}
|
|
|
|
void mutateRows(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->mutateRows(tableName, rowBatches, attributes);
|
|
}
|
|
ifaces_[i]->mutateRows(tableName, rowBatches, attributes);
|
|
}
|
|
|
|
void mutateRowsTs(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->mutateRowsTs(tableName, rowBatches, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->mutateRowsTs(tableName, rowBatches, timestamp, attributes);
|
|
}
|
|
|
|
int64_t atomicIncrement(const Text& tableName, const Text& row, const Text& column, const int64_t value) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->atomicIncrement(tableName, row, column, value);
|
|
}
|
|
return ifaces_[i]->atomicIncrement(tableName, row, column, value);
|
|
}
|
|
|
|
void deleteAll(const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->deleteAll(tableName, row, column, attributes);
|
|
}
|
|
ifaces_[i]->deleteAll(tableName, row, column, attributes);
|
|
}
|
|
|
|
void deleteAllTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->deleteAllTs(tableName, row, column, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->deleteAllTs(tableName, row, column, timestamp, attributes);
|
|
}
|
|
|
|
void deleteAllRow(const Text& tableName, const Text& row, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->deleteAllRow(tableName, row, attributes);
|
|
}
|
|
ifaces_[i]->deleteAllRow(tableName, row, attributes);
|
|
}
|
|
|
|
void increment(const TIncrement& increment) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->increment(increment);
|
|
}
|
|
ifaces_[i]->increment(increment);
|
|
}
|
|
|
|
void incrementRows(const std::vector<TIncrement> & increments) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->incrementRows(increments);
|
|
}
|
|
ifaces_[i]->incrementRows(increments);
|
|
}
|
|
|
|
void deleteAllRowTs(const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->deleteAllRowTs(tableName, row, timestamp, attributes);
|
|
}
|
|
ifaces_[i]->deleteAllRowTs(tableName, row, timestamp, attributes);
|
|
}
|
|
|
|
ScannerID scannerOpenWithScan(const Text& tableName, const TScan& scan, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerOpenWithScan(tableName, scan, attributes);
|
|
}
|
|
return ifaces_[i]->scannerOpenWithScan(tableName, scan, attributes);
|
|
}
|
|
|
|
ScannerID scannerOpen(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerOpen(tableName, startRow, columns, attributes);
|
|
}
|
|
return ifaces_[i]->scannerOpen(tableName, startRow, columns, attributes);
|
|
}
|
|
|
|
ScannerID scannerOpenWithStop(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes);
|
|
}
|
|
return ifaces_[i]->scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes);
|
|
}
|
|
|
|
ScannerID scannerOpenWithPrefix(const Text& tableName, const Text& startAndPrefix, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes);
|
|
}
|
|
return ifaces_[i]->scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes);
|
|
}
|
|
|
|
ScannerID scannerOpenTs(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerOpenTs(tableName, startRow, columns, timestamp, attributes);
|
|
}
|
|
return ifaces_[i]->scannerOpenTs(tableName, startRow, columns, timestamp, attributes);
|
|
}
|
|
|
|
ScannerID scannerOpenWithStopTs(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes);
|
|
}
|
|
return ifaces_[i]->scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes);
|
|
}
|
|
|
|
void scannerGet(std::vector<TRowResult> & _return, const ScannerID id) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerGet(_return, id);
|
|
}
|
|
ifaces_[i]->scannerGet(_return, id);
|
|
return;
|
|
}
|
|
|
|
void scannerGetList(std::vector<TRowResult> & _return, const ScannerID id, const int32_t nbRows) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerGetList(_return, id, nbRows);
|
|
}
|
|
ifaces_[i]->scannerGetList(_return, id, nbRows);
|
|
return;
|
|
}
|
|
|
|
void scannerClose(const ScannerID id) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->scannerClose(id);
|
|
}
|
|
ifaces_[i]->scannerClose(id);
|
|
}
|
|
|
|
void getRowOrBefore(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& family) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRowOrBefore(_return, tableName, row, family);
|
|
}
|
|
ifaces_[i]->getRowOrBefore(_return, tableName, row, family);
|
|
return;
|
|
}
|
|
|
|
void getRegionInfo(TRegionInfo& _return, const Text& row) {
|
|
size_t sz = ifaces_.size();
|
|
size_t i = 0;
|
|
for (; i < (sz - 1); ++i) {
|
|
ifaces_[i]->getRegionInfo(_return, row);
|
|
}
|
|
ifaces_[i]->getRegionInfo(_return, row);
|
|
return;
|
|
}
|
|
|
|
};
|
|
|
|
}}}} // namespace
|
|
|
|
#endif
|