TCLIService.py 145 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569457045714572457345744575457645774578457945804581458245834584458545864587458845894590459145924593459445954596
  1. #
  2. # Autogenerated by Thrift Compiler (0.13.0)
  3. #
  4. # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  5. #
  6. # options string: py:new_style
  7. #
  8. from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
  9. from thrift.protocol.TProtocol import TProtocolException
  10. from thrift.TRecursive import fix_spec
  11. import sys
  12. import logging
  13. from .ttypes import *
  14. from thrift.Thrift import TProcessor
  15. from thrift.transport import TTransport
  16. all_structs = []
  17. class Iface(object):
  18. def OpenSession(self, req):
  19. """
  20. Parameters:
  21. - req
  22. """
  23. pass
  24. def CloseSession(self, req):
  25. """
  26. Parameters:
  27. - req
  28. """
  29. pass
  30. def GetInfo(self, req):
  31. """
  32. Parameters:
  33. - req
  34. """
  35. pass
  36. def ExecuteStatement(self, req):
  37. """
  38. Parameters:
  39. - req
  40. """
  41. pass
  42. def GetTypeInfo(self, req):
  43. """
  44. Parameters:
  45. - req
  46. """
  47. pass
  48. def GetCatalogs(self, req):
  49. """
  50. Parameters:
  51. - req
  52. """
  53. pass
  54. def GetSchemas(self, req):
  55. """
  56. Parameters:
  57. - req
  58. """
  59. pass
  60. def GetTables(self, req):
  61. """
  62. Parameters:
  63. - req
  64. """
  65. pass
  66. def GetTableTypes(self, req):
  67. """
  68. Parameters:
  69. - req
  70. """
  71. pass
  72. def GetColumns(self, req):
  73. """
  74. Parameters:
  75. - req
  76. """
  77. pass
  78. def GetFunctions(self, req):
  79. """
  80. Parameters:
  81. - req
  82. """
  83. pass
  84. def GetPrimaryKeys(self, req):
  85. """
  86. Parameters:
  87. - req
  88. """
  89. pass
  90. def GetCrossReference(self, req):
  91. """
  92. Parameters:
  93. - req
  94. """
  95. pass
  96. def GetOperationStatus(self, req):
  97. """
  98. Parameters:
  99. - req
  100. """
  101. pass
  102. def CancelOperation(self, req):
  103. """
  104. Parameters:
  105. - req
  106. """
  107. pass
  108. def CloseOperation(self, req):
  109. """
  110. Parameters:
  111. - req
  112. """
  113. pass
  114. def GetResultSetMetadata(self, req):
  115. """
  116. Parameters:
  117. - req
  118. """
  119. pass
  120. def FetchResults(self, req):
  121. """
  122. Parameters:
  123. - req
  124. """
  125. pass
  126. def GetDelegationToken(self, req):
  127. """
  128. Parameters:
  129. - req
  130. """
  131. pass
  132. def CancelDelegationToken(self, req):
  133. """
  134. Parameters:
  135. - req
  136. """
  137. pass
  138. def RenewDelegationToken(self, req):
  139. """
  140. Parameters:
  141. - req
  142. """
  143. pass
  144. def GetQueryId(self, req):
  145. """
  146. Parameters:
  147. - req
  148. """
  149. pass
  150. def SetClientInfo(self, req):
  151. """
  152. Parameters:
  153. - req
  154. """
  155. pass
  156. def GetLog(self, req):
  157. """
  158. Parameters:
  159. - req
  160. """
  161. pass
  162. class Client(Iface):
  163. def __init__(self, iprot, oprot=None):
  164. self._iprot = self._oprot = iprot
  165. if oprot is not None:
  166. self._oprot = oprot
  167. self._seqid = 0
  168. def OpenSession(self, req):
  169. """
  170. Parameters:
  171. - req
  172. """
  173. self.send_OpenSession(req)
  174. return self.recv_OpenSession()
  175. def send_OpenSession(self, req):
  176. self._oprot.writeMessageBegin('OpenSession', TMessageType.CALL, self._seqid)
  177. args = OpenSession_args()
  178. args.req = req
  179. args.write(self._oprot)
  180. self._oprot.writeMessageEnd()
  181. self._oprot.trans.flush()
  182. def recv_OpenSession(self):
  183. iprot = self._iprot
  184. (fname, mtype, rseqid) = iprot.readMessageBegin()
  185. if mtype == TMessageType.EXCEPTION:
  186. x = TApplicationException()
  187. x.read(iprot)
  188. iprot.readMessageEnd()
  189. raise x
  190. result = OpenSession_result()
  191. result.read(iprot)
  192. iprot.readMessageEnd()
  193. if result.success is not None:
  194. return result.success
  195. raise TApplicationException(TApplicationException.MISSING_RESULT, "OpenSession failed: unknown result")
  196. def CloseSession(self, req):
  197. """
  198. Parameters:
  199. - req
  200. """
  201. self.send_CloseSession(req)
  202. return self.recv_CloseSession()
  203. def send_CloseSession(self, req):
  204. self._oprot.writeMessageBegin('CloseSession', TMessageType.CALL, self._seqid)
  205. args = CloseSession_args()
  206. args.req = req
  207. args.write(self._oprot)
  208. self._oprot.writeMessageEnd()
  209. self._oprot.trans.flush()
  210. def recv_CloseSession(self):
  211. iprot = self._iprot
  212. (fname, mtype, rseqid) = iprot.readMessageBegin()
  213. if mtype == TMessageType.EXCEPTION:
  214. x = TApplicationException()
  215. x.read(iprot)
  216. iprot.readMessageEnd()
  217. raise x
  218. result = CloseSession_result()
  219. result.read(iprot)
  220. iprot.readMessageEnd()
  221. if result.success is not None:
  222. return result.success
  223. raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseSession failed: unknown result")
  224. def GetInfo(self, req):
  225. """
  226. Parameters:
  227. - req
  228. """
  229. self.send_GetInfo(req)
  230. return self.recv_GetInfo()
  231. def send_GetInfo(self, req):
  232. self._oprot.writeMessageBegin('GetInfo', TMessageType.CALL, self._seqid)
  233. args = GetInfo_args()
  234. args.req = req
  235. args.write(self._oprot)
  236. self._oprot.writeMessageEnd()
  237. self._oprot.trans.flush()
  238. def recv_GetInfo(self):
  239. iprot = self._iprot
  240. (fname, mtype, rseqid) = iprot.readMessageBegin()
  241. if mtype == TMessageType.EXCEPTION:
  242. x = TApplicationException()
  243. x.read(iprot)
  244. iprot.readMessageEnd()
  245. raise x
  246. result = GetInfo_result()
  247. result.read(iprot)
  248. iprot.readMessageEnd()
  249. if result.success is not None:
  250. return result.success
  251. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetInfo failed: unknown result")
  252. def ExecuteStatement(self, req):
  253. """
  254. Parameters:
  255. - req
  256. """
  257. self.send_ExecuteStatement(req)
  258. return self.recv_ExecuteStatement()
  259. def send_ExecuteStatement(self, req):
  260. self._oprot.writeMessageBegin('ExecuteStatement', TMessageType.CALL, self._seqid)
  261. args = ExecuteStatement_args()
  262. args.req = req
  263. args.write(self._oprot)
  264. self._oprot.writeMessageEnd()
  265. self._oprot.trans.flush()
  266. def recv_ExecuteStatement(self):
  267. iprot = self._iprot
  268. (fname, mtype, rseqid) = iprot.readMessageBegin()
  269. if mtype == TMessageType.EXCEPTION:
  270. x = TApplicationException()
  271. x.read(iprot)
  272. iprot.readMessageEnd()
  273. raise x
  274. result = ExecuteStatement_result()
  275. result.read(iprot)
  276. iprot.readMessageEnd()
  277. if result.success is not None:
  278. return result.success
  279. raise TApplicationException(TApplicationException.MISSING_RESULT, "ExecuteStatement failed: unknown result")
  280. def GetTypeInfo(self, req):
  281. """
  282. Parameters:
  283. - req
  284. """
  285. self.send_GetTypeInfo(req)
  286. return self.recv_GetTypeInfo()
  287. def send_GetTypeInfo(self, req):
  288. self._oprot.writeMessageBegin('GetTypeInfo', TMessageType.CALL, self._seqid)
  289. args = GetTypeInfo_args()
  290. args.req = req
  291. args.write(self._oprot)
  292. self._oprot.writeMessageEnd()
  293. self._oprot.trans.flush()
  294. def recv_GetTypeInfo(self):
  295. iprot = self._iprot
  296. (fname, mtype, rseqid) = iprot.readMessageBegin()
  297. if mtype == TMessageType.EXCEPTION:
  298. x = TApplicationException()
  299. x.read(iprot)
  300. iprot.readMessageEnd()
  301. raise x
  302. result = GetTypeInfo_result()
  303. result.read(iprot)
  304. iprot.readMessageEnd()
  305. if result.success is not None:
  306. return result.success
  307. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTypeInfo failed: unknown result")
  308. def GetCatalogs(self, req):
  309. """
  310. Parameters:
  311. - req
  312. """
  313. self.send_GetCatalogs(req)
  314. return self.recv_GetCatalogs()
  315. def send_GetCatalogs(self, req):
  316. self._oprot.writeMessageBegin('GetCatalogs', TMessageType.CALL, self._seqid)
  317. args = GetCatalogs_args()
  318. args.req = req
  319. args.write(self._oprot)
  320. self._oprot.writeMessageEnd()
  321. self._oprot.trans.flush()
  322. def recv_GetCatalogs(self):
  323. iprot = self._iprot
  324. (fname, mtype, rseqid) = iprot.readMessageBegin()
  325. if mtype == TMessageType.EXCEPTION:
  326. x = TApplicationException()
  327. x.read(iprot)
  328. iprot.readMessageEnd()
  329. raise x
  330. result = GetCatalogs_result()
  331. result.read(iprot)
  332. iprot.readMessageEnd()
  333. if result.success is not None:
  334. return result.success
  335. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetCatalogs failed: unknown result")
  336. def GetSchemas(self, req):
  337. """
  338. Parameters:
  339. - req
  340. """
  341. self.send_GetSchemas(req)
  342. return self.recv_GetSchemas()
  343. def send_GetSchemas(self, req):
  344. self._oprot.writeMessageBegin('GetSchemas', TMessageType.CALL, self._seqid)
  345. args = GetSchemas_args()
  346. args.req = req
  347. args.write(self._oprot)
  348. self._oprot.writeMessageEnd()
  349. self._oprot.trans.flush()
  350. def recv_GetSchemas(self):
  351. iprot = self._iprot
  352. (fname, mtype, rseqid) = iprot.readMessageBegin()
  353. if mtype == TMessageType.EXCEPTION:
  354. x = TApplicationException()
  355. x.read(iprot)
  356. iprot.readMessageEnd()
  357. raise x
  358. result = GetSchemas_result()
  359. result.read(iprot)
  360. iprot.readMessageEnd()
  361. if result.success is not None:
  362. return result.success
  363. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetSchemas failed: unknown result")
  364. def GetTables(self, req):
  365. """
  366. Parameters:
  367. - req
  368. """
  369. self.send_GetTables(req)
  370. return self.recv_GetTables()
  371. def send_GetTables(self, req):
  372. self._oprot.writeMessageBegin('GetTables', TMessageType.CALL, self._seqid)
  373. args = GetTables_args()
  374. args.req = req
  375. args.write(self._oprot)
  376. self._oprot.writeMessageEnd()
  377. self._oprot.trans.flush()
  378. def recv_GetTables(self):
  379. iprot = self._iprot
  380. (fname, mtype, rseqid) = iprot.readMessageBegin()
  381. if mtype == TMessageType.EXCEPTION:
  382. x = TApplicationException()
  383. x.read(iprot)
  384. iprot.readMessageEnd()
  385. raise x
  386. result = GetTables_result()
  387. result.read(iprot)
  388. iprot.readMessageEnd()
  389. if result.success is not None:
  390. return result.success
  391. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTables failed: unknown result")
  392. def GetTableTypes(self, req):
  393. """
  394. Parameters:
  395. - req
  396. """
  397. self.send_GetTableTypes(req)
  398. return self.recv_GetTableTypes()
  399. def send_GetTableTypes(self, req):
  400. self._oprot.writeMessageBegin('GetTableTypes', TMessageType.CALL, self._seqid)
  401. args = GetTableTypes_args()
  402. args.req = req
  403. args.write(self._oprot)
  404. self._oprot.writeMessageEnd()
  405. self._oprot.trans.flush()
  406. def recv_GetTableTypes(self):
  407. iprot = self._iprot
  408. (fname, mtype, rseqid) = iprot.readMessageBegin()
  409. if mtype == TMessageType.EXCEPTION:
  410. x = TApplicationException()
  411. x.read(iprot)
  412. iprot.readMessageEnd()
  413. raise x
  414. result = GetTableTypes_result()
  415. result.read(iprot)
  416. iprot.readMessageEnd()
  417. if result.success is not None:
  418. return result.success
  419. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTableTypes failed: unknown result")
  420. def GetColumns(self, req):
  421. """
  422. Parameters:
  423. - req
  424. """
  425. self.send_GetColumns(req)
  426. return self.recv_GetColumns()
  427. def send_GetColumns(self, req):
  428. self._oprot.writeMessageBegin('GetColumns', TMessageType.CALL, self._seqid)
  429. args = GetColumns_args()
  430. args.req = req
  431. args.write(self._oprot)
  432. self._oprot.writeMessageEnd()
  433. self._oprot.trans.flush()
  434. def recv_GetColumns(self):
  435. iprot = self._iprot
  436. (fname, mtype, rseqid) = iprot.readMessageBegin()
  437. if mtype == TMessageType.EXCEPTION:
  438. x = TApplicationException()
  439. x.read(iprot)
  440. iprot.readMessageEnd()
  441. raise x
  442. result = GetColumns_result()
  443. result.read(iprot)
  444. iprot.readMessageEnd()
  445. if result.success is not None:
  446. return result.success
  447. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetColumns failed: unknown result")
  448. def GetFunctions(self, req):
  449. """
  450. Parameters:
  451. - req
  452. """
  453. self.send_GetFunctions(req)
  454. return self.recv_GetFunctions()
  455. def send_GetFunctions(self, req):
  456. self._oprot.writeMessageBegin('GetFunctions', TMessageType.CALL, self._seqid)
  457. args = GetFunctions_args()
  458. args.req = req
  459. args.write(self._oprot)
  460. self._oprot.writeMessageEnd()
  461. self._oprot.trans.flush()
  462. def recv_GetFunctions(self):
  463. iprot = self._iprot
  464. (fname, mtype, rseqid) = iprot.readMessageBegin()
  465. if mtype == TMessageType.EXCEPTION:
  466. x = TApplicationException()
  467. x.read(iprot)
  468. iprot.readMessageEnd()
  469. raise x
  470. result = GetFunctions_result()
  471. result.read(iprot)
  472. iprot.readMessageEnd()
  473. if result.success is not None:
  474. return result.success
  475. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetFunctions failed: unknown result")
  476. def GetPrimaryKeys(self, req):
  477. """
  478. Parameters:
  479. - req
  480. """
  481. self.send_GetPrimaryKeys(req)
  482. return self.recv_GetPrimaryKeys()
  483. def send_GetPrimaryKeys(self, req):
  484. self._oprot.writeMessageBegin('GetPrimaryKeys', TMessageType.CALL, self._seqid)
  485. args = GetPrimaryKeys_args()
  486. args.req = req
  487. args.write(self._oprot)
  488. self._oprot.writeMessageEnd()
  489. self._oprot.trans.flush()
  490. def recv_GetPrimaryKeys(self):
  491. iprot = self._iprot
  492. (fname, mtype, rseqid) = iprot.readMessageBegin()
  493. if mtype == TMessageType.EXCEPTION:
  494. x = TApplicationException()
  495. x.read(iprot)
  496. iprot.readMessageEnd()
  497. raise x
  498. result = GetPrimaryKeys_result()
  499. result.read(iprot)
  500. iprot.readMessageEnd()
  501. if result.success is not None:
  502. return result.success
  503. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetPrimaryKeys failed: unknown result")
  504. def GetCrossReference(self, req):
  505. """
  506. Parameters:
  507. - req
  508. """
  509. self.send_GetCrossReference(req)
  510. return self.recv_GetCrossReference()
  511. def send_GetCrossReference(self, req):
  512. self._oprot.writeMessageBegin('GetCrossReference', TMessageType.CALL, self._seqid)
  513. args = GetCrossReference_args()
  514. args.req = req
  515. args.write(self._oprot)
  516. self._oprot.writeMessageEnd()
  517. self._oprot.trans.flush()
  518. def recv_GetCrossReference(self):
  519. iprot = self._iprot
  520. (fname, mtype, rseqid) = iprot.readMessageBegin()
  521. if mtype == TMessageType.EXCEPTION:
  522. x = TApplicationException()
  523. x.read(iprot)
  524. iprot.readMessageEnd()
  525. raise x
  526. result = GetCrossReference_result()
  527. result.read(iprot)
  528. iprot.readMessageEnd()
  529. if result.success is not None:
  530. return result.success
  531. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetCrossReference failed: unknown result")
  532. def GetOperationStatus(self, req):
  533. """
  534. Parameters:
  535. - req
  536. """
  537. self.send_GetOperationStatus(req)
  538. return self.recv_GetOperationStatus()
  539. def send_GetOperationStatus(self, req):
  540. self._oprot.writeMessageBegin('GetOperationStatus', TMessageType.CALL, self._seqid)
  541. args = GetOperationStatus_args()
  542. args.req = req
  543. args.write(self._oprot)
  544. self._oprot.writeMessageEnd()
  545. self._oprot.trans.flush()
  546. def recv_GetOperationStatus(self):
  547. iprot = self._iprot
  548. (fname, mtype, rseqid) = iprot.readMessageBegin()
  549. if mtype == TMessageType.EXCEPTION:
  550. x = TApplicationException()
  551. x.read(iprot)
  552. iprot.readMessageEnd()
  553. raise x
  554. result = GetOperationStatus_result()
  555. result.read(iprot)
  556. iprot.readMessageEnd()
  557. if result.success is not None:
  558. return result.success
  559. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetOperationStatus failed: unknown result")
  560. def CancelOperation(self, req):
  561. """
  562. Parameters:
  563. - req
  564. """
  565. self.send_CancelOperation(req)
  566. return self.recv_CancelOperation()
  567. def send_CancelOperation(self, req):
  568. self._oprot.writeMessageBegin('CancelOperation', TMessageType.CALL, self._seqid)
  569. args = CancelOperation_args()
  570. args.req = req
  571. args.write(self._oprot)
  572. self._oprot.writeMessageEnd()
  573. self._oprot.trans.flush()
  574. def recv_CancelOperation(self):
  575. iprot = self._iprot
  576. (fname, mtype, rseqid) = iprot.readMessageBegin()
  577. if mtype == TMessageType.EXCEPTION:
  578. x = TApplicationException()
  579. x.read(iprot)
  580. iprot.readMessageEnd()
  581. raise x
  582. result = CancelOperation_result()
  583. result.read(iprot)
  584. iprot.readMessageEnd()
  585. if result.success is not None:
  586. return result.success
  587. raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelOperation failed: unknown result")
  588. def CloseOperation(self, req):
  589. """
  590. Parameters:
  591. - req
  592. """
  593. self.send_CloseOperation(req)
  594. return self.recv_CloseOperation()
  595. def send_CloseOperation(self, req):
  596. self._oprot.writeMessageBegin('CloseOperation', TMessageType.CALL, self._seqid)
  597. args = CloseOperation_args()
  598. args.req = req
  599. args.write(self._oprot)
  600. self._oprot.writeMessageEnd()
  601. self._oprot.trans.flush()
  602. def recv_CloseOperation(self):
  603. iprot = self._iprot
  604. (fname, mtype, rseqid) = iprot.readMessageBegin()
  605. if mtype == TMessageType.EXCEPTION:
  606. x = TApplicationException()
  607. x.read(iprot)
  608. iprot.readMessageEnd()
  609. raise x
  610. result = CloseOperation_result()
  611. result.read(iprot)
  612. iprot.readMessageEnd()
  613. if result.success is not None:
  614. return result.success
  615. raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseOperation failed: unknown result")
  616. def GetResultSetMetadata(self, req):
  617. """
  618. Parameters:
  619. - req
  620. """
  621. self.send_GetResultSetMetadata(req)
  622. return self.recv_GetResultSetMetadata()
  623. def send_GetResultSetMetadata(self, req):
  624. self._oprot.writeMessageBegin('GetResultSetMetadata', TMessageType.CALL, self._seqid)
  625. args = GetResultSetMetadata_args()
  626. args.req = req
  627. args.write(self._oprot)
  628. self._oprot.writeMessageEnd()
  629. self._oprot.trans.flush()
  630. def recv_GetResultSetMetadata(self):
  631. iprot = self._iprot
  632. (fname, mtype, rseqid) = iprot.readMessageBegin()
  633. if mtype == TMessageType.EXCEPTION:
  634. x = TApplicationException()
  635. x.read(iprot)
  636. iprot.readMessageEnd()
  637. raise x
  638. result = GetResultSetMetadata_result()
  639. result.read(iprot)
  640. iprot.readMessageEnd()
  641. if result.success is not None:
  642. return result.success
  643. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetResultSetMetadata failed: unknown result")
  644. def FetchResults(self, req):
  645. """
  646. Parameters:
  647. - req
  648. """
  649. self.send_FetchResults(req)
  650. return self.recv_FetchResults()
  651. def send_FetchResults(self, req):
  652. self._oprot.writeMessageBegin('FetchResults', TMessageType.CALL, self._seqid)
  653. args = FetchResults_args()
  654. args.req = req
  655. args.write(self._oprot)
  656. self._oprot.writeMessageEnd()
  657. self._oprot.trans.flush()
  658. def recv_FetchResults(self):
  659. iprot = self._iprot
  660. (fname, mtype, rseqid) = iprot.readMessageBegin()
  661. if mtype == TMessageType.EXCEPTION:
  662. x = TApplicationException()
  663. x.read(iprot)
  664. iprot.readMessageEnd()
  665. raise x
  666. result = FetchResults_result()
  667. result.read(iprot)
  668. iprot.readMessageEnd()
  669. if result.success is not None:
  670. return result.success
  671. raise TApplicationException(TApplicationException.MISSING_RESULT, "FetchResults failed: unknown result")
  672. def GetDelegationToken(self, req):
  673. """
  674. Parameters:
  675. - req
  676. """
  677. self.send_GetDelegationToken(req)
  678. return self.recv_GetDelegationToken()
  679. def send_GetDelegationToken(self, req):
  680. self._oprot.writeMessageBegin('GetDelegationToken', TMessageType.CALL, self._seqid)
  681. args = GetDelegationToken_args()
  682. args.req = req
  683. args.write(self._oprot)
  684. self._oprot.writeMessageEnd()
  685. self._oprot.trans.flush()
  686. def recv_GetDelegationToken(self):
  687. iprot = self._iprot
  688. (fname, mtype, rseqid) = iprot.readMessageBegin()
  689. if mtype == TMessageType.EXCEPTION:
  690. x = TApplicationException()
  691. x.read(iprot)
  692. iprot.readMessageEnd()
  693. raise x
  694. result = GetDelegationToken_result()
  695. result.read(iprot)
  696. iprot.readMessageEnd()
  697. if result.success is not None:
  698. return result.success
  699. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetDelegationToken failed: unknown result")
  700. def CancelDelegationToken(self, req):
  701. """
  702. Parameters:
  703. - req
  704. """
  705. self.send_CancelDelegationToken(req)
  706. return self.recv_CancelDelegationToken()
  707. def send_CancelDelegationToken(self, req):
  708. self._oprot.writeMessageBegin('CancelDelegationToken', TMessageType.CALL, self._seqid)
  709. args = CancelDelegationToken_args()
  710. args.req = req
  711. args.write(self._oprot)
  712. self._oprot.writeMessageEnd()
  713. self._oprot.trans.flush()
  714. def recv_CancelDelegationToken(self):
  715. iprot = self._iprot
  716. (fname, mtype, rseqid) = iprot.readMessageBegin()
  717. if mtype == TMessageType.EXCEPTION:
  718. x = TApplicationException()
  719. x.read(iprot)
  720. iprot.readMessageEnd()
  721. raise x
  722. result = CancelDelegationToken_result()
  723. result.read(iprot)
  724. iprot.readMessageEnd()
  725. if result.success is not None:
  726. return result.success
  727. raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelDelegationToken failed: unknown result")
  728. def RenewDelegationToken(self, req):
  729. """
  730. Parameters:
  731. - req
  732. """
  733. self.send_RenewDelegationToken(req)
  734. return self.recv_RenewDelegationToken()
  735. def send_RenewDelegationToken(self, req):
  736. self._oprot.writeMessageBegin('RenewDelegationToken', TMessageType.CALL, self._seqid)
  737. args = RenewDelegationToken_args()
  738. args.req = req
  739. args.write(self._oprot)
  740. self._oprot.writeMessageEnd()
  741. self._oprot.trans.flush()
  742. def recv_RenewDelegationToken(self):
  743. iprot = self._iprot
  744. (fname, mtype, rseqid) = iprot.readMessageBegin()
  745. if mtype == TMessageType.EXCEPTION:
  746. x = TApplicationException()
  747. x.read(iprot)
  748. iprot.readMessageEnd()
  749. raise x
  750. result = RenewDelegationToken_result()
  751. result.read(iprot)
  752. iprot.readMessageEnd()
  753. if result.success is not None:
  754. return result.success
  755. raise TApplicationException(TApplicationException.MISSING_RESULT, "RenewDelegationToken failed: unknown result")
  756. def GetQueryId(self, req):
  757. """
  758. Parameters:
  759. - req
  760. """
  761. self.send_GetQueryId(req)
  762. return self.recv_GetQueryId()
  763. def send_GetQueryId(self, req):
  764. self._oprot.writeMessageBegin('GetQueryId', TMessageType.CALL, self._seqid)
  765. args = GetQueryId_args()
  766. args.req = req
  767. args.write(self._oprot)
  768. self._oprot.writeMessageEnd()
  769. self._oprot.trans.flush()
  770. def recv_GetQueryId(self):
  771. iprot = self._iprot
  772. (fname, mtype, rseqid) = iprot.readMessageBegin()
  773. if mtype == TMessageType.EXCEPTION:
  774. x = TApplicationException()
  775. x.read(iprot)
  776. iprot.readMessageEnd()
  777. raise x
  778. result = GetQueryId_result()
  779. result.read(iprot)
  780. iprot.readMessageEnd()
  781. if result.success is not None:
  782. return result.success
  783. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetQueryId failed: unknown result")
  784. def SetClientInfo(self, req):
  785. """
  786. Parameters:
  787. - req
  788. """
  789. self.send_SetClientInfo(req)
  790. return self.recv_SetClientInfo()
  791. def send_SetClientInfo(self, req):
  792. self._oprot.writeMessageBegin('SetClientInfo', TMessageType.CALL, self._seqid)
  793. args = SetClientInfo_args()
  794. args.req = req
  795. args.write(self._oprot)
  796. self._oprot.writeMessageEnd()
  797. self._oprot.trans.flush()
  798. def recv_SetClientInfo(self):
  799. iprot = self._iprot
  800. (fname, mtype, rseqid) = iprot.readMessageBegin()
  801. if mtype == TMessageType.EXCEPTION:
  802. x = TApplicationException()
  803. x.read(iprot)
  804. iprot.readMessageEnd()
  805. raise x
  806. result = SetClientInfo_result()
  807. result.read(iprot)
  808. iprot.readMessageEnd()
  809. if result.success is not None:
  810. return result.success
  811. raise TApplicationException(TApplicationException.MISSING_RESULT, "SetClientInfo failed: unknown result")
  812. def GetLog(self, req):
  813. """
  814. Parameters:
  815. - req
  816. """
  817. self.send_GetLog(req)
  818. return self.recv_GetLog()
  819. def send_GetLog(self, req):
  820. self._oprot.writeMessageBegin('GetLog', TMessageType.CALL, self._seqid)
  821. args = GetLog_args()
  822. args.req = req
  823. args.write(self._oprot)
  824. self._oprot.writeMessageEnd()
  825. self._oprot.trans.flush()
  826. def recv_GetLog(self):
  827. iprot = self._iprot
  828. (fname, mtype, rseqid) = iprot.readMessageBegin()
  829. if mtype == TMessageType.EXCEPTION:
  830. x = TApplicationException()
  831. x.read(iprot)
  832. iprot.readMessageEnd()
  833. raise x
  834. result = GetLog_result()
  835. result.read(iprot)
  836. iprot.readMessageEnd()
  837. if result.success is not None:
  838. return result.success
  839. raise TApplicationException(TApplicationException.MISSING_RESULT, "GetLog failed: unknown result")
  840. class Processor(Iface, TProcessor):
  841. def __init__(self, handler):
  842. self._handler = handler
  843. self._processMap = {}
  844. self._processMap["OpenSession"] = Processor.process_OpenSession
  845. self._processMap["CloseSession"] = Processor.process_CloseSession
  846. self._processMap["GetInfo"] = Processor.process_GetInfo
  847. self._processMap["ExecuteStatement"] = Processor.process_ExecuteStatement
  848. self._processMap["GetTypeInfo"] = Processor.process_GetTypeInfo
  849. self._processMap["GetCatalogs"] = Processor.process_GetCatalogs
  850. self._processMap["GetSchemas"] = Processor.process_GetSchemas
  851. self._processMap["GetTables"] = Processor.process_GetTables
  852. self._processMap["GetTableTypes"] = Processor.process_GetTableTypes
  853. self._processMap["GetColumns"] = Processor.process_GetColumns
  854. self._processMap["GetFunctions"] = Processor.process_GetFunctions
  855. self._processMap["GetPrimaryKeys"] = Processor.process_GetPrimaryKeys
  856. self._processMap["GetCrossReference"] = Processor.process_GetCrossReference
  857. self._processMap["GetOperationStatus"] = Processor.process_GetOperationStatus
  858. self._processMap["CancelOperation"] = Processor.process_CancelOperation
  859. self._processMap["CloseOperation"] = Processor.process_CloseOperation
  860. self._processMap["GetResultSetMetadata"] = Processor.process_GetResultSetMetadata
  861. self._processMap["FetchResults"] = Processor.process_FetchResults
  862. self._processMap["GetDelegationToken"] = Processor.process_GetDelegationToken
  863. self._processMap["CancelDelegationToken"] = Processor.process_CancelDelegationToken
  864. self._processMap["RenewDelegationToken"] = Processor.process_RenewDelegationToken
  865. self._processMap["GetQueryId"] = Processor.process_GetQueryId
  866. self._processMap["SetClientInfo"] = Processor.process_SetClientInfo
  867. self._processMap["GetLog"] = Processor.process_GetLog
  868. self._on_message_begin = None
  869. def on_message_begin(self, func):
  870. self._on_message_begin = func
  871. def process(self, iprot, oprot):
  872. (name, type, seqid) = iprot.readMessageBegin()
  873. if self._on_message_begin:
  874. self._on_message_begin(name, type, seqid)
  875. if name not in self._processMap:
  876. iprot.skip(TType.STRUCT)
  877. iprot.readMessageEnd()
  878. x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
  879. oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
  880. x.write(oprot)
  881. oprot.writeMessageEnd()
  882. oprot.trans.flush()
  883. return
  884. else:
  885. self._processMap[name](self, seqid, iprot, oprot)
  886. return True
  887. def process_OpenSession(self, seqid, iprot, oprot):
  888. args = OpenSession_args()
  889. args.read(iprot)
  890. iprot.readMessageEnd()
  891. result = OpenSession_result()
  892. try:
  893. result.success = self._handler.OpenSession(args.req)
  894. msg_type = TMessageType.REPLY
  895. except TTransport.TTransportException:
  896. raise
  897. except TApplicationException as ex:
  898. logging.exception('TApplication exception in handler')
  899. msg_type = TMessageType.EXCEPTION
  900. result = ex
  901. except Exception:
  902. logging.exception('Unexpected exception in handler')
  903. msg_type = TMessageType.EXCEPTION
  904. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  905. oprot.writeMessageBegin("OpenSession", msg_type, seqid)
  906. result.write(oprot)
  907. oprot.writeMessageEnd()
  908. oprot.trans.flush()
  909. def process_CloseSession(self, seqid, iprot, oprot):
  910. args = CloseSession_args()
  911. args.read(iprot)
  912. iprot.readMessageEnd()
  913. result = CloseSession_result()
  914. try:
  915. result.success = self._handler.CloseSession(args.req)
  916. msg_type = TMessageType.REPLY
  917. except TTransport.TTransportException:
  918. raise
  919. except TApplicationException as ex:
  920. logging.exception('TApplication exception in handler')
  921. msg_type = TMessageType.EXCEPTION
  922. result = ex
  923. except Exception:
  924. logging.exception('Unexpected exception in handler')
  925. msg_type = TMessageType.EXCEPTION
  926. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  927. oprot.writeMessageBegin("CloseSession", msg_type, seqid)
  928. result.write(oprot)
  929. oprot.writeMessageEnd()
  930. oprot.trans.flush()
  931. def process_GetInfo(self, seqid, iprot, oprot):
  932. args = GetInfo_args()
  933. args.read(iprot)
  934. iprot.readMessageEnd()
  935. result = GetInfo_result()
  936. try:
  937. result.success = self._handler.GetInfo(args.req)
  938. msg_type = TMessageType.REPLY
  939. except TTransport.TTransportException:
  940. raise
  941. except TApplicationException as ex:
  942. logging.exception('TApplication exception in handler')
  943. msg_type = TMessageType.EXCEPTION
  944. result = ex
  945. except Exception:
  946. logging.exception('Unexpected exception in handler')
  947. msg_type = TMessageType.EXCEPTION
  948. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  949. oprot.writeMessageBegin("GetInfo", msg_type, seqid)
  950. result.write(oprot)
  951. oprot.writeMessageEnd()
  952. oprot.trans.flush()
  953. def process_ExecuteStatement(self, seqid, iprot, oprot):
  954. args = ExecuteStatement_args()
  955. args.read(iprot)
  956. iprot.readMessageEnd()
  957. result = ExecuteStatement_result()
  958. try:
  959. result.success = self._handler.ExecuteStatement(args.req)
  960. msg_type = TMessageType.REPLY
  961. except TTransport.TTransportException:
  962. raise
  963. except TApplicationException as ex:
  964. logging.exception('TApplication exception in handler')
  965. msg_type = TMessageType.EXCEPTION
  966. result = ex
  967. except Exception:
  968. logging.exception('Unexpected exception in handler')
  969. msg_type = TMessageType.EXCEPTION
  970. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  971. oprot.writeMessageBegin("ExecuteStatement", msg_type, seqid)
  972. result.write(oprot)
  973. oprot.writeMessageEnd()
  974. oprot.trans.flush()
  975. def process_GetTypeInfo(self, seqid, iprot, oprot):
  976. args = GetTypeInfo_args()
  977. args.read(iprot)
  978. iprot.readMessageEnd()
  979. result = GetTypeInfo_result()
  980. try:
  981. result.success = self._handler.GetTypeInfo(args.req)
  982. msg_type = TMessageType.REPLY
  983. except TTransport.TTransportException:
  984. raise
  985. except TApplicationException as ex:
  986. logging.exception('TApplication exception in handler')
  987. msg_type = TMessageType.EXCEPTION
  988. result = ex
  989. except Exception:
  990. logging.exception('Unexpected exception in handler')
  991. msg_type = TMessageType.EXCEPTION
  992. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  993. oprot.writeMessageBegin("GetTypeInfo", msg_type, seqid)
  994. result.write(oprot)
  995. oprot.writeMessageEnd()
  996. oprot.trans.flush()
  997. def process_GetCatalogs(self, seqid, iprot, oprot):
  998. args = GetCatalogs_args()
  999. args.read(iprot)
  1000. iprot.readMessageEnd()
  1001. result = GetCatalogs_result()
  1002. try:
  1003. result.success = self._handler.GetCatalogs(args.req)
  1004. msg_type = TMessageType.REPLY
  1005. except TTransport.TTransportException:
  1006. raise
  1007. except TApplicationException as ex:
  1008. logging.exception('TApplication exception in handler')
  1009. msg_type = TMessageType.EXCEPTION
  1010. result = ex
  1011. except Exception:
  1012. logging.exception('Unexpected exception in handler')
  1013. msg_type = TMessageType.EXCEPTION
  1014. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1015. oprot.writeMessageBegin("GetCatalogs", msg_type, seqid)
  1016. result.write(oprot)
  1017. oprot.writeMessageEnd()
  1018. oprot.trans.flush()
  1019. def process_GetSchemas(self, seqid, iprot, oprot):
  1020. args = GetSchemas_args()
  1021. args.read(iprot)
  1022. iprot.readMessageEnd()
  1023. result = GetSchemas_result()
  1024. try:
  1025. result.success = self._handler.GetSchemas(args.req)
  1026. msg_type = TMessageType.REPLY
  1027. except TTransport.TTransportException:
  1028. raise
  1029. except TApplicationException as ex:
  1030. logging.exception('TApplication exception in handler')
  1031. msg_type = TMessageType.EXCEPTION
  1032. result = ex
  1033. except Exception:
  1034. logging.exception('Unexpected exception in handler')
  1035. msg_type = TMessageType.EXCEPTION
  1036. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1037. oprot.writeMessageBegin("GetSchemas", msg_type, seqid)
  1038. result.write(oprot)
  1039. oprot.writeMessageEnd()
  1040. oprot.trans.flush()
  1041. def process_GetTables(self, seqid, iprot, oprot):
  1042. args = GetTables_args()
  1043. args.read(iprot)
  1044. iprot.readMessageEnd()
  1045. result = GetTables_result()
  1046. try:
  1047. result.success = self._handler.GetTables(args.req)
  1048. msg_type = TMessageType.REPLY
  1049. except TTransport.TTransportException:
  1050. raise
  1051. except TApplicationException as ex:
  1052. logging.exception('TApplication exception in handler')
  1053. msg_type = TMessageType.EXCEPTION
  1054. result = ex
  1055. except Exception:
  1056. logging.exception('Unexpected exception in handler')
  1057. msg_type = TMessageType.EXCEPTION
  1058. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1059. oprot.writeMessageBegin("GetTables", msg_type, seqid)
  1060. result.write(oprot)
  1061. oprot.writeMessageEnd()
  1062. oprot.trans.flush()
  1063. def process_GetTableTypes(self, seqid, iprot, oprot):
  1064. args = GetTableTypes_args()
  1065. args.read(iprot)
  1066. iprot.readMessageEnd()
  1067. result = GetTableTypes_result()
  1068. try:
  1069. result.success = self._handler.GetTableTypes(args.req)
  1070. msg_type = TMessageType.REPLY
  1071. except TTransport.TTransportException:
  1072. raise
  1073. except TApplicationException as ex:
  1074. logging.exception('TApplication exception in handler')
  1075. msg_type = TMessageType.EXCEPTION
  1076. result = ex
  1077. except Exception:
  1078. logging.exception('Unexpected exception in handler')
  1079. msg_type = TMessageType.EXCEPTION
  1080. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1081. oprot.writeMessageBegin("GetTableTypes", msg_type, seqid)
  1082. result.write(oprot)
  1083. oprot.writeMessageEnd()
  1084. oprot.trans.flush()
  1085. def process_GetColumns(self, seqid, iprot, oprot):
  1086. args = GetColumns_args()
  1087. args.read(iprot)
  1088. iprot.readMessageEnd()
  1089. result = GetColumns_result()
  1090. try:
  1091. result.success = self._handler.GetColumns(args.req)
  1092. msg_type = TMessageType.REPLY
  1093. except TTransport.TTransportException:
  1094. raise
  1095. except TApplicationException as ex:
  1096. logging.exception('TApplication exception in handler')
  1097. msg_type = TMessageType.EXCEPTION
  1098. result = ex
  1099. except Exception:
  1100. logging.exception('Unexpected exception in handler')
  1101. msg_type = TMessageType.EXCEPTION
  1102. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1103. oprot.writeMessageBegin("GetColumns", msg_type, seqid)
  1104. result.write(oprot)
  1105. oprot.writeMessageEnd()
  1106. oprot.trans.flush()
  1107. def process_GetFunctions(self, seqid, iprot, oprot):
  1108. args = GetFunctions_args()
  1109. args.read(iprot)
  1110. iprot.readMessageEnd()
  1111. result = GetFunctions_result()
  1112. try:
  1113. result.success = self._handler.GetFunctions(args.req)
  1114. msg_type = TMessageType.REPLY
  1115. except TTransport.TTransportException:
  1116. raise
  1117. except TApplicationException as ex:
  1118. logging.exception('TApplication exception in handler')
  1119. msg_type = TMessageType.EXCEPTION
  1120. result = ex
  1121. except Exception:
  1122. logging.exception('Unexpected exception in handler')
  1123. msg_type = TMessageType.EXCEPTION
  1124. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1125. oprot.writeMessageBegin("GetFunctions", msg_type, seqid)
  1126. result.write(oprot)
  1127. oprot.writeMessageEnd()
  1128. oprot.trans.flush()
  1129. def process_GetPrimaryKeys(self, seqid, iprot, oprot):
  1130. args = GetPrimaryKeys_args()
  1131. args.read(iprot)
  1132. iprot.readMessageEnd()
  1133. result = GetPrimaryKeys_result()
  1134. try:
  1135. result.success = self._handler.GetPrimaryKeys(args.req)
  1136. msg_type = TMessageType.REPLY
  1137. except TTransport.TTransportException:
  1138. raise
  1139. except TApplicationException as ex:
  1140. logging.exception('TApplication exception in handler')
  1141. msg_type = TMessageType.EXCEPTION
  1142. result = ex
  1143. except Exception:
  1144. logging.exception('Unexpected exception in handler')
  1145. msg_type = TMessageType.EXCEPTION
  1146. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1147. oprot.writeMessageBegin("GetPrimaryKeys", msg_type, seqid)
  1148. result.write(oprot)
  1149. oprot.writeMessageEnd()
  1150. oprot.trans.flush()
  1151. def process_GetCrossReference(self, seqid, iprot, oprot):
  1152. args = GetCrossReference_args()
  1153. args.read(iprot)
  1154. iprot.readMessageEnd()
  1155. result = GetCrossReference_result()
  1156. try:
  1157. result.success = self._handler.GetCrossReference(args.req)
  1158. msg_type = TMessageType.REPLY
  1159. except TTransport.TTransportException:
  1160. raise
  1161. except TApplicationException as ex:
  1162. logging.exception('TApplication exception in handler')
  1163. msg_type = TMessageType.EXCEPTION
  1164. result = ex
  1165. except Exception:
  1166. logging.exception('Unexpected exception in handler')
  1167. msg_type = TMessageType.EXCEPTION
  1168. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1169. oprot.writeMessageBegin("GetCrossReference", msg_type, seqid)
  1170. result.write(oprot)
  1171. oprot.writeMessageEnd()
  1172. oprot.trans.flush()
  1173. def process_GetOperationStatus(self, seqid, iprot, oprot):
  1174. args = GetOperationStatus_args()
  1175. args.read(iprot)
  1176. iprot.readMessageEnd()
  1177. result = GetOperationStatus_result()
  1178. try:
  1179. result.success = self._handler.GetOperationStatus(args.req)
  1180. msg_type = TMessageType.REPLY
  1181. except TTransport.TTransportException:
  1182. raise
  1183. except TApplicationException as ex:
  1184. logging.exception('TApplication exception in handler')
  1185. msg_type = TMessageType.EXCEPTION
  1186. result = ex
  1187. except Exception:
  1188. logging.exception('Unexpected exception in handler')
  1189. msg_type = TMessageType.EXCEPTION
  1190. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1191. oprot.writeMessageBegin("GetOperationStatus", msg_type, seqid)
  1192. result.write(oprot)
  1193. oprot.writeMessageEnd()
  1194. oprot.trans.flush()
  1195. def process_CancelOperation(self, seqid, iprot, oprot):
  1196. args = CancelOperation_args()
  1197. args.read(iprot)
  1198. iprot.readMessageEnd()
  1199. result = CancelOperation_result()
  1200. try:
  1201. result.success = self._handler.CancelOperation(args.req)
  1202. msg_type = TMessageType.REPLY
  1203. except TTransport.TTransportException:
  1204. raise
  1205. except TApplicationException as ex:
  1206. logging.exception('TApplication exception in handler')
  1207. msg_type = TMessageType.EXCEPTION
  1208. result = ex
  1209. except Exception:
  1210. logging.exception('Unexpected exception in handler')
  1211. msg_type = TMessageType.EXCEPTION
  1212. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1213. oprot.writeMessageBegin("CancelOperation", msg_type, seqid)
  1214. result.write(oprot)
  1215. oprot.writeMessageEnd()
  1216. oprot.trans.flush()
  1217. def process_CloseOperation(self, seqid, iprot, oprot):
  1218. args = CloseOperation_args()
  1219. args.read(iprot)
  1220. iprot.readMessageEnd()
  1221. result = CloseOperation_result()
  1222. try:
  1223. result.success = self._handler.CloseOperation(args.req)
  1224. msg_type = TMessageType.REPLY
  1225. except TTransport.TTransportException:
  1226. raise
  1227. except TApplicationException as ex:
  1228. logging.exception('TApplication exception in handler')
  1229. msg_type = TMessageType.EXCEPTION
  1230. result = ex
  1231. except Exception:
  1232. logging.exception('Unexpected exception in handler')
  1233. msg_type = TMessageType.EXCEPTION
  1234. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1235. oprot.writeMessageBegin("CloseOperation", msg_type, seqid)
  1236. result.write(oprot)
  1237. oprot.writeMessageEnd()
  1238. oprot.trans.flush()
  1239. def process_GetResultSetMetadata(self, seqid, iprot, oprot):
  1240. args = GetResultSetMetadata_args()
  1241. args.read(iprot)
  1242. iprot.readMessageEnd()
  1243. result = GetResultSetMetadata_result()
  1244. try:
  1245. result.success = self._handler.GetResultSetMetadata(args.req)
  1246. msg_type = TMessageType.REPLY
  1247. except TTransport.TTransportException:
  1248. raise
  1249. except TApplicationException as ex:
  1250. logging.exception('TApplication exception in handler')
  1251. msg_type = TMessageType.EXCEPTION
  1252. result = ex
  1253. except Exception:
  1254. logging.exception('Unexpected exception in handler')
  1255. msg_type = TMessageType.EXCEPTION
  1256. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1257. oprot.writeMessageBegin("GetResultSetMetadata", msg_type, seqid)
  1258. result.write(oprot)
  1259. oprot.writeMessageEnd()
  1260. oprot.trans.flush()
  1261. def process_FetchResults(self, seqid, iprot, oprot):
  1262. args = FetchResults_args()
  1263. args.read(iprot)
  1264. iprot.readMessageEnd()
  1265. result = FetchResults_result()
  1266. try:
  1267. result.success = self._handler.FetchResults(args.req)
  1268. msg_type = TMessageType.REPLY
  1269. except TTransport.TTransportException:
  1270. raise
  1271. except TApplicationException as ex:
  1272. logging.exception('TApplication exception in handler')
  1273. msg_type = TMessageType.EXCEPTION
  1274. result = ex
  1275. except Exception:
  1276. logging.exception('Unexpected exception in handler')
  1277. msg_type = TMessageType.EXCEPTION
  1278. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1279. oprot.writeMessageBegin("FetchResults", msg_type, seqid)
  1280. result.write(oprot)
  1281. oprot.writeMessageEnd()
  1282. oprot.trans.flush()
  1283. def process_GetDelegationToken(self, seqid, iprot, oprot):
  1284. args = GetDelegationToken_args()
  1285. args.read(iprot)
  1286. iprot.readMessageEnd()
  1287. result = GetDelegationToken_result()
  1288. try:
  1289. result.success = self._handler.GetDelegationToken(args.req)
  1290. msg_type = TMessageType.REPLY
  1291. except TTransport.TTransportException:
  1292. raise
  1293. except TApplicationException as ex:
  1294. logging.exception('TApplication exception in handler')
  1295. msg_type = TMessageType.EXCEPTION
  1296. result = ex
  1297. except Exception:
  1298. logging.exception('Unexpected exception in handler')
  1299. msg_type = TMessageType.EXCEPTION
  1300. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1301. oprot.writeMessageBegin("GetDelegationToken", msg_type, seqid)
  1302. result.write(oprot)
  1303. oprot.writeMessageEnd()
  1304. oprot.trans.flush()
  1305. def process_CancelDelegationToken(self, seqid, iprot, oprot):
  1306. args = CancelDelegationToken_args()
  1307. args.read(iprot)
  1308. iprot.readMessageEnd()
  1309. result = CancelDelegationToken_result()
  1310. try:
  1311. result.success = self._handler.CancelDelegationToken(args.req)
  1312. msg_type = TMessageType.REPLY
  1313. except TTransport.TTransportException:
  1314. raise
  1315. except TApplicationException as ex:
  1316. logging.exception('TApplication exception in handler')
  1317. msg_type = TMessageType.EXCEPTION
  1318. result = ex
  1319. except Exception:
  1320. logging.exception('Unexpected exception in handler')
  1321. msg_type = TMessageType.EXCEPTION
  1322. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1323. oprot.writeMessageBegin("CancelDelegationToken", msg_type, seqid)
  1324. result.write(oprot)
  1325. oprot.writeMessageEnd()
  1326. oprot.trans.flush()
  1327. def process_RenewDelegationToken(self, seqid, iprot, oprot):
  1328. args = RenewDelegationToken_args()
  1329. args.read(iprot)
  1330. iprot.readMessageEnd()
  1331. result = RenewDelegationToken_result()
  1332. try:
  1333. result.success = self._handler.RenewDelegationToken(args.req)
  1334. msg_type = TMessageType.REPLY
  1335. except TTransport.TTransportException:
  1336. raise
  1337. except TApplicationException as ex:
  1338. logging.exception('TApplication exception in handler')
  1339. msg_type = TMessageType.EXCEPTION
  1340. result = ex
  1341. except Exception:
  1342. logging.exception('Unexpected exception in handler')
  1343. msg_type = TMessageType.EXCEPTION
  1344. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1345. oprot.writeMessageBegin("RenewDelegationToken", msg_type, seqid)
  1346. result.write(oprot)
  1347. oprot.writeMessageEnd()
  1348. oprot.trans.flush()
  1349. def process_GetQueryId(self, seqid, iprot, oprot):
  1350. args = GetQueryId_args()
  1351. args.read(iprot)
  1352. iprot.readMessageEnd()
  1353. result = GetQueryId_result()
  1354. try:
  1355. result.success = self._handler.GetQueryId(args.req)
  1356. msg_type = TMessageType.REPLY
  1357. except TTransport.TTransportException:
  1358. raise
  1359. except TApplicationException as ex:
  1360. logging.exception('TApplication exception in handler')
  1361. msg_type = TMessageType.EXCEPTION
  1362. result = ex
  1363. except Exception:
  1364. logging.exception('Unexpected exception in handler')
  1365. msg_type = TMessageType.EXCEPTION
  1366. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1367. oprot.writeMessageBegin("GetQueryId", msg_type, seqid)
  1368. result.write(oprot)
  1369. oprot.writeMessageEnd()
  1370. oprot.trans.flush()
  1371. def process_SetClientInfo(self, seqid, iprot, oprot):
  1372. args = SetClientInfo_args()
  1373. args.read(iprot)
  1374. iprot.readMessageEnd()
  1375. result = SetClientInfo_result()
  1376. try:
  1377. result.success = self._handler.SetClientInfo(args.req)
  1378. msg_type = TMessageType.REPLY
  1379. except TTransport.TTransportException:
  1380. raise
  1381. except TApplicationException as ex:
  1382. logging.exception('TApplication exception in handler')
  1383. msg_type = TMessageType.EXCEPTION
  1384. result = ex
  1385. except Exception:
  1386. logging.exception('Unexpected exception in handler')
  1387. msg_type = TMessageType.EXCEPTION
  1388. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1389. oprot.writeMessageBegin("SetClientInfo", msg_type, seqid)
  1390. result.write(oprot)
  1391. oprot.writeMessageEnd()
  1392. oprot.trans.flush()
  1393. def process_GetLog(self, seqid, iprot, oprot):
  1394. args = GetLog_args()
  1395. args.read(iprot)
  1396. iprot.readMessageEnd()
  1397. result = GetLog_result()
  1398. try:
  1399. result.success = self._handler.GetLog(args.req)
  1400. msg_type = TMessageType.REPLY
  1401. except TTransport.TTransportException:
  1402. raise
  1403. except TApplicationException as ex:
  1404. logging.exception('TApplication exception in handler')
  1405. msg_type = TMessageType.EXCEPTION
  1406. result = ex
  1407. except Exception:
  1408. logging.exception('Unexpected exception in handler')
  1409. msg_type = TMessageType.EXCEPTION
  1410. result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
  1411. oprot.writeMessageBegin("GetLog", msg_type, seqid)
  1412. result.write(oprot)
  1413. oprot.writeMessageEnd()
  1414. oprot.trans.flush()
  1415. # HELPER FUNCTIONS AND STRUCTURES
  1416. class OpenSession_args(object):
  1417. """
  1418. Attributes:
  1419. - req
  1420. """
  1421. def __init__(self, req=None,):
  1422. self.req = req
  1423. def read(self, iprot):
  1424. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1425. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1426. return
  1427. iprot.readStructBegin()
  1428. while True:
  1429. (fname, ftype, fid) = iprot.readFieldBegin()
  1430. if ftype == TType.STOP:
  1431. break
  1432. if fid == 1:
  1433. if ftype == TType.STRUCT:
  1434. self.req = TOpenSessionReq()
  1435. self.req.read(iprot)
  1436. else:
  1437. iprot.skip(ftype)
  1438. else:
  1439. iprot.skip(ftype)
  1440. iprot.readFieldEnd()
  1441. iprot.readStructEnd()
  1442. def write(self, oprot):
  1443. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1444. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1445. return
  1446. oprot.writeStructBegin('OpenSession_args')
  1447. if self.req is not None:
  1448. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1449. self.req.write(oprot)
  1450. oprot.writeFieldEnd()
  1451. oprot.writeFieldStop()
  1452. oprot.writeStructEnd()
  1453. def validate(self):
  1454. return
  1455. def __repr__(self):
  1456. L = ['%s=%r' % (key, value)
  1457. for key, value in self.__dict__.items()]
  1458. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1459. def __eq__(self, other):
  1460. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1461. def __ne__(self, other):
  1462. return not (self == other)
  1463. all_structs.append(OpenSession_args)
  1464. OpenSession_args.thrift_spec = (
  1465. None, # 0
  1466. (1, TType.STRUCT, 'req', [TOpenSessionReq, None], None, ), # 1
  1467. )
  1468. class OpenSession_result(object):
  1469. """
  1470. Attributes:
  1471. - success
  1472. """
  1473. def __init__(self, success=None,):
  1474. self.success = success
  1475. def read(self, iprot):
  1476. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1477. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1478. return
  1479. iprot.readStructBegin()
  1480. while True:
  1481. (fname, ftype, fid) = iprot.readFieldBegin()
  1482. if ftype == TType.STOP:
  1483. break
  1484. if fid == 0:
  1485. if ftype == TType.STRUCT:
  1486. self.success = TOpenSessionResp()
  1487. self.success.read(iprot)
  1488. else:
  1489. iprot.skip(ftype)
  1490. else:
  1491. iprot.skip(ftype)
  1492. iprot.readFieldEnd()
  1493. iprot.readStructEnd()
  1494. def write(self, oprot):
  1495. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1496. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1497. return
  1498. oprot.writeStructBegin('OpenSession_result')
  1499. if self.success is not None:
  1500. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1501. self.success.write(oprot)
  1502. oprot.writeFieldEnd()
  1503. oprot.writeFieldStop()
  1504. oprot.writeStructEnd()
  1505. def validate(self):
  1506. return
  1507. def __repr__(self):
  1508. L = ['%s=%r' % (key, value)
  1509. for key, value in self.__dict__.items()]
  1510. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1511. def __eq__(self, other):
  1512. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1513. def __ne__(self, other):
  1514. return not (self == other)
  1515. all_structs.append(OpenSession_result)
  1516. OpenSession_result.thrift_spec = (
  1517. (0, TType.STRUCT, 'success', [TOpenSessionResp, None], None, ), # 0
  1518. )
  1519. class CloseSession_args(object):
  1520. """
  1521. Attributes:
  1522. - req
  1523. """
  1524. def __init__(self, req=None,):
  1525. self.req = req
  1526. def read(self, iprot):
  1527. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1528. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1529. return
  1530. iprot.readStructBegin()
  1531. while True:
  1532. (fname, ftype, fid) = iprot.readFieldBegin()
  1533. if ftype == TType.STOP:
  1534. break
  1535. if fid == 1:
  1536. if ftype == TType.STRUCT:
  1537. self.req = TCloseSessionReq()
  1538. self.req.read(iprot)
  1539. else:
  1540. iprot.skip(ftype)
  1541. else:
  1542. iprot.skip(ftype)
  1543. iprot.readFieldEnd()
  1544. iprot.readStructEnd()
  1545. def write(self, oprot):
  1546. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1547. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1548. return
  1549. oprot.writeStructBegin('CloseSession_args')
  1550. if self.req is not None:
  1551. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1552. self.req.write(oprot)
  1553. oprot.writeFieldEnd()
  1554. oprot.writeFieldStop()
  1555. oprot.writeStructEnd()
  1556. def validate(self):
  1557. return
  1558. def __repr__(self):
  1559. L = ['%s=%r' % (key, value)
  1560. for key, value in self.__dict__.items()]
  1561. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1562. def __eq__(self, other):
  1563. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1564. def __ne__(self, other):
  1565. return not (self == other)
  1566. all_structs.append(CloseSession_args)
  1567. CloseSession_args.thrift_spec = (
  1568. None, # 0
  1569. (1, TType.STRUCT, 'req', [TCloseSessionReq, None], None, ), # 1
  1570. )
  1571. class CloseSession_result(object):
  1572. """
  1573. Attributes:
  1574. - success
  1575. """
  1576. def __init__(self, success=None,):
  1577. self.success = success
  1578. def read(self, iprot):
  1579. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1580. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1581. return
  1582. iprot.readStructBegin()
  1583. while True:
  1584. (fname, ftype, fid) = iprot.readFieldBegin()
  1585. if ftype == TType.STOP:
  1586. break
  1587. if fid == 0:
  1588. if ftype == TType.STRUCT:
  1589. self.success = TCloseSessionResp()
  1590. self.success.read(iprot)
  1591. else:
  1592. iprot.skip(ftype)
  1593. else:
  1594. iprot.skip(ftype)
  1595. iprot.readFieldEnd()
  1596. iprot.readStructEnd()
  1597. def write(self, oprot):
  1598. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1599. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1600. return
  1601. oprot.writeStructBegin('CloseSession_result')
  1602. if self.success is not None:
  1603. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1604. self.success.write(oprot)
  1605. oprot.writeFieldEnd()
  1606. oprot.writeFieldStop()
  1607. oprot.writeStructEnd()
  1608. def validate(self):
  1609. return
  1610. def __repr__(self):
  1611. L = ['%s=%r' % (key, value)
  1612. for key, value in self.__dict__.items()]
  1613. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1614. def __eq__(self, other):
  1615. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1616. def __ne__(self, other):
  1617. return not (self == other)
  1618. all_structs.append(CloseSession_result)
  1619. CloseSession_result.thrift_spec = (
  1620. (0, TType.STRUCT, 'success', [TCloseSessionResp, None], None, ), # 0
  1621. )
  1622. class GetInfo_args(object):
  1623. """
  1624. Attributes:
  1625. - req
  1626. """
  1627. def __init__(self, req=None,):
  1628. self.req = req
  1629. def read(self, iprot):
  1630. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1631. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1632. return
  1633. iprot.readStructBegin()
  1634. while True:
  1635. (fname, ftype, fid) = iprot.readFieldBegin()
  1636. if ftype == TType.STOP:
  1637. break
  1638. if fid == 1:
  1639. if ftype == TType.STRUCT:
  1640. self.req = TGetInfoReq()
  1641. self.req.read(iprot)
  1642. else:
  1643. iprot.skip(ftype)
  1644. else:
  1645. iprot.skip(ftype)
  1646. iprot.readFieldEnd()
  1647. iprot.readStructEnd()
  1648. def write(self, oprot):
  1649. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1650. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1651. return
  1652. oprot.writeStructBegin('GetInfo_args')
  1653. if self.req is not None:
  1654. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1655. self.req.write(oprot)
  1656. oprot.writeFieldEnd()
  1657. oprot.writeFieldStop()
  1658. oprot.writeStructEnd()
  1659. def validate(self):
  1660. return
  1661. def __repr__(self):
  1662. L = ['%s=%r' % (key, value)
  1663. for key, value in self.__dict__.items()]
  1664. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1665. def __eq__(self, other):
  1666. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1667. def __ne__(self, other):
  1668. return not (self == other)
  1669. all_structs.append(GetInfo_args)
  1670. GetInfo_args.thrift_spec = (
  1671. None, # 0
  1672. (1, TType.STRUCT, 'req', [TGetInfoReq, None], None, ), # 1
  1673. )
  1674. class GetInfo_result(object):
  1675. """
  1676. Attributes:
  1677. - success
  1678. """
  1679. def __init__(self, success=None,):
  1680. self.success = success
  1681. def read(self, iprot):
  1682. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1683. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1684. return
  1685. iprot.readStructBegin()
  1686. while True:
  1687. (fname, ftype, fid) = iprot.readFieldBegin()
  1688. if ftype == TType.STOP:
  1689. break
  1690. if fid == 0:
  1691. if ftype == TType.STRUCT:
  1692. self.success = TGetInfoResp()
  1693. self.success.read(iprot)
  1694. else:
  1695. iprot.skip(ftype)
  1696. else:
  1697. iprot.skip(ftype)
  1698. iprot.readFieldEnd()
  1699. iprot.readStructEnd()
  1700. def write(self, oprot):
  1701. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1702. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1703. return
  1704. oprot.writeStructBegin('GetInfo_result')
  1705. if self.success is not None:
  1706. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1707. self.success.write(oprot)
  1708. oprot.writeFieldEnd()
  1709. oprot.writeFieldStop()
  1710. oprot.writeStructEnd()
  1711. def validate(self):
  1712. return
  1713. def __repr__(self):
  1714. L = ['%s=%r' % (key, value)
  1715. for key, value in self.__dict__.items()]
  1716. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1717. def __eq__(self, other):
  1718. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1719. def __ne__(self, other):
  1720. return not (self == other)
  1721. all_structs.append(GetInfo_result)
  1722. GetInfo_result.thrift_spec = (
  1723. (0, TType.STRUCT, 'success', [TGetInfoResp, None], None, ), # 0
  1724. )
  1725. class ExecuteStatement_args(object):
  1726. """
  1727. Attributes:
  1728. - req
  1729. """
  1730. def __init__(self, req=None,):
  1731. self.req = req
  1732. def read(self, iprot):
  1733. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1734. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1735. return
  1736. iprot.readStructBegin()
  1737. while True:
  1738. (fname, ftype, fid) = iprot.readFieldBegin()
  1739. if ftype == TType.STOP:
  1740. break
  1741. if fid == 1:
  1742. if ftype == TType.STRUCT:
  1743. self.req = TExecuteStatementReq()
  1744. self.req.read(iprot)
  1745. else:
  1746. iprot.skip(ftype)
  1747. else:
  1748. iprot.skip(ftype)
  1749. iprot.readFieldEnd()
  1750. iprot.readStructEnd()
  1751. def write(self, oprot):
  1752. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1753. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1754. return
  1755. oprot.writeStructBegin('ExecuteStatement_args')
  1756. if self.req is not None:
  1757. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1758. self.req.write(oprot)
  1759. oprot.writeFieldEnd()
  1760. oprot.writeFieldStop()
  1761. oprot.writeStructEnd()
  1762. def validate(self):
  1763. return
  1764. def __repr__(self):
  1765. L = ['%s=%r' % (key, value)
  1766. for key, value in self.__dict__.items()]
  1767. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1768. def __eq__(self, other):
  1769. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1770. def __ne__(self, other):
  1771. return not (self == other)
  1772. all_structs.append(ExecuteStatement_args)
  1773. ExecuteStatement_args.thrift_spec = (
  1774. None, # 0
  1775. (1, TType.STRUCT, 'req', [TExecuteStatementReq, None], None, ), # 1
  1776. )
  1777. class ExecuteStatement_result(object):
  1778. """
  1779. Attributes:
  1780. - success
  1781. """
  1782. def __init__(self, success=None,):
  1783. self.success = success
  1784. def read(self, iprot):
  1785. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1786. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1787. return
  1788. iprot.readStructBegin()
  1789. while True:
  1790. (fname, ftype, fid) = iprot.readFieldBegin()
  1791. if ftype == TType.STOP:
  1792. break
  1793. if fid == 0:
  1794. if ftype == TType.STRUCT:
  1795. self.success = TExecuteStatementResp()
  1796. self.success.read(iprot)
  1797. else:
  1798. iprot.skip(ftype)
  1799. else:
  1800. iprot.skip(ftype)
  1801. iprot.readFieldEnd()
  1802. iprot.readStructEnd()
  1803. def write(self, oprot):
  1804. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1805. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1806. return
  1807. oprot.writeStructBegin('ExecuteStatement_result')
  1808. if self.success is not None:
  1809. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1810. self.success.write(oprot)
  1811. oprot.writeFieldEnd()
  1812. oprot.writeFieldStop()
  1813. oprot.writeStructEnd()
  1814. def validate(self):
  1815. return
  1816. def __repr__(self):
  1817. L = ['%s=%r' % (key, value)
  1818. for key, value in self.__dict__.items()]
  1819. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1820. def __eq__(self, other):
  1821. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1822. def __ne__(self, other):
  1823. return not (self == other)
  1824. all_structs.append(ExecuteStatement_result)
  1825. ExecuteStatement_result.thrift_spec = (
  1826. (0, TType.STRUCT, 'success', [TExecuteStatementResp, None], None, ), # 0
  1827. )
  1828. class GetTypeInfo_args(object):
  1829. """
  1830. Attributes:
  1831. - req
  1832. """
  1833. def __init__(self, req=None,):
  1834. self.req = req
  1835. def read(self, iprot):
  1836. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1837. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1838. return
  1839. iprot.readStructBegin()
  1840. while True:
  1841. (fname, ftype, fid) = iprot.readFieldBegin()
  1842. if ftype == TType.STOP:
  1843. break
  1844. if fid == 1:
  1845. if ftype == TType.STRUCT:
  1846. self.req = TGetTypeInfoReq()
  1847. self.req.read(iprot)
  1848. else:
  1849. iprot.skip(ftype)
  1850. else:
  1851. iprot.skip(ftype)
  1852. iprot.readFieldEnd()
  1853. iprot.readStructEnd()
  1854. def write(self, oprot):
  1855. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1856. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1857. return
  1858. oprot.writeStructBegin('GetTypeInfo_args')
  1859. if self.req is not None:
  1860. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1861. self.req.write(oprot)
  1862. oprot.writeFieldEnd()
  1863. oprot.writeFieldStop()
  1864. oprot.writeStructEnd()
  1865. def validate(self):
  1866. return
  1867. def __repr__(self):
  1868. L = ['%s=%r' % (key, value)
  1869. for key, value in self.__dict__.items()]
  1870. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1871. def __eq__(self, other):
  1872. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1873. def __ne__(self, other):
  1874. return not (self == other)
  1875. all_structs.append(GetTypeInfo_args)
  1876. GetTypeInfo_args.thrift_spec = (
  1877. None, # 0
  1878. (1, TType.STRUCT, 'req', [TGetTypeInfoReq, None], None, ), # 1
  1879. )
  1880. class GetTypeInfo_result(object):
  1881. """
  1882. Attributes:
  1883. - success
  1884. """
  1885. def __init__(self, success=None,):
  1886. self.success = success
  1887. def read(self, iprot):
  1888. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1889. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1890. return
  1891. iprot.readStructBegin()
  1892. while True:
  1893. (fname, ftype, fid) = iprot.readFieldBegin()
  1894. if ftype == TType.STOP:
  1895. break
  1896. if fid == 0:
  1897. if ftype == TType.STRUCT:
  1898. self.success = TGetTypeInfoResp()
  1899. self.success.read(iprot)
  1900. else:
  1901. iprot.skip(ftype)
  1902. else:
  1903. iprot.skip(ftype)
  1904. iprot.readFieldEnd()
  1905. iprot.readStructEnd()
  1906. def write(self, oprot):
  1907. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1908. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1909. return
  1910. oprot.writeStructBegin('GetTypeInfo_result')
  1911. if self.success is not None:
  1912. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1913. self.success.write(oprot)
  1914. oprot.writeFieldEnd()
  1915. oprot.writeFieldStop()
  1916. oprot.writeStructEnd()
  1917. def validate(self):
  1918. return
  1919. def __repr__(self):
  1920. L = ['%s=%r' % (key, value)
  1921. for key, value in self.__dict__.items()]
  1922. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1923. def __eq__(self, other):
  1924. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1925. def __ne__(self, other):
  1926. return not (self == other)
  1927. all_structs.append(GetTypeInfo_result)
  1928. GetTypeInfo_result.thrift_spec = (
  1929. (0, TType.STRUCT, 'success', [TGetTypeInfoResp, None], None, ), # 0
  1930. )
  1931. class GetCatalogs_args(object):
  1932. """
  1933. Attributes:
  1934. - req
  1935. """
  1936. def __init__(self, req=None,):
  1937. self.req = req
  1938. def read(self, iprot):
  1939. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1940. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1941. return
  1942. iprot.readStructBegin()
  1943. while True:
  1944. (fname, ftype, fid) = iprot.readFieldBegin()
  1945. if ftype == TType.STOP:
  1946. break
  1947. if fid == 1:
  1948. if ftype == TType.STRUCT:
  1949. self.req = TGetCatalogsReq()
  1950. self.req.read(iprot)
  1951. else:
  1952. iprot.skip(ftype)
  1953. else:
  1954. iprot.skip(ftype)
  1955. iprot.readFieldEnd()
  1956. iprot.readStructEnd()
  1957. def write(self, oprot):
  1958. if oprot._fast_encode is not None and self.thrift_spec is not None:
  1959. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  1960. return
  1961. oprot.writeStructBegin('GetCatalogs_args')
  1962. if self.req is not None:
  1963. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  1964. self.req.write(oprot)
  1965. oprot.writeFieldEnd()
  1966. oprot.writeFieldStop()
  1967. oprot.writeStructEnd()
  1968. def validate(self):
  1969. return
  1970. def __repr__(self):
  1971. L = ['%s=%r' % (key, value)
  1972. for key, value in self.__dict__.items()]
  1973. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1974. def __eq__(self, other):
  1975. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1976. def __ne__(self, other):
  1977. return not (self == other)
  1978. all_structs.append(GetCatalogs_args)
  1979. GetCatalogs_args.thrift_spec = (
  1980. None, # 0
  1981. (1, TType.STRUCT, 'req', [TGetCatalogsReq, None], None, ), # 1
  1982. )
  1983. class GetCatalogs_result(object):
  1984. """
  1985. Attributes:
  1986. - success
  1987. """
  1988. def __init__(self, success=None,):
  1989. self.success = success
  1990. def read(self, iprot):
  1991. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  1992. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  1993. return
  1994. iprot.readStructBegin()
  1995. while True:
  1996. (fname, ftype, fid) = iprot.readFieldBegin()
  1997. if ftype == TType.STOP:
  1998. break
  1999. if fid == 0:
  2000. if ftype == TType.STRUCT:
  2001. self.success = TGetCatalogsResp()
  2002. self.success.read(iprot)
  2003. else:
  2004. iprot.skip(ftype)
  2005. else:
  2006. iprot.skip(ftype)
  2007. iprot.readFieldEnd()
  2008. iprot.readStructEnd()
  2009. def write(self, oprot):
  2010. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2011. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2012. return
  2013. oprot.writeStructBegin('GetCatalogs_result')
  2014. if self.success is not None:
  2015. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2016. self.success.write(oprot)
  2017. oprot.writeFieldEnd()
  2018. oprot.writeFieldStop()
  2019. oprot.writeStructEnd()
  2020. def validate(self):
  2021. return
  2022. def __repr__(self):
  2023. L = ['%s=%r' % (key, value)
  2024. for key, value in self.__dict__.items()]
  2025. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2026. def __eq__(self, other):
  2027. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2028. def __ne__(self, other):
  2029. return not (self == other)
  2030. all_structs.append(GetCatalogs_result)
  2031. GetCatalogs_result.thrift_spec = (
  2032. (0, TType.STRUCT, 'success', [TGetCatalogsResp, None], None, ), # 0
  2033. )
  2034. class GetSchemas_args(object):
  2035. """
  2036. Attributes:
  2037. - req
  2038. """
  2039. def __init__(self, req=None,):
  2040. self.req = req
  2041. def read(self, iprot):
  2042. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2043. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2044. return
  2045. iprot.readStructBegin()
  2046. while True:
  2047. (fname, ftype, fid) = iprot.readFieldBegin()
  2048. if ftype == TType.STOP:
  2049. break
  2050. if fid == 1:
  2051. if ftype == TType.STRUCT:
  2052. self.req = TGetSchemasReq()
  2053. self.req.read(iprot)
  2054. else:
  2055. iprot.skip(ftype)
  2056. else:
  2057. iprot.skip(ftype)
  2058. iprot.readFieldEnd()
  2059. iprot.readStructEnd()
  2060. def write(self, oprot):
  2061. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2062. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2063. return
  2064. oprot.writeStructBegin('GetSchemas_args')
  2065. if self.req is not None:
  2066. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2067. self.req.write(oprot)
  2068. oprot.writeFieldEnd()
  2069. oprot.writeFieldStop()
  2070. oprot.writeStructEnd()
  2071. def validate(self):
  2072. return
  2073. def __repr__(self):
  2074. L = ['%s=%r' % (key, value)
  2075. for key, value in self.__dict__.items()]
  2076. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2077. def __eq__(self, other):
  2078. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2079. def __ne__(self, other):
  2080. return not (self == other)
  2081. all_structs.append(GetSchemas_args)
  2082. GetSchemas_args.thrift_spec = (
  2083. None, # 0
  2084. (1, TType.STRUCT, 'req', [TGetSchemasReq, None], None, ), # 1
  2085. )
  2086. class GetSchemas_result(object):
  2087. """
  2088. Attributes:
  2089. - success
  2090. """
  2091. def __init__(self, success=None,):
  2092. self.success = success
  2093. def read(self, iprot):
  2094. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2095. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2096. return
  2097. iprot.readStructBegin()
  2098. while True:
  2099. (fname, ftype, fid) = iprot.readFieldBegin()
  2100. if ftype == TType.STOP:
  2101. break
  2102. if fid == 0:
  2103. if ftype == TType.STRUCT:
  2104. self.success = TGetSchemasResp()
  2105. self.success.read(iprot)
  2106. else:
  2107. iprot.skip(ftype)
  2108. else:
  2109. iprot.skip(ftype)
  2110. iprot.readFieldEnd()
  2111. iprot.readStructEnd()
  2112. def write(self, oprot):
  2113. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2114. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2115. return
  2116. oprot.writeStructBegin('GetSchemas_result')
  2117. if self.success is not None:
  2118. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2119. self.success.write(oprot)
  2120. oprot.writeFieldEnd()
  2121. oprot.writeFieldStop()
  2122. oprot.writeStructEnd()
  2123. def validate(self):
  2124. return
  2125. def __repr__(self):
  2126. L = ['%s=%r' % (key, value)
  2127. for key, value in self.__dict__.items()]
  2128. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2129. def __eq__(self, other):
  2130. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2131. def __ne__(self, other):
  2132. return not (self == other)
  2133. all_structs.append(GetSchemas_result)
  2134. GetSchemas_result.thrift_spec = (
  2135. (0, TType.STRUCT, 'success', [TGetSchemasResp, None], None, ), # 0
  2136. )
  2137. class GetTables_args(object):
  2138. """
  2139. Attributes:
  2140. - req
  2141. """
  2142. def __init__(self, req=None,):
  2143. self.req = req
  2144. def read(self, iprot):
  2145. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2146. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2147. return
  2148. iprot.readStructBegin()
  2149. while True:
  2150. (fname, ftype, fid) = iprot.readFieldBegin()
  2151. if ftype == TType.STOP:
  2152. break
  2153. if fid == 1:
  2154. if ftype == TType.STRUCT:
  2155. self.req = TGetTablesReq()
  2156. self.req.read(iprot)
  2157. else:
  2158. iprot.skip(ftype)
  2159. else:
  2160. iprot.skip(ftype)
  2161. iprot.readFieldEnd()
  2162. iprot.readStructEnd()
  2163. def write(self, oprot):
  2164. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2165. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2166. return
  2167. oprot.writeStructBegin('GetTables_args')
  2168. if self.req is not None:
  2169. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2170. self.req.write(oprot)
  2171. oprot.writeFieldEnd()
  2172. oprot.writeFieldStop()
  2173. oprot.writeStructEnd()
  2174. def validate(self):
  2175. return
  2176. def __repr__(self):
  2177. L = ['%s=%r' % (key, value)
  2178. for key, value in self.__dict__.items()]
  2179. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2180. def __eq__(self, other):
  2181. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2182. def __ne__(self, other):
  2183. return not (self == other)
  2184. all_structs.append(GetTables_args)
  2185. GetTables_args.thrift_spec = (
  2186. None, # 0
  2187. (1, TType.STRUCT, 'req', [TGetTablesReq, None], None, ), # 1
  2188. )
  2189. class GetTables_result(object):
  2190. """
  2191. Attributes:
  2192. - success
  2193. """
  2194. def __init__(self, success=None,):
  2195. self.success = success
  2196. def read(self, iprot):
  2197. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2198. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2199. return
  2200. iprot.readStructBegin()
  2201. while True:
  2202. (fname, ftype, fid) = iprot.readFieldBegin()
  2203. if ftype == TType.STOP:
  2204. break
  2205. if fid == 0:
  2206. if ftype == TType.STRUCT:
  2207. self.success = TGetTablesResp()
  2208. self.success.read(iprot)
  2209. else:
  2210. iprot.skip(ftype)
  2211. else:
  2212. iprot.skip(ftype)
  2213. iprot.readFieldEnd()
  2214. iprot.readStructEnd()
  2215. def write(self, oprot):
  2216. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2217. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2218. return
  2219. oprot.writeStructBegin('GetTables_result')
  2220. if self.success is not None:
  2221. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2222. self.success.write(oprot)
  2223. oprot.writeFieldEnd()
  2224. oprot.writeFieldStop()
  2225. oprot.writeStructEnd()
  2226. def validate(self):
  2227. return
  2228. def __repr__(self):
  2229. L = ['%s=%r' % (key, value)
  2230. for key, value in self.__dict__.items()]
  2231. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2232. def __eq__(self, other):
  2233. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2234. def __ne__(self, other):
  2235. return not (self == other)
  2236. all_structs.append(GetTables_result)
  2237. GetTables_result.thrift_spec = (
  2238. (0, TType.STRUCT, 'success', [TGetTablesResp, None], None, ), # 0
  2239. )
  2240. class GetTableTypes_args(object):
  2241. """
  2242. Attributes:
  2243. - req
  2244. """
  2245. def __init__(self, req=None,):
  2246. self.req = req
  2247. def read(self, iprot):
  2248. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2249. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2250. return
  2251. iprot.readStructBegin()
  2252. while True:
  2253. (fname, ftype, fid) = iprot.readFieldBegin()
  2254. if ftype == TType.STOP:
  2255. break
  2256. if fid == 1:
  2257. if ftype == TType.STRUCT:
  2258. self.req = TGetTableTypesReq()
  2259. self.req.read(iprot)
  2260. else:
  2261. iprot.skip(ftype)
  2262. else:
  2263. iprot.skip(ftype)
  2264. iprot.readFieldEnd()
  2265. iprot.readStructEnd()
  2266. def write(self, oprot):
  2267. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2268. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2269. return
  2270. oprot.writeStructBegin('GetTableTypes_args')
  2271. if self.req is not None:
  2272. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2273. self.req.write(oprot)
  2274. oprot.writeFieldEnd()
  2275. oprot.writeFieldStop()
  2276. oprot.writeStructEnd()
  2277. def validate(self):
  2278. return
  2279. def __repr__(self):
  2280. L = ['%s=%r' % (key, value)
  2281. for key, value in self.__dict__.items()]
  2282. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2283. def __eq__(self, other):
  2284. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2285. def __ne__(self, other):
  2286. return not (self == other)
  2287. all_structs.append(GetTableTypes_args)
  2288. GetTableTypes_args.thrift_spec = (
  2289. None, # 0
  2290. (1, TType.STRUCT, 'req', [TGetTableTypesReq, None], None, ), # 1
  2291. )
  2292. class GetTableTypes_result(object):
  2293. """
  2294. Attributes:
  2295. - success
  2296. """
  2297. def __init__(self, success=None,):
  2298. self.success = success
  2299. def read(self, iprot):
  2300. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2301. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2302. return
  2303. iprot.readStructBegin()
  2304. while True:
  2305. (fname, ftype, fid) = iprot.readFieldBegin()
  2306. if ftype == TType.STOP:
  2307. break
  2308. if fid == 0:
  2309. if ftype == TType.STRUCT:
  2310. self.success = TGetTableTypesResp()
  2311. self.success.read(iprot)
  2312. else:
  2313. iprot.skip(ftype)
  2314. else:
  2315. iprot.skip(ftype)
  2316. iprot.readFieldEnd()
  2317. iprot.readStructEnd()
  2318. def write(self, oprot):
  2319. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2320. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2321. return
  2322. oprot.writeStructBegin('GetTableTypes_result')
  2323. if self.success is not None:
  2324. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2325. self.success.write(oprot)
  2326. oprot.writeFieldEnd()
  2327. oprot.writeFieldStop()
  2328. oprot.writeStructEnd()
  2329. def validate(self):
  2330. return
  2331. def __repr__(self):
  2332. L = ['%s=%r' % (key, value)
  2333. for key, value in self.__dict__.items()]
  2334. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2335. def __eq__(self, other):
  2336. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2337. def __ne__(self, other):
  2338. return not (self == other)
  2339. all_structs.append(GetTableTypes_result)
  2340. GetTableTypes_result.thrift_spec = (
  2341. (0, TType.STRUCT, 'success', [TGetTableTypesResp, None], None, ), # 0
  2342. )
  2343. class GetColumns_args(object):
  2344. """
  2345. Attributes:
  2346. - req
  2347. """
  2348. def __init__(self, req=None,):
  2349. self.req = req
  2350. def read(self, iprot):
  2351. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2352. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2353. return
  2354. iprot.readStructBegin()
  2355. while True:
  2356. (fname, ftype, fid) = iprot.readFieldBegin()
  2357. if ftype == TType.STOP:
  2358. break
  2359. if fid == 1:
  2360. if ftype == TType.STRUCT:
  2361. self.req = TGetColumnsReq()
  2362. self.req.read(iprot)
  2363. else:
  2364. iprot.skip(ftype)
  2365. else:
  2366. iprot.skip(ftype)
  2367. iprot.readFieldEnd()
  2368. iprot.readStructEnd()
  2369. def write(self, oprot):
  2370. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2371. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2372. return
  2373. oprot.writeStructBegin('GetColumns_args')
  2374. if self.req is not None:
  2375. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2376. self.req.write(oprot)
  2377. oprot.writeFieldEnd()
  2378. oprot.writeFieldStop()
  2379. oprot.writeStructEnd()
  2380. def validate(self):
  2381. return
  2382. def __repr__(self):
  2383. L = ['%s=%r' % (key, value)
  2384. for key, value in self.__dict__.items()]
  2385. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2386. def __eq__(self, other):
  2387. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2388. def __ne__(self, other):
  2389. return not (self == other)
  2390. all_structs.append(GetColumns_args)
  2391. GetColumns_args.thrift_spec = (
  2392. None, # 0
  2393. (1, TType.STRUCT, 'req', [TGetColumnsReq, None], None, ), # 1
  2394. )
  2395. class GetColumns_result(object):
  2396. """
  2397. Attributes:
  2398. - success
  2399. """
  2400. def __init__(self, success=None,):
  2401. self.success = success
  2402. def read(self, iprot):
  2403. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2404. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2405. return
  2406. iprot.readStructBegin()
  2407. while True:
  2408. (fname, ftype, fid) = iprot.readFieldBegin()
  2409. if ftype == TType.STOP:
  2410. break
  2411. if fid == 0:
  2412. if ftype == TType.STRUCT:
  2413. self.success = TGetColumnsResp()
  2414. self.success.read(iprot)
  2415. else:
  2416. iprot.skip(ftype)
  2417. else:
  2418. iprot.skip(ftype)
  2419. iprot.readFieldEnd()
  2420. iprot.readStructEnd()
  2421. def write(self, oprot):
  2422. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2423. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2424. return
  2425. oprot.writeStructBegin('GetColumns_result')
  2426. if self.success is not None:
  2427. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2428. self.success.write(oprot)
  2429. oprot.writeFieldEnd()
  2430. oprot.writeFieldStop()
  2431. oprot.writeStructEnd()
  2432. def validate(self):
  2433. return
  2434. def __repr__(self):
  2435. L = ['%s=%r' % (key, value)
  2436. for key, value in self.__dict__.items()]
  2437. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2438. def __eq__(self, other):
  2439. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2440. def __ne__(self, other):
  2441. return not (self == other)
  2442. all_structs.append(GetColumns_result)
  2443. GetColumns_result.thrift_spec = (
  2444. (0, TType.STRUCT, 'success', [TGetColumnsResp, None], None, ), # 0
  2445. )
  2446. class GetFunctions_args(object):
  2447. """
  2448. Attributes:
  2449. - req
  2450. """
  2451. def __init__(self, req=None,):
  2452. self.req = req
  2453. def read(self, iprot):
  2454. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2455. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2456. return
  2457. iprot.readStructBegin()
  2458. while True:
  2459. (fname, ftype, fid) = iprot.readFieldBegin()
  2460. if ftype == TType.STOP:
  2461. break
  2462. if fid == 1:
  2463. if ftype == TType.STRUCT:
  2464. self.req = TGetFunctionsReq()
  2465. self.req.read(iprot)
  2466. else:
  2467. iprot.skip(ftype)
  2468. else:
  2469. iprot.skip(ftype)
  2470. iprot.readFieldEnd()
  2471. iprot.readStructEnd()
  2472. def write(self, oprot):
  2473. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2474. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2475. return
  2476. oprot.writeStructBegin('GetFunctions_args')
  2477. if self.req is not None:
  2478. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2479. self.req.write(oprot)
  2480. oprot.writeFieldEnd()
  2481. oprot.writeFieldStop()
  2482. oprot.writeStructEnd()
  2483. def validate(self):
  2484. return
  2485. def __repr__(self):
  2486. L = ['%s=%r' % (key, value)
  2487. for key, value in self.__dict__.items()]
  2488. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2489. def __eq__(self, other):
  2490. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2491. def __ne__(self, other):
  2492. return not (self == other)
  2493. all_structs.append(GetFunctions_args)
  2494. GetFunctions_args.thrift_spec = (
  2495. None, # 0
  2496. (1, TType.STRUCT, 'req', [TGetFunctionsReq, None], None, ), # 1
  2497. )
  2498. class GetFunctions_result(object):
  2499. """
  2500. Attributes:
  2501. - success
  2502. """
  2503. def __init__(self, success=None,):
  2504. self.success = success
  2505. def read(self, iprot):
  2506. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2507. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2508. return
  2509. iprot.readStructBegin()
  2510. while True:
  2511. (fname, ftype, fid) = iprot.readFieldBegin()
  2512. if ftype == TType.STOP:
  2513. break
  2514. if fid == 0:
  2515. if ftype == TType.STRUCT:
  2516. self.success = TGetFunctionsResp()
  2517. self.success.read(iprot)
  2518. else:
  2519. iprot.skip(ftype)
  2520. else:
  2521. iprot.skip(ftype)
  2522. iprot.readFieldEnd()
  2523. iprot.readStructEnd()
  2524. def write(self, oprot):
  2525. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2526. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2527. return
  2528. oprot.writeStructBegin('GetFunctions_result')
  2529. if self.success is not None:
  2530. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2531. self.success.write(oprot)
  2532. oprot.writeFieldEnd()
  2533. oprot.writeFieldStop()
  2534. oprot.writeStructEnd()
  2535. def validate(self):
  2536. return
  2537. def __repr__(self):
  2538. L = ['%s=%r' % (key, value)
  2539. for key, value in self.__dict__.items()]
  2540. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2541. def __eq__(self, other):
  2542. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2543. def __ne__(self, other):
  2544. return not (self == other)
  2545. all_structs.append(GetFunctions_result)
  2546. GetFunctions_result.thrift_spec = (
  2547. (0, TType.STRUCT, 'success', [TGetFunctionsResp, None], None, ), # 0
  2548. )
  2549. class GetPrimaryKeys_args(object):
  2550. """
  2551. Attributes:
  2552. - req
  2553. """
  2554. def __init__(self, req=None,):
  2555. self.req = req
  2556. def read(self, iprot):
  2557. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2558. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2559. return
  2560. iprot.readStructBegin()
  2561. while True:
  2562. (fname, ftype, fid) = iprot.readFieldBegin()
  2563. if ftype == TType.STOP:
  2564. break
  2565. if fid == 1:
  2566. if ftype == TType.STRUCT:
  2567. self.req = TGetPrimaryKeysReq()
  2568. self.req.read(iprot)
  2569. else:
  2570. iprot.skip(ftype)
  2571. else:
  2572. iprot.skip(ftype)
  2573. iprot.readFieldEnd()
  2574. iprot.readStructEnd()
  2575. def write(self, oprot):
  2576. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2577. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2578. return
  2579. oprot.writeStructBegin('GetPrimaryKeys_args')
  2580. if self.req is not None:
  2581. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2582. self.req.write(oprot)
  2583. oprot.writeFieldEnd()
  2584. oprot.writeFieldStop()
  2585. oprot.writeStructEnd()
  2586. def validate(self):
  2587. return
  2588. def __repr__(self):
  2589. L = ['%s=%r' % (key, value)
  2590. for key, value in self.__dict__.items()]
  2591. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2592. def __eq__(self, other):
  2593. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2594. def __ne__(self, other):
  2595. return not (self == other)
  2596. all_structs.append(GetPrimaryKeys_args)
  2597. GetPrimaryKeys_args.thrift_spec = (
  2598. None, # 0
  2599. (1, TType.STRUCT, 'req', [TGetPrimaryKeysReq, None], None, ), # 1
  2600. )
  2601. class GetPrimaryKeys_result(object):
  2602. """
  2603. Attributes:
  2604. - success
  2605. """
  2606. def __init__(self, success=None,):
  2607. self.success = success
  2608. def read(self, iprot):
  2609. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2610. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2611. return
  2612. iprot.readStructBegin()
  2613. while True:
  2614. (fname, ftype, fid) = iprot.readFieldBegin()
  2615. if ftype == TType.STOP:
  2616. break
  2617. if fid == 0:
  2618. if ftype == TType.STRUCT:
  2619. self.success = TGetPrimaryKeysResp()
  2620. self.success.read(iprot)
  2621. else:
  2622. iprot.skip(ftype)
  2623. else:
  2624. iprot.skip(ftype)
  2625. iprot.readFieldEnd()
  2626. iprot.readStructEnd()
  2627. def write(self, oprot):
  2628. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2629. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2630. return
  2631. oprot.writeStructBegin('GetPrimaryKeys_result')
  2632. if self.success is not None:
  2633. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2634. self.success.write(oprot)
  2635. oprot.writeFieldEnd()
  2636. oprot.writeFieldStop()
  2637. oprot.writeStructEnd()
  2638. def validate(self):
  2639. return
  2640. def __repr__(self):
  2641. L = ['%s=%r' % (key, value)
  2642. for key, value in self.__dict__.items()]
  2643. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2644. def __eq__(self, other):
  2645. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2646. def __ne__(self, other):
  2647. return not (self == other)
  2648. all_structs.append(GetPrimaryKeys_result)
  2649. GetPrimaryKeys_result.thrift_spec = (
  2650. (0, TType.STRUCT, 'success', [TGetPrimaryKeysResp, None], None, ), # 0
  2651. )
  2652. class GetCrossReference_args(object):
  2653. """
  2654. Attributes:
  2655. - req
  2656. """
  2657. def __init__(self, req=None,):
  2658. self.req = req
  2659. def read(self, iprot):
  2660. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2661. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2662. return
  2663. iprot.readStructBegin()
  2664. while True:
  2665. (fname, ftype, fid) = iprot.readFieldBegin()
  2666. if ftype == TType.STOP:
  2667. break
  2668. if fid == 1:
  2669. if ftype == TType.STRUCT:
  2670. self.req = TGetCrossReferenceReq()
  2671. self.req.read(iprot)
  2672. else:
  2673. iprot.skip(ftype)
  2674. else:
  2675. iprot.skip(ftype)
  2676. iprot.readFieldEnd()
  2677. iprot.readStructEnd()
  2678. def write(self, oprot):
  2679. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2680. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2681. return
  2682. oprot.writeStructBegin('GetCrossReference_args')
  2683. if self.req is not None:
  2684. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2685. self.req.write(oprot)
  2686. oprot.writeFieldEnd()
  2687. oprot.writeFieldStop()
  2688. oprot.writeStructEnd()
  2689. def validate(self):
  2690. return
  2691. def __repr__(self):
  2692. L = ['%s=%r' % (key, value)
  2693. for key, value in self.__dict__.items()]
  2694. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2695. def __eq__(self, other):
  2696. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2697. def __ne__(self, other):
  2698. return not (self == other)
  2699. all_structs.append(GetCrossReference_args)
  2700. GetCrossReference_args.thrift_spec = (
  2701. None, # 0
  2702. (1, TType.STRUCT, 'req', [TGetCrossReferenceReq, None], None, ), # 1
  2703. )
  2704. class GetCrossReference_result(object):
  2705. """
  2706. Attributes:
  2707. - success
  2708. """
  2709. def __init__(self, success=None,):
  2710. self.success = success
  2711. def read(self, iprot):
  2712. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2713. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2714. return
  2715. iprot.readStructBegin()
  2716. while True:
  2717. (fname, ftype, fid) = iprot.readFieldBegin()
  2718. if ftype == TType.STOP:
  2719. break
  2720. if fid == 0:
  2721. if ftype == TType.STRUCT:
  2722. self.success = TGetCrossReferenceResp()
  2723. self.success.read(iprot)
  2724. else:
  2725. iprot.skip(ftype)
  2726. else:
  2727. iprot.skip(ftype)
  2728. iprot.readFieldEnd()
  2729. iprot.readStructEnd()
  2730. def write(self, oprot):
  2731. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2732. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2733. return
  2734. oprot.writeStructBegin('GetCrossReference_result')
  2735. if self.success is not None:
  2736. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2737. self.success.write(oprot)
  2738. oprot.writeFieldEnd()
  2739. oprot.writeFieldStop()
  2740. oprot.writeStructEnd()
  2741. def validate(self):
  2742. return
  2743. def __repr__(self):
  2744. L = ['%s=%r' % (key, value)
  2745. for key, value in self.__dict__.items()]
  2746. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2747. def __eq__(self, other):
  2748. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2749. def __ne__(self, other):
  2750. return not (self == other)
  2751. all_structs.append(GetCrossReference_result)
  2752. GetCrossReference_result.thrift_spec = (
  2753. (0, TType.STRUCT, 'success', [TGetCrossReferenceResp, None], None, ), # 0
  2754. )
  2755. class GetOperationStatus_args(object):
  2756. """
  2757. Attributes:
  2758. - req
  2759. """
  2760. def __init__(self, req=None,):
  2761. self.req = req
  2762. def read(self, iprot):
  2763. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2764. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2765. return
  2766. iprot.readStructBegin()
  2767. while True:
  2768. (fname, ftype, fid) = iprot.readFieldBegin()
  2769. if ftype == TType.STOP:
  2770. break
  2771. if fid == 1:
  2772. if ftype == TType.STRUCT:
  2773. self.req = TGetOperationStatusReq()
  2774. self.req.read(iprot)
  2775. else:
  2776. iprot.skip(ftype)
  2777. else:
  2778. iprot.skip(ftype)
  2779. iprot.readFieldEnd()
  2780. iprot.readStructEnd()
  2781. def write(self, oprot):
  2782. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2783. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2784. return
  2785. oprot.writeStructBegin('GetOperationStatus_args')
  2786. if self.req is not None:
  2787. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2788. self.req.write(oprot)
  2789. oprot.writeFieldEnd()
  2790. oprot.writeFieldStop()
  2791. oprot.writeStructEnd()
  2792. def validate(self):
  2793. return
  2794. def __repr__(self):
  2795. L = ['%s=%r' % (key, value)
  2796. for key, value in self.__dict__.items()]
  2797. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2798. def __eq__(self, other):
  2799. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2800. def __ne__(self, other):
  2801. return not (self == other)
  2802. all_structs.append(GetOperationStatus_args)
  2803. GetOperationStatus_args.thrift_spec = (
  2804. None, # 0
  2805. (1, TType.STRUCT, 'req', [TGetOperationStatusReq, None], None, ), # 1
  2806. )
  2807. class GetOperationStatus_result(object):
  2808. """
  2809. Attributes:
  2810. - success
  2811. """
  2812. def __init__(self, success=None,):
  2813. self.success = success
  2814. def read(self, iprot):
  2815. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2816. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2817. return
  2818. iprot.readStructBegin()
  2819. while True:
  2820. (fname, ftype, fid) = iprot.readFieldBegin()
  2821. if ftype == TType.STOP:
  2822. break
  2823. if fid == 0:
  2824. if ftype == TType.STRUCT:
  2825. self.success = TGetOperationStatusResp()
  2826. self.success.read(iprot)
  2827. else:
  2828. iprot.skip(ftype)
  2829. else:
  2830. iprot.skip(ftype)
  2831. iprot.readFieldEnd()
  2832. iprot.readStructEnd()
  2833. def write(self, oprot):
  2834. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2835. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2836. return
  2837. oprot.writeStructBegin('GetOperationStatus_result')
  2838. if self.success is not None:
  2839. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2840. self.success.write(oprot)
  2841. oprot.writeFieldEnd()
  2842. oprot.writeFieldStop()
  2843. oprot.writeStructEnd()
  2844. def validate(self):
  2845. return
  2846. def __repr__(self):
  2847. L = ['%s=%r' % (key, value)
  2848. for key, value in self.__dict__.items()]
  2849. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2850. def __eq__(self, other):
  2851. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2852. def __ne__(self, other):
  2853. return not (self == other)
  2854. all_structs.append(GetOperationStatus_result)
  2855. GetOperationStatus_result.thrift_spec = (
  2856. (0, TType.STRUCT, 'success', [TGetOperationStatusResp, None], None, ), # 0
  2857. )
  2858. class CancelOperation_args(object):
  2859. """
  2860. Attributes:
  2861. - req
  2862. """
  2863. def __init__(self, req=None,):
  2864. self.req = req
  2865. def read(self, iprot):
  2866. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2867. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2868. return
  2869. iprot.readStructBegin()
  2870. while True:
  2871. (fname, ftype, fid) = iprot.readFieldBegin()
  2872. if ftype == TType.STOP:
  2873. break
  2874. if fid == 1:
  2875. if ftype == TType.STRUCT:
  2876. self.req = TCancelOperationReq()
  2877. self.req.read(iprot)
  2878. else:
  2879. iprot.skip(ftype)
  2880. else:
  2881. iprot.skip(ftype)
  2882. iprot.readFieldEnd()
  2883. iprot.readStructEnd()
  2884. def write(self, oprot):
  2885. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2886. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2887. return
  2888. oprot.writeStructBegin('CancelOperation_args')
  2889. if self.req is not None:
  2890. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2891. self.req.write(oprot)
  2892. oprot.writeFieldEnd()
  2893. oprot.writeFieldStop()
  2894. oprot.writeStructEnd()
  2895. def validate(self):
  2896. return
  2897. def __repr__(self):
  2898. L = ['%s=%r' % (key, value)
  2899. for key, value in self.__dict__.items()]
  2900. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2901. def __eq__(self, other):
  2902. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2903. def __ne__(self, other):
  2904. return not (self == other)
  2905. all_structs.append(CancelOperation_args)
  2906. CancelOperation_args.thrift_spec = (
  2907. None, # 0
  2908. (1, TType.STRUCT, 'req', [TCancelOperationReq, None], None, ), # 1
  2909. )
  2910. class CancelOperation_result(object):
  2911. """
  2912. Attributes:
  2913. - success
  2914. """
  2915. def __init__(self, success=None,):
  2916. self.success = success
  2917. def read(self, iprot):
  2918. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2919. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2920. return
  2921. iprot.readStructBegin()
  2922. while True:
  2923. (fname, ftype, fid) = iprot.readFieldBegin()
  2924. if ftype == TType.STOP:
  2925. break
  2926. if fid == 0:
  2927. if ftype == TType.STRUCT:
  2928. self.success = TCancelOperationResp()
  2929. self.success.read(iprot)
  2930. else:
  2931. iprot.skip(ftype)
  2932. else:
  2933. iprot.skip(ftype)
  2934. iprot.readFieldEnd()
  2935. iprot.readStructEnd()
  2936. def write(self, oprot):
  2937. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2938. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2939. return
  2940. oprot.writeStructBegin('CancelOperation_result')
  2941. if self.success is not None:
  2942. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2943. self.success.write(oprot)
  2944. oprot.writeFieldEnd()
  2945. oprot.writeFieldStop()
  2946. oprot.writeStructEnd()
  2947. def validate(self):
  2948. return
  2949. def __repr__(self):
  2950. L = ['%s=%r' % (key, value)
  2951. for key, value in self.__dict__.items()]
  2952. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2953. def __eq__(self, other):
  2954. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2955. def __ne__(self, other):
  2956. return not (self == other)
  2957. all_structs.append(CancelOperation_result)
  2958. CancelOperation_result.thrift_spec = (
  2959. (0, TType.STRUCT, 'success', [TCancelOperationResp, None], None, ), # 0
  2960. )
  2961. class CloseOperation_args(object):
  2962. """
  2963. Attributes:
  2964. - req
  2965. """
  2966. def __init__(self, req=None,):
  2967. self.req = req
  2968. def read(self, iprot):
  2969. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  2970. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  2971. return
  2972. iprot.readStructBegin()
  2973. while True:
  2974. (fname, ftype, fid) = iprot.readFieldBegin()
  2975. if ftype == TType.STOP:
  2976. break
  2977. if fid == 1:
  2978. if ftype == TType.STRUCT:
  2979. self.req = TCloseOperationReq()
  2980. self.req.read(iprot)
  2981. else:
  2982. iprot.skip(ftype)
  2983. else:
  2984. iprot.skip(ftype)
  2985. iprot.readFieldEnd()
  2986. iprot.readStructEnd()
  2987. def write(self, oprot):
  2988. if oprot._fast_encode is not None and self.thrift_spec is not None:
  2989. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  2990. return
  2991. oprot.writeStructBegin('CloseOperation_args')
  2992. if self.req is not None:
  2993. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  2994. self.req.write(oprot)
  2995. oprot.writeFieldEnd()
  2996. oprot.writeFieldStop()
  2997. oprot.writeStructEnd()
  2998. def validate(self):
  2999. return
  3000. def __repr__(self):
  3001. L = ['%s=%r' % (key, value)
  3002. for key, value in self.__dict__.items()]
  3003. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3004. def __eq__(self, other):
  3005. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3006. def __ne__(self, other):
  3007. return not (self == other)
  3008. all_structs.append(CloseOperation_args)
  3009. CloseOperation_args.thrift_spec = (
  3010. None, # 0
  3011. (1, TType.STRUCT, 'req', [TCloseOperationReq, None], None, ), # 1
  3012. )
  3013. class CloseOperation_result(object):
  3014. """
  3015. Attributes:
  3016. - success
  3017. """
  3018. def __init__(self, success=None,):
  3019. self.success = success
  3020. def read(self, iprot):
  3021. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3022. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3023. return
  3024. iprot.readStructBegin()
  3025. while True:
  3026. (fname, ftype, fid) = iprot.readFieldBegin()
  3027. if ftype == TType.STOP:
  3028. break
  3029. if fid == 0:
  3030. if ftype == TType.STRUCT:
  3031. self.success = TCloseOperationResp()
  3032. self.success.read(iprot)
  3033. else:
  3034. iprot.skip(ftype)
  3035. else:
  3036. iprot.skip(ftype)
  3037. iprot.readFieldEnd()
  3038. iprot.readStructEnd()
  3039. def write(self, oprot):
  3040. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3041. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3042. return
  3043. oprot.writeStructBegin('CloseOperation_result')
  3044. if self.success is not None:
  3045. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3046. self.success.write(oprot)
  3047. oprot.writeFieldEnd()
  3048. oprot.writeFieldStop()
  3049. oprot.writeStructEnd()
  3050. def validate(self):
  3051. return
  3052. def __repr__(self):
  3053. L = ['%s=%r' % (key, value)
  3054. for key, value in self.__dict__.items()]
  3055. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3056. def __eq__(self, other):
  3057. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3058. def __ne__(self, other):
  3059. return not (self == other)
  3060. all_structs.append(CloseOperation_result)
  3061. CloseOperation_result.thrift_spec = (
  3062. (0, TType.STRUCT, 'success', [TCloseOperationResp, None], None, ), # 0
  3063. )
  3064. class GetResultSetMetadata_args(object):
  3065. """
  3066. Attributes:
  3067. - req
  3068. """
  3069. def __init__(self, req=None,):
  3070. self.req = req
  3071. def read(self, iprot):
  3072. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3073. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3074. return
  3075. iprot.readStructBegin()
  3076. while True:
  3077. (fname, ftype, fid) = iprot.readFieldBegin()
  3078. if ftype == TType.STOP:
  3079. break
  3080. if fid == 1:
  3081. if ftype == TType.STRUCT:
  3082. self.req = TGetResultSetMetadataReq()
  3083. self.req.read(iprot)
  3084. else:
  3085. iprot.skip(ftype)
  3086. else:
  3087. iprot.skip(ftype)
  3088. iprot.readFieldEnd()
  3089. iprot.readStructEnd()
  3090. def write(self, oprot):
  3091. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3092. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3093. return
  3094. oprot.writeStructBegin('GetResultSetMetadata_args')
  3095. if self.req is not None:
  3096. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3097. self.req.write(oprot)
  3098. oprot.writeFieldEnd()
  3099. oprot.writeFieldStop()
  3100. oprot.writeStructEnd()
  3101. def validate(self):
  3102. return
  3103. def __repr__(self):
  3104. L = ['%s=%r' % (key, value)
  3105. for key, value in self.__dict__.items()]
  3106. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3107. def __eq__(self, other):
  3108. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3109. def __ne__(self, other):
  3110. return not (self == other)
  3111. all_structs.append(GetResultSetMetadata_args)
  3112. GetResultSetMetadata_args.thrift_spec = (
  3113. None, # 0
  3114. (1, TType.STRUCT, 'req', [TGetResultSetMetadataReq, None], None, ), # 1
  3115. )
  3116. class GetResultSetMetadata_result(object):
  3117. """
  3118. Attributes:
  3119. - success
  3120. """
  3121. def __init__(self, success=None,):
  3122. self.success = success
  3123. def read(self, iprot):
  3124. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3125. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3126. return
  3127. iprot.readStructBegin()
  3128. while True:
  3129. (fname, ftype, fid) = iprot.readFieldBegin()
  3130. if ftype == TType.STOP:
  3131. break
  3132. if fid == 0:
  3133. if ftype == TType.STRUCT:
  3134. self.success = TGetResultSetMetadataResp()
  3135. self.success.read(iprot)
  3136. else:
  3137. iprot.skip(ftype)
  3138. else:
  3139. iprot.skip(ftype)
  3140. iprot.readFieldEnd()
  3141. iprot.readStructEnd()
  3142. def write(self, oprot):
  3143. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3144. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3145. return
  3146. oprot.writeStructBegin('GetResultSetMetadata_result')
  3147. if self.success is not None:
  3148. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3149. self.success.write(oprot)
  3150. oprot.writeFieldEnd()
  3151. oprot.writeFieldStop()
  3152. oprot.writeStructEnd()
  3153. def validate(self):
  3154. return
  3155. def __repr__(self):
  3156. L = ['%s=%r' % (key, value)
  3157. for key, value in self.__dict__.items()]
  3158. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3159. def __eq__(self, other):
  3160. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3161. def __ne__(self, other):
  3162. return not (self == other)
  3163. all_structs.append(GetResultSetMetadata_result)
  3164. GetResultSetMetadata_result.thrift_spec = (
  3165. (0, TType.STRUCT, 'success', [TGetResultSetMetadataResp, None], None, ), # 0
  3166. )
  3167. class FetchResults_args(object):
  3168. """
  3169. Attributes:
  3170. - req
  3171. """
  3172. def __init__(self, req=None,):
  3173. self.req = req
  3174. def read(self, iprot):
  3175. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3176. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3177. return
  3178. iprot.readStructBegin()
  3179. while True:
  3180. (fname, ftype, fid) = iprot.readFieldBegin()
  3181. if ftype == TType.STOP:
  3182. break
  3183. if fid == 1:
  3184. if ftype == TType.STRUCT:
  3185. self.req = TFetchResultsReq()
  3186. self.req.read(iprot)
  3187. else:
  3188. iprot.skip(ftype)
  3189. else:
  3190. iprot.skip(ftype)
  3191. iprot.readFieldEnd()
  3192. iprot.readStructEnd()
  3193. def write(self, oprot):
  3194. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3195. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3196. return
  3197. oprot.writeStructBegin('FetchResults_args')
  3198. if self.req is not None:
  3199. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3200. self.req.write(oprot)
  3201. oprot.writeFieldEnd()
  3202. oprot.writeFieldStop()
  3203. oprot.writeStructEnd()
  3204. def validate(self):
  3205. return
  3206. def __repr__(self):
  3207. L = ['%s=%r' % (key, value)
  3208. for key, value in self.__dict__.items()]
  3209. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3210. def __eq__(self, other):
  3211. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3212. def __ne__(self, other):
  3213. return not (self == other)
  3214. all_structs.append(FetchResults_args)
  3215. FetchResults_args.thrift_spec = (
  3216. None, # 0
  3217. (1, TType.STRUCT, 'req', [TFetchResultsReq, None], None, ), # 1
  3218. )
  3219. class FetchResults_result(object):
  3220. """
  3221. Attributes:
  3222. - success
  3223. """
  3224. def __init__(self, success=None,):
  3225. self.success = success
  3226. def read(self, iprot):
  3227. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3228. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3229. return
  3230. iprot.readStructBegin()
  3231. while True:
  3232. (fname, ftype, fid) = iprot.readFieldBegin()
  3233. if ftype == TType.STOP:
  3234. break
  3235. if fid == 0:
  3236. if ftype == TType.STRUCT:
  3237. self.success = TFetchResultsResp()
  3238. self.success.read(iprot)
  3239. else:
  3240. iprot.skip(ftype)
  3241. else:
  3242. iprot.skip(ftype)
  3243. iprot.readFieldEnd()
  3244. iprot.readStructEnd()
  3245. def write(self, oprot):
  3246. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3247. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3248. return
  3249. oprot.writeStructBegin('FetchResults_result')
  3250. if self.success is not None:
  3251. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3252. self.success.write(oprot)
  3253. oprot.writeFieldEnd()
  3254. oprot.writeFieldStop()
  3255. oprot.writeStructEnd()
  3256. def validate(self):
  3257. return
  3258. def __repr__(self):
  3259. L = ['%s=%r' % (key, value)
  3260. for key, value in self.__dict__.items()]
  3261. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3262. def __eq__(self, other):
  3263. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3264. def __ne__(self, other):
  3265. return not (self == other)
  3266. all_structs.append(FetchResults_result)
  3267. FetchResults_result.thrift_spec = (
  3268. (0, TType.STRUCT, 'success', [TFetchResultsResp, None], None, ), # 0
  3269. )
  3270. class GetDelegationToken_args(object):
  3271. """
  3272. Attributes:
  3273. - req
  3274. """
  3275. def __init__(self, req=None,):
  3276. self.req = req
  3277. def read(self, iprot):
  3278. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3279. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3280. return
  3281. iprot.readStructBegin()
  3282. while True:
  3283. (fname, ftype, fid) = iprot.readFieldBegin()
  3284. if ftype == TType.STOP:
  3285. break
  3286. if fid == 1:
  3287. if ftype == TType.STRUCT:
  3288. self.req = TGetDelegationTokenReq()
  3289. self.req.read(iprot)
  3290. else:
  3291. iprot.skip(ftype)
  3292. else:
  3293. iprot.skip(ftype)
  3294. iprot.readFieldEnd()
  3295. iprot.readStructEnd()
  3296. def write(self, oprot):
  3297. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3298. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3299. return
  3300. oprot.writeStructBegin('GetDelegationToken_args')
  3301. if self.req is not None:
  3302. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3303. self.req.write(oprot)
  3304. oprot.writeFieldEnd()
  3305. oprot.writeFieldStop()
  3306. oprot.writeStructEnd()
  3307. def validate(self):
  3308. return
  3309. def __repr__(self):
  3310. L = ['%s=%r' % (key, value)
  3311. for key, value in self.__dict__.items()]
  3312. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3313. def __eq__(self, other):
  3314. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3315. def __ne__(self, other):
  3316. return not (self == other)
  3317. all_structs.append(GetDelegationToken_args)
  3318. GetDelegationToken_args.thrift_spec = (
  3319. None, # 0
  3320. (1, TType.STRUCT, 'req', [TGetDelegationTokenReq, None], None, ), # 1
  3321. )
  3322. class GetDelegationToken_result(object):
  3323. """
  3324. Attributes:
  3325. - success
  3326. """
  3327. def __init__(self, success=None,):
  3328. self.success = success
  3329. def read(self, iprot):
  3330. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3331. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3332. return
  3333. iprot.readStructBegin()
  3334. while True:
  3335. (fname, ftype, fid) = iprot.readFieldBegin()
  3336. if ftype == TType.STOP:
  3337. break
  3338. if fid == 0:
  3339. if ftype == TType.STRUCT:
  3340. self.success = TGetDelegationTokenResp()
  3341. self.success.read(iprot)
  3342. else:
  3343. iprot.skip(ftype)
  3344. else:
  3345. iprot.skip(ftype)
  3346. iprot.readFieldEnd()
  3347. iprot.readStructEnd()
  3348. def write(self, oprot):
  3349. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3350. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3351. return
  3352. oprot.writeStructBegin('GetDelegationToken_result')
  3353. if self.success is not None:
  3354. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3355. self.success.write(oprot)
  3356. oprot.writeFieldEnd()
  3357. oprot.writeFieldStop()
  3358. oprot.writeStructEnd()
  3359. def validate(self):
  3360. return
  3361. def __repr__(self):
  3362. L = ['%s=%r' % (key, value)
  3363. for key, value in self.__dict__.items()]
  3364. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3365. def __eq__(self, other):
  3366. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3367. def __ne__(self, other):
  3368. return not (self == other)
  3369. all_structs.append(GetDelegationToken_result)
  3370. GetDelegationToken_result.thrift_spec = (
  3371. (0, TType.STRUCT, 'success', [TGetDelegationTokenResp, None], None, ), # 0
  3372. )
  3373. class CancelDelegationToken_args(object):
  3374. """
  3375. Attributes:
  3376. - req
  3377. """
  3378. def __init__(self, req=None,):
  3379. self.req = req
  3380. def read(self, iprot):
  3381. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3382. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3383. return
  3384. iprot.readStructBegin()
  3385. while True:
  3386. (fname, ftype, fid) = iprot.readFieldBegin()
  3387. if ftype == TType.STOP:
  3388. break
  3389. if fid == 1:
  3390. if ftype == TType.STRUCT:
  3391. self.req = TCancelDelegationTokenReq()
  3392. self.req.read(iprot)
  3393. else:
  3394. iprot.skip(ftype)
  3395. else:
  3396. iprot.skip(ftype)
  3397. iprot.readFieldEnd()
  3398. iprot.readStructEnd()
  3399. def write(self, oprot):
  3400. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3401. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3402. return
  3403. oprot.writeStructBegin('CancelDelegationToken_args')
  3404. if self.req is not None:
  3405. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3406. self.req.write(oprot)
  3407. oprot.writeFieldEnd()
  3408. oprot.writeFieldStop()
  3409. oprot.writeStructEnd()
  3410. def validate(self):
  3411. return
  3412. def __repr__(self):
  3413. L = ['%s=%r' % (key, value)
  3414. for key, value in self.__dict__.items()]
  3415. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3416. def __eq__(self, other):
  3417. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3418. def __ne__(self, other):
  3419. return not (self == other)
  3420. all_structs.append(CancelDelegationToken_args)
  3421. CancelDelegationToken_args.thrift_spec = (
  3422. None, # 0
  3423. (1, TType.STRUCT, 'req', [TCancelDelegationTokenReq, None], None, ), # 1
  3424. )
  3425. class CancelDelegationToken_result(object):
  3426. """
  3427. Attributes:
  3428. - success
  3429. """
  3430. def __init__(self, success=None,):
  3431. self.success = success
  3432. def read(self, iprot):
  3433. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3434. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3435. return
  3436. iprot.readStructBegin()
  3437. while True:
  3438. (fname, ftype, fid) = iprot.readFieldBegin()
  3439. if ftype == TType.STOP:
  3440. break
  3441. if fid == 0:
  3442. if ftype == TType.STRUCT:
  3443. self.success = TCancelDelegationTokenResp()
  3444. self.success.read(iprot)
  3445. else:
  3446. iprot.skip(ftype)
  3447. else:
  3448. iprot.skip(ftype)
  3449. iprot.readFieldEnd()
  3450. iprot.readStructEnd()
  3451. def write(self, oprot):
  3452. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3453. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3454. return
  3455. oprot.writeStructBegin('CancelDelegationToken_result')
  3456. if self.success is not None:
  3457. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3458. self.success.write(oprot)
  3459. oprot.writeFieldEnd()
  3460. oprot.writeFieldStop()
  3461. oprot.writeStructEnd()
  3462. def validate(self):
  3463. return
  3464. def __repr__(self):
  3465. L = ['%s=%r' % (key, value)
  3466. for key, value in self.__dict__.items()]
  3467. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3468. def __eq__(self, other):
  3469. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3470. def __ne__(self, other):
  3471. return not (self == other)
  3472. all_structs.append(CancelDelegationToken_result)
  3473. CancelDelegationToken_result.thrift_spec = (
  3474. (0, TType.STRUCT, 'success', [TCancelDelegationTokenResp, None], None, ), # 0
  3475. )
  3476. class RenewDelegationToken_args(object):
  3477. """
  3478. Attributes:
  3479. - req
  3480. """
  3481. def __init__(self, req=None,):
  3482. self.req = req
  3483. def read(self, iprot):
  3484. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3485. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3486. return
  3487. iprot.readStructBegin()
  3488. while True:
  3489. (fname, ftype, fid) = iprot.readFieldBegin()
  3490. if ftype == TType.STOP:
  3491. break
  3492. if fid == 1:
  3493. if ftype == TType.STRUCT:
  3494. self.req = TRenewDelegationTokenReq()
  3495. self.req.read(iprot)
  3496. else:
  3497. iprot.skip(ftype)
  3498. else:
  3499. iprot.skip(ftype)
  3500. iprot.readFieldEnd()
  3501. iprot.readStructEnd()
  3502. def write(self, oprot):
  3503. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3504. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3505. return
  3506. oprot.writeStructBegin('RenewDelegationToken_args')
  3507. if self.req is not None:
  3508. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3509. self.req.write(oprot)
  3510. oprot.writeFieldEnd()
  3511. oprot.writeFieldStop()
  3512. oprot.writeStructEnd()
  3513. def validate(self):
  3514. return
  3515. def __repr__(self):
  3516. L = ['%s=%r' % (key, value)
  3517. for key, value in self.__dict__.items()]
  3518. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3519. def __eq__(self, other):
  3520. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3521. def __ne__(self, other):
  3522. return not (self == other)
  3523. all_structs.append(RenewDelegationToken_args)
  3524. RenewDelegationToken_args.thrift_spec = (
  3525. None, # 0
  3526. (1, TType.STRUCT, 'req', [TRenewDelegationTokenReq, None], None, ), # 1
  3527. )
  3528. class RenewDelegationToken_result(object):
  3529. """
  3530. Attributes:
  3531. - success
  3532. """
  3533. def __init__(self, success=None,):
  3534. self.success = success
  3535. def read(self, iprot):
  3536. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3537. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3538. return
  3539. iprot.readStructBegin()
  3540. while True:
  3541. (fname, ftype, fid) = iprot.readFieldBegin()
  3542. if ftype == TType.STOP:
  3543. break
  3544. if fid == 0:
  3545. if ftype == TType.STRUCT:
  3546. self.success = TRenewDelegationTokenResp()
  3547. self.success.read(iprot)
  3548. else:
  3549. iprot.skip(ftype)
  3550. else:
  3551. iprot.skip(ftype)
  3552. iprot.readFieldEnd()
  3553. iprot.readStructEnd()
  3554. def write(self, oprot):
  3555. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3556. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3557. return
  3558. oprot.writeStructBegin('RenewDelegationToken_result')
  3559. if self.success is not None:
  3560. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3561. self.success.write(oprot)
  3562. oprot.writeFieldEnd()
  3563. oprot.writeFieldStop()
  3564. oprot.writeStructEnd()
  3565. def validate(self):
  3566. return
  3567. def __repr__(self):
  3568. L = ['%s=%r' % (key, value)
  3569. for key, value in self.__dict__.items()]
  3570. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3571. def __eq__(self, other):
  3572. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3573. def __ne__(self, other):
  3574. return not (self == other)
  3575. all_structs.append(RenewDelegationToken_result)
  3576. RenewDelegationToken_result.thrift_spec = (
  3577. (0, TType.STRUCT, 'success', [TRenewDelegationTokenResp, None], None, ), # 0
  3578. )
  3579. class GetQueryId_args(object):
  3580. """
  3581. Attributes:
  3582. - req
  3583. """
  3584. def __init__(self, req=None,):
  3585. self.req = req
  3586. def read(self, iprot):
  3587. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3588. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3589. return
  3590. iprot.readStructBegin()
  3591. while True:
  3592. (fname, ftype, fid) = iprot.readFieldBegin()
  3593. if ftype == TType.STOP:
  3594. break
  3595. if fid == 1:
  3596. if ftype == TType.STRUCT:
  3597. self.req = TGetQueryIdReq()
  3598. self.req.read(iprot)
  3599. else:
  3600. iprot.skip(ftype)
  3601. else:
  3602. iprot.skip(ftype)
  3603. iprot.readFieldEnd()
  3604. iprot.readStructEnd()
  3605. def write(self, oprot):
  3606. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3607. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3608. return
  3609. oprot.writeStructBegin('GetQueryId_args')
  3610. if self.req is not None:
  3611. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3612. self.req.write(oprot)
  3613. oprot.writeFieldEnd()
  3614. oprot.writeFieldStop()
  3615. oprot.writeStructEnd()
  3616. def validate(self):
  3617. return
  3618. def __repr__(self):
  3619. L = ['%s=%r' % (key, value)
  3620. for key, value in self.__dict__.items()]
  3621. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3622. def __eq__(self, other):
  3623. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3624. def __ne__(self, other):
  3625. return not (self == other)
  3626. all_structs.append(GetQueryId_args)
  3627. GetQueryId_args.thrift_spec = (
  3628. None, # 0
  3629. (1, TType.STRUCT, 'req', [TGetQueryIdReq, None], None, ), # 1
  3630. )
  3631. class GetQueryId_result(object):
  3632. """
  3633. Attributes:
  3634. - success
  3635. """
  3636. def __init__(self, success=None,):
  3637. self.success = success
  3638. def read(self, iprot):
  3639. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3640. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3641. return
  3642. iprot.readStructBegin()
  3643. while True:
  3644. (fname, ftype, fid) = iprot.readFieldBegin()
  3645. if ftype == TType.STOP:
  3646. break
  3647. if fid == 0:
  3648. if ftype == TType.STRUCT:
  3649. self.success = TGetQueryIdResp()
  3650. self.success.read(iprot)
  3651. else:
  3652. iprot.skip(ftype)
  3653. else:
  3654. iprot.skip(ftype)
  3655. iprot.readFieldEnd()
  3656. iprot.readStructEnd()
  3657. def write(self, oprot):
  3658. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3659. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3660. return
  3661. oprot.writeStructBegin('GetQueryId_result')
  3662. if self.success is not None:
  3663. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3664. self.success.write(oprot)
  3665. oprot.writeFieldEnd()
  3666. oprot.writeFieldStop()
  3667. oprot.writeStructEnd()
  3668. def validate(self):
  3669. return
  3670. def __repr__(self):
  3671. L = ['%s=%r' % (key, value)
  3672. for key, value in self.__dict__.items()]
  3673. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3674. def __eq__(self, other):
  3675. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3676. def __ne__(self, other):
  3677. return not (self == other)
  3678. all_structs.append(GetQueryId_result)
  3679. GetQueryId_result.thrift_spec = (
  3680. (0, TType.STRUCT, 'success', [TGetQueryIdResp, None], None, ), # 0
  3681. )
  3682. class SetClientInfo_args(object):
  3683. """
  3684. Attributes:
  3685. - req
  3686. """
  3687. def __init__(self, req=None,):
  3688. self.req = req
  3689. def read(self, iprot):
  3690. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3691. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3692. return
  3693. iprot.readStructBegin()
  3694. while True:
  3695. (fname, ftype, fid) = iprot.readFieldBegin()
  3696. if ftype == TType.STOP:
  3697. break
  3698. if fid == 1:
  3699. if ftype == TType.STRUCT:
  3700. self.req = TSetClientInfoReq()
  3701. self.req.read(iprot)
  3702. else:
  3703. iprot.skip(ftype)
  3704. else:
  3705. iprot.skip(ftype)
  3706. iprot.readFieldEnd()
  3707. iprot.readStructEnd()
  3708. def write(self, oprot):
  3709. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3710. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3711. return
  3712. oprot.writeStructBegin('SetClientInfo_args')
  3713. if self.req is not None:
  3714. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3715. self.req.write(oprot)
  3716. oprot.writeFieldEnd()
  3717. oprot.writeFieldStop()
  3718. oprot.writeStructEnd()
  3719. def validate(self):
  3720. return
  3721. def __repr__(self):
  3722. L = ['%s=%r' % (key, value)
  3723. for key, value in self.__dict__.items()]
  3724. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3725. def __eq__(self, other):
  3726. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3727. def __ne__(self, other):
  3728. return not (self == other)
  3729. all_structs.append(SetClientInfo_args)
  3730. SetClientInfo_args.thrift_spec = (
  3731. None, # 0
  3732. (1, TType.STRUCT, 'req', [TSetClientInfoReq, None], None, ), # 1
  3733. )
  3734. class SetClientInfo_result(object):
  3735. """
  3736. Attributes:
  3737. - success
  3738. """
  3739. def __init__(self, success=None,):
  3740. self.success = success
  3741. def read(self, iprot):
  3742. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3743. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3744. return
  3745. iprot.readStructBegin()
  3746. while True:
  3747. (fname, ftype, fid) = iprot.readFieldBegin()
  3748. if ftype == TType.STOP:
  3749. break
  3750. if fid == 0:
  3751. if ftype == TType.STRUCT:
  3752. self.success = TSetClientInfoResp()
  3753. self.success.read(iprot)
  3754. else:
  3755. iprot.skip(ftype)
  3756. else:
  3757. iprot.skip(ftype)
  3758. iprot.readFieldEnd()
  3759. iprot.readStructEnd()
  3760. def write(self, oprot):
  3761. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3762. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3763. return
  3764. oprot.writeStructBegin('SetClientInfo_result')
  3765. if self.success is not None:
  3766. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3767. self.success.write(oprot)
  3768. oprot.writeFieldEnd()
  3769. oprot.writeFieldStop()
  3770. oprot.writeStructEnd()
  3771. def validate(self):
  3772. return
  3773. def __repr__(self):
  3774. L = ['%s=%r' % (key, value)
  3775. for key, value in self.__dict__.items()]
  3776. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3777. def __eq__(self, other):
  3778. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3779. def __ne__(self, other):
  3780. return not (self == other)
  3781. all_structs.append(SetClientInfo_result)
  3782. SetClientInfo_result.thrift_spec = (
  3783. (0, TType.STRUCT, 'success', [TSetClientInfoResp, None], None, ), # 0
  3784. )
  3785. class GetLog_args(object):
  3786. """
  3787. Attributes:
  3788. - req
  3789. """
  3790. def __init__(self, req=None,):
  3791. self.req = req
  3792. def read(self, iprot):
  3793. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3794. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3795. return
  3796. iprot.readStructBegin()
  3797. while True:
  3798. (fname, ftype, fid) = iprot.readFieldBegin()
  3799. if ftype == TType.STOP:
  3800. break
  3801. if fid == 1:
  3802. if ftype == TType.STRUCT:
  3803. self.req = TGetLogReq()
  3804. self.req.read(iprot)
  3805. else:
  3806. iprot.skip(ftype)
  3807. else:
  3808. iprot.skip(ftype)
  3809. iprot.readFieldEnd()
  3810. iprot.readStructEnd()
  3811. def write(self, oprot):
  3812. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3813. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3814. return
  3815. oprot.writeStructBegin('GetLog_args')
  3816. if self.req is not None:
  3817. oprot.writeFieldBegin('req', TType.STRUCT, 1)
  3818. self.req.write(oprot)
  3819. oprot.writeFieldEnd()
  3820. oprot.writeFieldStop()
  3821. oprot.writeStructEnd()
  3822. def validate(self):
  3823. return
  3824. def __repr__(self):
  3825. L = ['%s=%r' % (key, value)
  3826. for key, value in self.__dict__.items()]
  3827. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3828. def __eq__(self, other):
  3829. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3830. def __ne__(self, other):
  3831. return not (self == other)
  3832. all_structs.append(GetLog_args)
  3833. GetLog_args.thrift_spec = (
  3834. None, # 0
  3835. (1, TType.STRUCT, 'req', [TGetLogReq, None], None, ), # 1
  3836. )
  3837. class GetLog_result(object):
  3838. """
  3839. Attributes:
  3840. - success
  3841. """
  3842. def __init__(self, success=None,):
  3843. self.success = success
  3844. def read(self, iprot):
  3845. if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
  3846. iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
  3847. return
  3848. iprot.readStructBegin()
  3849. while True:
  3850. (fname, ftype, fid) = iprot.readFieldBegin()
  3851. if ftype == TType.STOP:
  3852. break
  3853. if fid == 0:
  3854. if ftype == TType.STRUCT:
  3855. self.success = TGetLogResp()
  3856. self.success.read(iprot)
  3857. else:
  3858. iprot.skip(ftype)
  3859. else:
  3860. iprot.skip(ftype)
  3861. iprot.readFieldEnd()
  3862. iprot.readStructEnd()
  3863. def write(self, oprot):
  3864. if oprot._fast_encode is not None and self.thrift_spec is not None:
  3865. oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
  3866. return
  3867. oprot.writeStructBegin('GetLog_result')
  3868. if self.success is not None:
  3869. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3870. self.success.write(oprot)
  3871. oprot.writeFieldEnd()
  3872. oprot.writeFieldStop()
  3873. oprot.writeStructEnd()
  3874. def validate(self):
  3875. return
  3876. def __repr__(self):
  3877. L = ['%s=%r' % (key, value)
  3878. for key, value in self.__dict__.items()]
  3879. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3880. def __eq__(self, other):
  3881. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3882. def __ne__(self, other):
  3883. return not (self == other)
  3884. all_structs.append(GetLog_result)
  3885. GetLog_result.thrift_spec = (
  3886. (0, TType.STRUCT, 'success', [TGetLogResp, None], None, ), # 0
  3887. )
  3888. fix_spec(all_structs)
  3889. del all_structs