TCLIService.py 112 KB

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