TCLIService.py 82 KB

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