TCLIService.py 87 KB

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