TCLIService.py 82 KB

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