TCLIService.py 102 KB

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