/** * Autogenerated by Thrift * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING */ #include "Hbase.h" namespace apache { namespace hadoop { namespace hbase { namespace thrift { uint32_t Hbase_getTableNames_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getTableNames_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getTableNames_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getTableNames_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getTableNames_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getTableNames_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size8; facebook::thrift::protocol::TType _etype11; iprot->readListBegin(_etype11, _size8); this->success.resize(_size8); uint32_t _i12; for (_i12 = 0; _i12 < _size8; ++_i12) { xfer += iprot->readBinary(this->success[_i12]); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getTableNames_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getTableNames_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->success.size()); std::vector ::const_iterator _iter13; for (_iter13 = this->success.begin(); _iter13 != this->success.end(); ++_iter13) { xfer += oprot->writeBinary((*_iter13)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getTableNames_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size14; facebook::thrift::protocol::TType _etype17; iprot->readListBegin(_etype17, _size14); (*(this->success)).resize(_size14); uint32_t _i18; for (_i18 = 0; _i18 < _size14; ++_i18) { xfer += iprot->readBinary((*(this->success))[_i18]); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getColumnDescriptors_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getColumnDescriptors_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getColumnDescriptors_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getColumnDescriptors_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getColumnDescriptors_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getColumnDescriptors_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_MAP) { { this->success.clear(); uint32_t _size19; facebook::thrift::protocol::TType _ktype20; facebook::thrift::protocol::TType _vtype21; iprot->readMapBegin(_ktype20, _vtype21, _size19); uint32_t _i23; for (_i23 = 0; _i23 < _size19; ++_i23) { Text _key24; xfer += iprot->readBinary(_key24); ColumnDescriptor& _val25 = this->success[_key24]; xfer += _val25.read(iprot); } iprot->readMapEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getColumnDescriptors_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getColumnDescriptors_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_MAP, 0); { xfer += oprot->writeMapBegin(facebook::thrift::protocol::T_STRING, facebook::thrift::protocol::T_STRUCT, this->success.size()); std::map ::const_iterator _iter26; for (_iter26 = this->success.begin(); _iter26 != this->success.end(); ++_iter26) { xfer += oprot->writeBinary(_iter26->first); xfer += _iter26->second.write(oprot); } xfer += oprot->writeMapEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getColumnDescriptors_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_MAP) { { (*(this->success)).clear(); uint32_t _size27; facebook::thrift::protocol::TType _ktype28; facebook::thrift::protocol::TType _vtype29; iprot->readMapBegin(_ktype28, _vtype29, _size27); uint32_t _i31; for (_i31 = 0; _i31 < _size27; ++_i31) { Text _key32; xfer += iprot->readBinary(_key32); ColumnDescriptor& _val33 = (*(this->success))[_key32]; xfer += _val33.read(iprot); } iprot->readMapEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getTableRegions_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getTableRegions_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getTableRegions_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getTableRegions_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getTableRegions_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getTableRegions_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size34; facebook::thrift::protocol::TType _etype37; iprot->readListBegin(_etype37, _size34); this->success.resize(_size34); uint32_t _i38; for (_i38 = 0; _i38 < _size34; ++_i38) { xfer += this->success[_i38].read(iprot); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getTableRegions_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getTableRegions_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRUCT, this->success.size()); std::vector ::const_iterator _iter39; for (_iter39 = this->success.begin(); _iter39 != this->success.end(); ++_iter39) { xfer += (*_iter39).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getTableRegions_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size40; facebook::thrift::protocol::TType _etype43; iprot->readListBegin(_etype43, _size40); (*(this->success)).resize(_size40); uint32_t _i44; for (_i44 = 0; _i44 < _size40; ++_i44) { xfer += (*(this->success))[_i44].read(iprot); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_createTable_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_LIST) { { this->columnFamilies.clear(); uint32_t _size45; facebook::thrift::protocol::TType _etype48; iprot->readListBegin(_etype48, _size45); this->columnFamilies.resize(_size45); uint32_t _i49; for (_i49 = 0; _i49 < _size45; ++_i49) { xfer += this->columnFamilies[_i49].read(iprot); } iprot->readListEnd(); } this->__isset.columnFamilies = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_createTable_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_createTable_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columnFamilies", facebook::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRUCT, this->columnFamilies.size()); std::vector ::const_iterator _iter50; for (_iter50 = this->columnFamilies.begin(); _iter50 != this->columnFamilies.end(); ++_iter50) { xfer += (*_iter50).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_createTable_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_createTable_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columnFamilies", facebook::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRUCT, (*(this->columnFamilies)).size()); std::vector ::const_iterator _iter51; for (_iter51 = (*(this->columnFamilies)).begin(); _iter51 != (*(this->columnFamilies)).end(); ++_iter51) { xfer += (*_iter51).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_createTable_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->ia.read(iprot); this->__isset.ia = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->exist.read(iprot); this->__isset.exist = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_createTable_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_createTable_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ia) { xfer += oprot->writeFieldBegin("ia", facebook::thrift::protocol::T_STRUCT, 2); xfer += this->ia.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.exist) { xfer += oprot->writeFieldBegin("exist", facebook::thrift::protocol::T_STRUCT, 3); xfer += this->exist.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_createTable_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->ia.read(iprot); this->__isset.ia = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->exist.read(iprot); this->__isset.exist = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteTable_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteTable_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteTable_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteTable_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteTable_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteTable_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteTable_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteTable_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.nf) { xfer += oprot->writeFieldBegin("nf", facebook::thrift::protocol::T_STRUCT, 2); xfer += this->nf.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteTable_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_get_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->column); this->__isset.column = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_get_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_get_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->column); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_get_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_get_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->column))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_get_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_get_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_get_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_STRING, 0); xfer += oprot->writeBinary(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.nf) { xfer += oprot->writeFieldBegin("nf", facebook::thrift::protocol::T_STRUCT, 2); xfer += this->nf.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_get_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getVer_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->column); this->__isset.column = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->numVersions); this->__isset.numVersions = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getVer_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getVer_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->column); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("numVersions", facebook::thrift::protocol::T_I32, 4); xfer += oprot->writeI32(this->numVersions); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getVer_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getVer_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->column))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("numVersions", facebook::thrift::protocol::T_I32, 4); xfer += oprot->writeI32((*(this->numVersions))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getVer_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size52; facebook::thrift::protocol::TType _etype55; iprot->readListBegin(_etype55, _size52); this->success.resize(_size52); uint32_t _i56; for (_i56 = 0; _i56 < _size52; ++_i56) { xfer += iprot->readBinary(this->success[_i56]); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getVer_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getVer_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->success.size()); std::vector ::const_iterator _iter57; for (_iter57 = this->success.begin(); _iter57 != this->success.end(); ++_iter57) { xfer += oprot->writeBinary((*_iter57)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.nf) { xfer += oprot->writeFieldBegin("nf", facebook::thrift::protocol::T_STRUCT, 2); xfer += this->nf.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getVer_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size58; facebook::thrift::protocol::TType _etype61; iprot->readListBegin(_etype61, _size58); (*(this->success)).resize(_size58); uint32_t _i62; for (_i62 = 0; _i62 < _size58; ++_i62) { xfer += iprot->readBinary((*(this->success))[_i62]); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getVerTs_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->column); this->__isset.column = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_I64) { xfer += iprot->readI64(this->timestamp); this->__isset.timestamp = true; } else { xfer += iprot->skip(ftype); } break; case 5: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->numVersions); this->__isset.numVersions = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getVerTs_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getVerTs_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->column); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64(this->timestamp); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("numVersions", facebook::thrift::protocol::T_I32, 5); xfer += oprot->writeI32(this->numVersions); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getVerTs_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getVerTs_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->column))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64((*(this->timestamp))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("numVersions", facebook::thrift::protocol::T_I32, 5); xfer += oprot->writeI32((*(this->numVersions))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getVerTs_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size63; facebook::thrift::protocol::TType _etype66; iprot->readListBegin(_etype66, _size63); this->success.resize(_size63); uint32_t _i67; for (_i67 = 0; _i67 < _size63; ++_i67) { xfer += iprot->readBinary(this->success[_i67]); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getVerTs_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getVerTs_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->success.size()); std::vector ::const_iterator _iter68; for (_iter68 = this->success.begin(); _iter68 != this->success.end(); ++_iter68) { xfer += oprot->writeBinary((*_iter68)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.nf) { xfer += oprot->writeFieldBegin("nf", facebook::thrift::protocol::T_STRUCT, 2); xfer += this->nf.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getVerTs_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size69; facebook::thrift::protocol::TType _etype72; iprot->readListBegin(_etype72, _size69); (*(this->success)).resize(_size69); uint32_t _i73; for (_i73 = 0; _i73 < _size69; ++_i73) { xfer += iprot->readBinary((*(this->success))[_i73]); } iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getRow_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getRow_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getRow_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getRow_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getRow_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getRow_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_MAP) { { this->success.clear(); uint32_t _size74; facebook::thrift::protocol::TType _ktype75; facebook::thrift::protocol::TType _vtype76; iprot->readMapBegin(_ktype75, _vtype76, _size74); uint32_t _i78; for (_i78 = 0; _i78 < _size74; ++_i78) { Text _key79; xfer += iprot->readBinary(_key79); Bytes& _val80 = this->success[_key79]; xfer += iprot->readBinary(_val80); } iprot->readMapEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getRow_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getRow_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_MAP, 0); { xfer += oprot->writeMapBegin(facebook::thrift::protocol::T_STRING, facebook::thrift::protocol::T_STRING, this->success.size()); std::map ::const_iterator _iter81; for (_iter81 = this->success.begin(); _iter81 != this->success.end(); ++_iter81) { xfer += oprot->writeBinary(_iter81->first); xfer += oprot->writeBinary(_iter81->second); } xfer += oprot->writeMapEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getRow_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_MAP) { { (*(this->success)).clear(); uint32_t _size82; facebook::thrift::protocol::TType _ktype83; facebook::thrift::protocol::TType _vtype84; iprot->readMapBegin(_ktype83, _vtype84, _size82); uint32_t _i86; for (_i86 = 0; _i86 < _size82; ++_i86) { Text _key87; xfer += iprot->readBinary(_key87); Bytes& _val88 = (*(this->success))[_key87]; xfer += iprot->readBinary(_val88); } iprot->readMapEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getRowTs_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_I64) { xfer += iprot->readI64(this->timestamp); this->__isset.timestamp = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getRowTs_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getRowTs_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 3); xfer += oprot->writeI64(this->timestamp); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getRowTs_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getRowTs_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 3); xfer += oprot->writeI64((*(this->timestamp))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getRowTs_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_MAP) { { this->success.clear(); uint32_t _size89; facebook::thrift::protocol::TType _ktype90; facebook::thrift::protocol::TType _vtype91; iprot->readMapBegin(_ktype90, _vtype91, _size89); uint32_t _i93; for (_i93 = 0; _i93 < _size89; ++_i93) { Text _key94; xfer += iprot->readBinary(_key94); Bytes& _val95 = this->success[_key94]; xfer += iprot->readBinary(_val95); } iprot->readMapEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_getRowTs_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_getRowTs_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_MAP, 0); { xfer += oprot->writeMapBegin(facebook::thrift::protocol::T_STRING, facebook::thrift::protocol::T_STRING, this->success.size()); std::map ::const_iterator _iter96; for (_iter96 = this->success.begin(); _iter96 != this->success.end(); ++_iter96) { xfer += oprot->writeBinary(_iter96->first); xfer += oprot->writeBinary(_iter96->second); } xfer += oprot->writeMapEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_getRowTs_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_MAP) { { (*(this->success)).clear(); uint32_t _size97; facebook::thrift::protocol::TType _ktype98; facebook::thrift::protocol::TType _vtype99; iprot->readMapBegin(_ktype98, _vtype99, _size97); uint32_t _i101; for (_i101 = 0; _i101 < _size97; ++_i101) { Text _key102; xfer += iprot->readBinary(_key102); Bytes& _val103 = (*(this->success))[_key102]; xfer += iprot->readBinary(_val103); } iprot->readMapEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_put_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->column); this->__isset.column = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->value); this->__isset.value = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_put_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_put_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->column); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("value", facebook::thrift::protocol::T_STRING, 4); xfer += oprot->writeBinary(this->value); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_put_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_put_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->column))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("value", facebook::thrift::protocol::T_STRING, 4); xfer += oprot->writeBinary((*(this->value))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_put_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_put_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_put_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_put_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_mutateRow_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_LIST) { { this->mutations.clear(); uint32_t _size104; facebook::thrift::protocol::TType _etype107; iprot->readListBegin(_etype107, _size104); this->mutations.resize(_size104); uint32_t _i108; for (_i108 = 0; _i108 < _size104; ++_i108) { xfer += this->mutations[_i108].read(iprot); } iprot->readListEnd(); } this->__isset.mutations = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_mutateRow_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_mutateRow_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("mutations", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRUCT, this->mutations.size()); std::vector ::const_iterator _iter109; for (_iter109 = this->mutations.begin(); _iter109 != this->mutations.end(); ++_iter109) { xfer += (*_iter109).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_mutateRow_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_mutateRow_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("mutations", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRUCT, (*(this->mutations)).size()); std::vector ::const_iterator _iter110; for (_iter110 = (*(this->mutations)).begin(); _iter110 != (*(this->mutations)).end(); ++_iter110) { xfer += (*_iter110).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_mutateRow_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_mutateRow_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_mutateRow_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_mutateRow_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_mutateRowTs_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_LIST) { { this->mutations.clear(); uint32_t _size111; facebook::thrift::protocol::TType _etype114; iprot->readListBegin(_etype114, _size111); this->mutations.resize(_size111); uint32_t _i115; for (_i115 = 0; _i115 < _size111; ++_i115) { xfer += this->mutations[_i115].read(iprot); } iprot->readListEnd(); } this->__isset.mutations = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_I64) { xfer += iprot->readI64(this->timestamp); this->__isset.timestamp = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_mutateRowTs_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_mutateRowTs_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("mutations", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRUCT, this->mutations.size()); std::vector ::const_iterator _iter116; for (_iter116 = this->mutations.begin(); _iter116 != this->mutations.end(); ++_iter116) { xfer += (*_iter116).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64(this->timestamp); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_mutateRowTs_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_mutateRowTs_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("mutations", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRUCT, (*(this->mutations)).size()); std::vector ::const_iterator _iter117; for (_iter117 = (*(this->mutations)).begin(); _iter117 != (*(this->mutations)).end(); ++_iter117) { xfer += (*_iter117).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64((*(this->timestamp))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_mutateRowTs_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_mutateRowTs_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_mutateRowTs_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_mutateRowTs_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAll_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->column); this->__isset.column = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAll_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAll_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->column); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAll_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAll_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->column))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAll_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAll_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAll_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAll_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllTs_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->column); this->__isset.column = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_I64) { xfer += iprot->readI64(this->timestamp); this->__isset.timestamp = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllTs_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllTs_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->column); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64(this->timestamp); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllTs_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllTs_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("column", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->column))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64((*(this->timestamp))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllTs_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllTs_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllTs_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllTs_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllRow_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllRow_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllRow_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllRow_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllRow_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllRow_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllRow_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllRow_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllRow_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllRowTs_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->row); this->__isset.row = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_I64) { xfer += iprot->readI64(this->timestamp); this->__isset.timestamp = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllRowTs_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllRowTs_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->row); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 3); xfer += oprot->writeI64(this->timestamp); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllRowTs_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllRowTs_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("row", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->row))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 3); xfer += oprot->writeI64((*(this->timestamp))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllRowTs_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_deleteAllRowTs_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_deleteAllRowTs_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_deleteAllRowTs_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpen_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->startRow); this->__isset.startRow = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_LIST) { { this->columns.clear(); uint32_t _size118; facebook::thrift::protocol::TType _etype121; iprot->readListBegin(_etype121, _size118); this->columns.resize(_size118); uint32_t _i122; for (_i122 = 0; _i122 < _size118; ++_i122) { xfer += iprot->readBinary(this->columns[_i122]); } iprot->readListEnd(); } this->__isset.columns = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpen_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpen_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->startRow); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->columns.size()); std::vector ::const_iterator _iter123; for (_iter123 = this->columns.begin(); _iter123 != this->columns.end(); ++_iter123) { xfer += oprot->writeBinary((*_iter123)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpen_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpen_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->startRow))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, (*(this->columns)).size()); std::vector ::const_iterator _iter124; for (_iter124 = (*(this->columns)).begin(); _iter124 != (*(this->columns)).end(); ++_iter124) { xfer += oprot->writeBinary((*_iter124)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpen_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpen_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpen_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_I32, 0); xfer += oprot->writeI32(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpen_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStop_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->startRow); this->__isset.startRow = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->stopRow); this->__isset.stopRow = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_LIST) { { this->columns.clear(); uint32_t _size125; facebook::thrift::protocol::TType _etype128; iprot->readListBegin(_etype128, _size125); this->columns.resize(_size125); uint32_t _i129; for (_i129 = 0; _i129 < _size125; ++_i129) { xfer += iprot->readBinary(this->columns[_i129]); } iprot->readListEnd(); } this->__isset.columns = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStop_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenWithStop_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->startRow); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("stopRow", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->stopRow); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->columns.size()); std::vector ::const_iterator _iter130; for (_iter130 = this->columns.begin(); _iter130 != this->columns.end(); ++_iter130) { xfer += oprot->writeBinary((*_iter130)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStop_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenWithStop_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->startRow))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("stopRow", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->stopRow))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, (*(this->columns)).size()); std::vector ::const_iterator _iter131; for (_iter131 = (*(this->columns)).begin(); _iter131 != (*(this->columns)).end(); ++_iter131) { xfer += oprot->writeBinary((*_iter131)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStop_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStop_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenWithStop_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_I32, 0); xfer += oprot->writeI32(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStop_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenTs_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->startRow); this->__isset.startRow = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_LIST) { { this->columns.clear(); uint32_t _size132; facebook::thrift::protocol::TType _etype135; iprot->readListBegin(_etype135, _size132); this->columns.resize(_size132); uint32_t _i136; for (_i136 = 0; _i136 < _size132; ++_i136) { xfer += iprot->readBinary(this->columns[_i136]); } iprot->readListEnd(); } this->__isset.columns = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_I64) { xfer += iprot->readI64(this->timestamp); this->__isset.timestamp = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenTs_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenTs_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->startRow); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->columns.size()); std::vector ::const_iterator _iter137; for (_iter137 = this->columns.begin(); _iter137 != this->columns.end(); ++_iter137) { xfer += oprot->writeBinary((*_iter137)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64(this->timestamp); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenTs_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenTs_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->startRow))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, (*(this->columns)).size()); std::vector ::const_iterator _iter138; for (_iter138 = (*(this->columns)).begin(); _iter138 != (*(this->columns)).end(); ++_iter138) { xfer += oprot->writeBinary((*_iter138)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 4); xfer += oprot->writeI64((*(this->timestamp))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenTs_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenTs_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenTs_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_I32, 0); xfer += oprot->writeI32(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenTs_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStopTs_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->tableName); this->__isset.tableName = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->startRow); this->__isset.startRow = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRING) { xfer += iprot->readBinary(this->stopRow); this->__isset.stopRow = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == facebook::thrift::protocol::T_LIST) { { this->columns.clear(); uint32_t _size139; facebook::thrift::protocol::TType _etype142; iprot->readListBegin(_etype142, _size139); this->columns.resize(_size139); uint32_t _i143; for (_i143 = 0; _i143 < _size139; ++_i143) { xfer += iprot->readBinary(this->columns[_i143]); } iprot->readListEnd(); } this->__isset.columns = true; } else { xfer += iprot->skip(ftype); } break; case 5: if (ftype == facebook::thrift::protocol::T_I64) { xfer += iprot->readI64(this->timestamp); this->__isset.timestamp = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStopTs_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenWithStopTs_args"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary(this->tableName); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary(this->startRow); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("stopRow", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary(this->stopRow); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, this->columns.size()); std::vector ::const_iterator _iter144; for (_iter144 = this->columns.begin(); _iter144 != this->columns.end(); ++_iter144) { xfer += oprot->writeBinary((*_iter144)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 5); xfer += oprot->writeI64(this->timestamp); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStopTs_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenWithStopTs_pargs"); xfer += oprot->writeFieldBegin("tableName", facebook::thrift::protocol::T_STRING, 1); xfer += oprot->writeBinary((*(this->tableName))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("startRow", facebook::thrift::protocol::T_STRING, 2); xfer += oprot->writeBinary((*(this->startRow))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("stopRow", facebook::thrift::protocol::T_STRING, 3); xfer += oprot->writeBinary((*(this->stopRow))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("columns", facebook::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(facebook::thrift::protocol::T_STRING, (*(this->columns)).size()); std::vector ::const_iterator _iter145; for (_iter145 = (*(this->columns)).begin(); _iter145 != (*(this->columns)).end(); ++_iter145) { xfer += oprot->writeBinary((*_iter145)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("timestamp", facebook::thrift::protocol::T_I64, 5); xfer += oprot->writeI64((*(this->timestamp))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStopTs_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStopTs_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerOpenWithStopTs_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_I32, 0); xfer += oprot->writeI32(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerOpenWithStopTs_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerGet_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->id); this->__isset.id = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerGet_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerGet_args"); xfer += oprot->writeFieldBegin("id", facebook::thrift::protocol::T_I32, 1); xfer += oprot->writeI32(this->id); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerGet_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerGet_pargs"); xfer += oprot->writeFieldBegin("id", facebook::thrift::protocol::T_I32, 1); xfer += oprot->writeI32((*(this->id))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerGet_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->ia.read(iprot); this->__isset.ia = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerGet_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerGet_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", facebook::thrift::protocol::T_STRUCT, 0); xfer += this->success.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ia) { xfer += oprot->writeFieldBegin("ia", facebook::thrift::protocol::T_STRUCT, 2); xfer += this->ia.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.nf) { xfer += oprot->writeFieldBegin("nf", facebook::thrift::protocol::T_STRUCT, 3); xfer += this->nf.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerGet_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->ia.read(iprot); this->__isset.ia = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->nf.read(iprot); this->__isset.nf = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerClose_args::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_I32) { xfer += iprot->readI32(this->id); this->__isset.id = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerClose_args::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerClose_args"); xfer += oprot->writeFieldBegin("id", facebook::thrift::protocol::T_I32, 1); xfer += oprot->writeI32(this->id); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerClose_pargs::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerClose_pargs"); xfer += oprot->writeFieldBegin("id", facebook::thrift::protocol::T_I32, 1); xfer += oprot->writeI32((*(this->id))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerClose_result::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->ia.read(iprot); this->__isset.ia = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t Hbase_scannerClose_result::write(facebook::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("Hbase_scannerClose_result"); if (this->__isset.io) { xfer += oprot->writeFieldBegin("io", facebook::thrift::protocol::T_STRUCT, 1); xfer += this->io.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ia) { xfer += oprot->writeFieldBegin("ia", facebook::thrift::protocol::T_STRUCT, 2); xfer += this->ia.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } uint32_t Hbase_scannerClose_presult::read(facebook::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; facebook::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using facebook::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == facebook::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->io.read(iprot); this->__isset.io = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == facebook::thrift::protocol::T_STRUCT) { xfer += this->ia.read(iprot); this->__isset.ia = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } void HbaseClient::getTableNames(std::vector & _return) { send_getTableNames(); recv_getTableNames(_return); } void HbaseClient::send_getTableNames() { int32_t cseqid = 0; oprot_->writeMessageBegin("getTableNames", facebook::thrift::protocol::T_CALL, cseqid); Hbase_getTableNames_pargs args; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_getTableNames(std::vector & _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("getTableNames") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_getTableNames_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "getTableNames failed: unknown result"); } void HbaseClient::getColumnDescriptors(std::map & _return, const Text& tableName) { send_getColumnDescriptors(tableName); recv_getColumnDescriptors(_return); } void HbaseClient::send_getColumnDescriptors(const Text& tableName) { int32_t cseqid = 0; oprot_->writeMessageBegin("getColumnDescriptors", facebook::thrift::protocol::T_CALL, cseqid); Hbase_getColumnDescriptors_pargs args; args.tableName = &tableName; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_getColumnDescriptors(std::map & _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("getColumnDescriptors") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_getColumnDescriptors_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "getColumnDescriptors failed: unknown result"); } void HbaseClient::getTableRegions(std::vector & _return, const Text& tableName) { send_getTableRegions(tableName); recv_getTableRegions(_return); } void HbaseClient::send_getTableRegions(const Text& tableName) { int32_t cseqid = 0; oprot_->writeMessageBegin("getTableRegions", facebook::thrift::protocol::T_CALL, cseqid); Hbase_getTableRegions_pargs args; args.tableName = &tableName; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_getTableRegions(std::vector & _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("getTableRegions") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_getTableRegions_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "getTableRegions failed: unknown result"); } void HbaseClient::createTable(const Text& tableName, const std::vector & columnFamilies) { send_createTable(tableName, columnFamilies); recv_createTable(); } void HbaseClient::send_createTable(const Text& tableName, const std::vector & columnFamilies) { int32_t cseqid = 0; oprot_->writeMessageBegin("createTable", facebook::thrift::protocol::T_CALL, cseqid); Hbase_createTable_pargs args; args.tableName = &tableName; args.columnFamilies = &columnFamilies; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_createTable() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("createTable") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_createTable_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } if (result.__isset.ia) { throw result.ia; } if (result.__isset.exist) { throw result.exist; } return; } void HbaseClient::deleteTable(const Text& tableName) { send_deleteTable(tableName); recv_deleteTable(); } void HbaseClient::send_deleteTable(const Text& tableName) { int32_t cseqid = 0; oprot_->writeMessageBegin("deleteTable", facebook::thrift::protocol::T_CALL, cseqid); Hbase_deleteTable_pargs args; args.tableName = &tableName; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_deleteTable() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("deleteTable") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_deleteTable_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } if (result.__isset.nf) { throw result.nf; } return; } void HbaseClient::get(Bytes& _return, const Text& tableName, const Text& row, const Text& column) { send_get(tableName, row, column); recv_get(_return); } void HbaseClient::send_get(const Text& tableName, const Text& row, const Text& column) { int32_t cseqid = 0; oprot_->writeMessageBegin("get", facebook::thrift::protocol::T_CALL, cseqid); Hbase_get_pargs args; args.tableName = &tableName; args.row = &row; args.column = &column; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_get(Bytes& _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("get") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_get_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } if (result.__isset.nf) { throw result.nf; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "get failed: unknown result"); } void HbaseClient::getVer(std::vector & _return, const Text& tableName, const Text& row, const Text& column, const int32_t numVersions) { send_getVer(tableName, row, column, numVersions); recv_getVer(_return); } void HbaseClient::send_getVer(const Text& tableName, const Text& row, const Text& column, const int32_t numVersions) { int32_t cseqid = 0; oprot_->writeMessageBegin("getVer", facebook::thrift::protocol::T_CALL, cseqid); Hbase_getVer_pargs args; args.tableName = &tableName; args.row = &row; args.column = &column; args.numVersions = &numVersions; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_getVer(std::vector & _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("getVer") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_getVer_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } if (result.__isset.nf) { throw result.nf; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "getVer failed: unknown result"); } void HbaseClient::getVerTs(std::vector & _return, const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const int32_t numVersions) { send_getVerTs(tableName, row, column, timestamp, numVersions); recv_getVerTs(_return); } void HbaseClient::send_getVerTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const int32_t numVersions) { int32_t cseqid = 0; oprot_->writeMessageBegin("getVerTs", facebook::thrift::protocol::T_CALL, cseqid); Hbase_getVerTs_pargs args; args.tableName = &tableName; args.row = &row; args.column = &column; args.timestamp = ×tamp; args.numVersions = &numVersions; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_getVerTs(std::vector & _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("getVerTs") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_getVerTs_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } if (result.__isset.nf) { throw result.nf; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "getVerTs failed: unknown result"); } void HbaseClient::getRow(std::map & _return, const Text& tableName, const Text& row) { send_getRow(tableName, row); recv_getRow(_return); } void HbaseClient::send_getRow(const Text& tableName, const Text& row) { int32_t cseqid = 0; oprot_->writeMessageBegin("getRow", facebook::thrift::protocol::T_CALL, cseqid); Hbase_getRow_pargs args; args.tableName = &tableName; args.row = &row; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_getRow(std::map & _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("getRow") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_getRow_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "getRow failed: unknown result"); } void HbaseClient::getRowTs(std::map & _return, const Text& tableName, const Text& row, const int64_t timestamp) { send_getRowTs(tableName, row, timestamp); recv_getRowTs(_return); } void HbaseClient::send_getRowTs(const Text& tableName, const Text& row, const int64_t timestamp) { int32_t cseqid = 0; oprot_->writeMessageBegin("getRowTs", facebook::thrift::protocol::T_CALL, cseqid); Hbase_getRowTs_pargs args; args.tableName = &tableName; args.row = &row; args.timestamp = ×tamp; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_getRowTs(std::map & _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("getRowTs") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_getRowTs_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "getRowTs failed: unknown result"); } void HbaseClient::put(const Text& tableName, const Text& row, const Text& column, const Bytes& value) { send_put(tableName, row, column, value); recv_put(); } void HbaseClient::send_put(const Text& tableName, const Text& row, const Text& column, const Bytes& value) { int32_t cseqid = 0; oprot_->writeMessageBegin("put", facebook::thrift::protocol::T_CALL, cseqid); Hbase_put_pargs args; args.tableName = &tableName; args.row = &row; args.column = &column; args.value = &value; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_put() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("put") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_put_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } return; } void HbaseClient::mutateRow(const Text& tableName, const Text& row, const std::vector & mutations) { send_mutateRow(tableName, row, mutations); recv_mutateRow(); } void HbaseClient::send_mutateRow(const Text& tableName, const Text& row, const std::vector & mutations) { int32_t cseqid = 0; oprot_->writeMessageBegin("mutateRow", facebook::thrift::protocol::T_CALL, cseqid); Hbase_mutateRow_pargs args; args.tableName = &tableName; args.row = &row; args.mutations = &mutations; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_mutateRow() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("mutateRow") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_mutateRow_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } return; } void HbaseClient::mutateRowTs(const Text& tableName, const Text& row, const std::vector & mutations, const int64_t timestamp) { send_mutateRowTs(tableName, row, mutations, timestamp); recv_mutateRowTs(); } void HbaseClient::send_mutateRowTs(const Text& tableName, const Text& row, const std::vector & mutations, const int64_t timestamp) { int32_t cseqid = 0; oprot_->writeMessageBegin("mutateRowTs", facebook::thrift::protocol::T_CALL, cseqid); Hbase_mutateRowTs_pargs args; args.tableName = &tableName; args.row = &row; args.mutations = &mutations; args.timestamp = ×tamp; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_mutateRowTs() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("mutateRowTs") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_mutateRowTs_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } return; } void HbaseClient::deleteAll(const Text& tableName, const Text& row, const Text& column) { send_deleteAll(tableName, row, column); recv_deleteAll(); } void HbaseClient::send_deleteAll(const Text& tableName, const Text& row, const Text& column) { int32_t cseqid = 0; oprot_->writeMessageBegin("deleteAll", facebook::thrift::protocol::T_CALL, cseqid); Hbase_deleteAll_pargs args; args.tableName = &tableName; args.row = &row; args.column = &column; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_deleteAll() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("deleteAll") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_deleteAll_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } return; } void HbaseClient::deleteAllTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp) { send_deleteAllTs(tableName, row, column, timestamp); recv_deleteAllTs(); } void HbaseClient::send_deleteAllTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp) { int32_t cseqid = 0; oprot_->writeMessageBegin("deleteAllTs", facebook::thrift::protocol::T_CALL, cseqid); Hbase_deleteAllTs_pargs args; args.tableName = &tableName; args.row = &row; args.column = &column; args.timestamp = ×tamp; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_deleteAllTs() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("deleteAllTs") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_deleteAllTs_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } return; } void HbaseClient::deleteAllRow(const Text& tableName, const Text& row) { send_deleteAllRow(tableName, row); recv_deleteAllRow(); } void HbaseClient::send_deleteAllRow(const Text& tableName, const Text& row) { int32_t cseqid = 0; oprot_->writeMessageBegin("deleteAllRow", facebook::thrift::protocol::T_CALL, cseqid); Hbase_deleteAllRow_pargs args; args.tableName = &tableName; args.row = &row; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_deleteAllRow() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("deleteAllRow") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_deleteAllRow_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } return; } void HbaseClient::deleteAllRowTs(const Text& tableName, const Text& row, const int64_t timestamp) { send_deleteAllRowTs(tableName, row, timestamp); recv_deleteAllRowTs(); } void HbaseClient::send_deleteAllRowTs(const Text& tableName, const Text& row, const int64_t timestamp) { int32_t cseqid = 0; oprot_->writeMessageBegin("deleteAllRowTs", facebook::thrift::protocol::T_CALL, cseqid); Hbase_deleteAllRowTs_pargs args; args.tableName = &tableName; args.row = &row; args.timestamp = ×tamp; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_deleteAllRowTs() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("deleteAllRowTs") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_deleteAllRowTs_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } return; } ScannerID HbaseClient::scannerOpen(const Text& tableName, const Text& startRow, const std::vector & columns) { send_scannerOpen(tableName, startRow, columns); return recv_scannerOpen(); } void HbaseClient::send_scannerOpen(const Text& tableName, const Text& startRow, const std::vector & columns) { int32_t cseqid = 0; oprot_->writeMessageBegin("scannerOpen", facebook::thrift::protocol::T_CALL, cseqid); Hbase_scannerOpen_pargs args; args.tableName = &tableName; args.startRow = &startRow; args.columns = &columns; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } ScannerID HbaseClient::recv_scannerOpen() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("scannerOpen") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } ScannerID _return; Hbase_scannerOpen_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { return _return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "scannerOpen failed: unknown result"); } ScannerID HbaseClient::scannerOpenWithStop(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector & columns) { send_scannerOpenWithStop(tableName, startRow, stopRow, columns); return recv_scannerOpenWithStop(); } void HbaseClient::send_scannerOpenWithStop(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector & columns) { int32_t cseqid = 0; oprot_->writeMessageBegin("scannerOpenWithStop", facebook::thrift::protocol::T_CALL, cseqid); Hbase_scannerOpenWithStop_pargs args; args.tableName = &tableName; args.startRow = &startRow; args.stopRow = &stopRow; args.columns = &columns; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } ScannerID HbaseClient::recv_scannerOpenWithStop() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("scannerOpenWithStop") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } ScannerID _return; Hbase_scannerOpenWithStop_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { return _return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "scannerOpenWithStop failed: unknown result"); } ScannerID HbaseClient::scannerOpenTs(const Text& tableName, const Text& startRow, const std::vector & columns, const int64_t timestamp) { send_scannerOpenTs(tableName, startRow, columns, timestamp); return recv_scannerOpenTs(); } void HbaseClient::send_scannerOpenTs(const Text& tableName, const Text& startRow, const std::vector & columns, const int64_t timestamp) { int32_t cseqid = 0; oprot_->writeMessageBegin("scannerOpenTs", facebook::thrift::protocol::T_CALL, cseqid); Hbase_scannerOpenTs_pargs args; args.tableName = &tableName; args.startRow = &startRow; args.columns = &columns; args.timestamp = ×tamp; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } ScannerID HbaseClient::recv_scannerOpenTs() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("scannerOpenTs") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } ScannerID _return; Hbase_scannerOpenTs_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { return _return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "scannerOpenTs failed: unknown result"); } ScannerID HbaseClient::scannerOpenWithStopTs(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector & columns, const int64_t timestamp) { send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp); return recv_scannerOpenWithStopTs(); } void HbaseClient::send_scannerOpenWithStopTs(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector & columns, const int64_t timestamp) { int32_t cseqid = 0; oprot_->writeMessageBegin("scannerOpenWithStopTs", facebook::thrift::protocol::T_CALL, cseqid); Hbase_scannerOpenWithStopTs_pargs args; args.tableName = &tableName; args.startRow = &startRow; args.stopRow = &stopRow; args.columns = &columns; args.timestamp = ×tamp; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } ScannerID HbaseClient::recv_scannerOpenWithStopTs() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("scannerOpenWithStopTs") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } ScannerID _return; Hbase_scannerOpenWithStopTs_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { return _return; } if (result.__isset.io) { throw result.io; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "scannerOpenWithStopTs failed: unknown result"); } void HbaseClient::scannerGet(ScanEntry& _return, const ScannerID id) { send_scannerGet(id); recv_scannerGet(_return); } void HbaseClient::send_scannerGet(const ScannerID id) { int32_t cseqid = 0; oprot_->writeMessageBegin("scannerGet", facebook::thrift::protocol::T_CALL, cseqid); Hbase_scannerGet_pargs args; args.id = &id; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_scannerGet(ScanEntry& _return) { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("scannerGet") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_scannerGet_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.io) { throw result.io; } if (result.__isset.ia) { throw result.ia; } if (result.__isset.nf) { throw result.nf; } throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::MISSING_RESULT, "scannerGet failed: unknown result"); } void HbaseClient::scannerClose(const ScannerID id) { send_scannerClose(id); recv_scannerClose(); } void HbaseClient::send_scannerClose(const ScannerID id) { int32_t cseqid = 0; oprot_->writeMessageBegin("scannerClose", facebook::thrift::protocol::T_CALL, cseqid); Hbase_scannerClose_pargs args; args.id = &id; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->flush(); oprot_->getTransport()->writeEnd(); } void HbaseClient::recv_scannerClose() { int32_t rseqid = 0; std::string fname; facebook::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == facebook::thrift::protocol::T_EXCEPTION) { facebook::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != facebook::thrift::protocol::T_REPLY) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); } if (fname.compare("scannerClose") != 0) { iprot_->skip(facebook::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw facebook::thrift::TApplicationException(facebook::thrift::TApplicationException::WRONG_METHOD_NAME); } Hbase_scannerClose_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.io) { throw result.io; } if (result.__isset.ia) { throw result.ia; } return; } bool HbaseProcessor::process(boost::shared_ptr piprot, boost::shared_ptr poprot) { facebook::thrift::protocol::TProtocol* iprot = piprot.get(); facebook::thrift::protocol::TProtocol* oprot = poprot.get(); std::string fname; facebook::thrift::protocol::TMessageType mtype; int32_t seqid; iprot->readMessageBegin(fname, mtype, seqid); if (mtype != facebook::thrift::protocol::T_CALL) { iprot->skip(facebook::thrift::protocol::T_STRUCT); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); facebook::thrift::TApplicationException x(facebook::thrift::TApplicationException::INVALID_MESSAGE_TYPE); oprot->writeMessageBegin(fname, facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return true; } return process_fn(iprot, oprot, fname, seqid); } bool HbaseProcessor::process_fn(facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot, std::string& fname, int32_t seqid) { std::map::iterator pfn; pfn = processMap_.find(fname); if (pfn == processMap_.end()) { iprot->skip(facebook::thrift::protocol::T_STRUCT); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); facebook::thrift::TApplicationException x(facebook::thrift::TApplicationException::UNKNOWN_METHOD, "Invalid method name: '"+fname+"'"); oprot->writeMessageBegin(fname, facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return true; } (this->*(pfn->second))(seqid, iprot, oprot); return true; } void HbaseProcessor::process_getTableNames(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_getTableNames_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_getTableNames_result result; try { iface_->getTableNames(result.success); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("getTableNames", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("getTableNames", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_getColumnDescriptors(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_getColumnDescriptors_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_getColumnDescriptors_result result; try { iface_->getColumnDescriptors(result.success, args.tableName); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("getColumnDescriptors", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("getColumnDescriptors", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_getTableRegions(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_getTableRegions_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_getTableRegions_result result; try { iface_->getTableRegions(result.success, args.tableName); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("getTableRegions", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("getTableRegions", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_createTable(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_createTable_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_createTable_result result; try { iface_->createTable(args.tableName, args.columnFamilies); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (IllegalArgument &ia) { result.ia = ia; result.__isset.ia = true; } catch (AlreadyExists &exist) { result.exist = exist; result.__isset.exist = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("createTable", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("createTable", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_deleteTable(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_deleteTable_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_deleteTable_result result; try { iface_->deleteTable(args.tableName); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (NotFound &nf) { result.nf = nf; result.__isset.nf = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("deleteTable", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("deleteTable", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_get(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_get_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_get_result result; try { iface_->get(result.success, args.tableName, args.row, args.column); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (NotFound &nf) { result.nf = nf; result.__isset.nf = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("get", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("get", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_getVer(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_getVer_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_getVer_result result; try { iface_->getVer(result.success, args.tableName, args.row, args.column, args.numVersions); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (NotFound &nf) { result.nf = nf; result.__isset.nf = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("getVer", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("getVer", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_getVerTs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_getVerTs_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_getVerTs_result result; try { iface_->getVerTs(result.success, args.tableName, args.row, args.column, args.timestamp, args.numVersions); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (NotFound &nf) { result.nf = nf; result.__isset.nf = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("getVerTs", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("getVerTs", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_getRow(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_getRow_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_getRow_result result; try { iface_->getRow(result.success, args.tableName, args.row); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("getRow", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("getRow", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_getRowTs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_getRowTs_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_getRowTs_result result; try { iface_->getRowTs(result.success, args.tableName, args.row, args.timestamp); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("getRowTs", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("getRowTs", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_put(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_put_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_put_result result; try { iface_->put(args.tableName, args.row, args.column, args.value); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("put", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("put", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_mutateRow(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_mutateRow_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_mutateRow_result result; try { iface_->mutateRow(args.tableName, args.row, args.mutations); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("mutateRow", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("mutateRow", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_mutateRowTs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_mutateRowTs_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_mutateRowTs_result result; try { iface_->mutateRowTs(args.tableName, args.row, args.mutations, args.timestamp); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("mutateRowTs", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("mutateRowTs", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_deleteAll(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_deleteAll_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_deleteAll_result result; try { iface_->deleteAll(args.tableName, args.row, args.column); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("deleteAll", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("deleteAll", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_deleteAllTs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_deleteAllTs_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_deleteAllTs_result result; try { iface_->deleteAllTs(args.tableName, args.row, args.column, args.timestamp); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("deleteAllTs", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("deleteAllTs", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_deleteAllRow(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_deleteAllRow_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_deleteAllRow_result result; try { iface_->deleteAllRow(args.tableName, args.row); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("deleteAllRow", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("deleteAllRow", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_deleteAllRowTs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_deleteAllRowTs_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_deleteAllRowTs_result result; try { iface_->deleteAllRowTs(args.tableName, args.row, args.timestamp); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("deleteAllRowTs", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("deleteAllRowTs", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_scannerOpen(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_scannerOpen_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_scannerOpen_result result; try { result.success = iface_->scannerOpen(args.tableName, args.startRow, args.columns); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("scannerOpen", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("scannerOpen", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_scannerOpenWithStop(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_scannerOpenWithStop_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_scannerOpenWithStop_result result; try { result.success = iface_->scannerOpenWithStop(args.tableName, args.startRow, args.stopRow, args.columns); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("scannerOpenWithStop", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("scannerOpenWithStop", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_scannerOpenTs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_scannerOpenTs_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_scannerOpenTs_result result; try { result.success = iface_->scannerOpenTs(args.tableName, args.startRow, args.columns, args.timestamp); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("scannerOpenTs", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("scannerOpenTs", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_scannerOpenWithStopTs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_scannerOpenWithStopTs_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_scannerOpenWithStopTs_result result; try { result.success = iface_->scannerOpenWithStopTs(args.tableName, args.startRow, args.stopRow, args.columns, args.timestamp); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("scannerOpenWithStopTs", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("scannerOpenWithStopTs", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_scannerGet(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_scannerGet_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_scannerGet_result result; try { iface_->scannerGet(result.success, args.id); result.__isset.success = true; } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (IllegalArgument &ia) { result.ia = ia; result.__isset.ia = true; } catch (NotFound &nf) { result.nf = nf; result.__isset.nf = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("scannerGet", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("scannerGet", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } void HbaseProcessor::process_scannerClose(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot) { Hbase_scannerClose_args args; args.read(iprot); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); Hbase_scannerClose_result result; try { iface_->scannerClose(args.id); } catch (IOError &io) { result.io = io; result.__isset.io = true; } catch (IllegalArgument &ia) { result.ia = ia; result.__isset.ia = true; } catch (const std::exception& e) { facebook::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("scannerClose", facebook::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); return; } oprot->writeMessageBegin("scannerClose", facebook::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->flush(); oprot->getTransport()->writeEnd(); } }}}} // namespace