Jobtracker.py 159 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972497349744975497649774978497949804981498249834984498549864987498849894990499149924993499449954996499749984999500050015002500350045005500650075008500950105011501250135014501550165017501850195020502150225023502450255026502750285029503050315032503350345035503650375038503950405041504250435044504550465047504850495050505150525053505450555056505750585059506050615062506350645065506650675068506950705071507250735074507550765077507850795080508150825083508450855086508750885089509050915092509350945095509650975098509951005101510251035104510551065107510851095110511151125113511451155116511751185119512051215122512351245125512651275128512951305131513251335134513551365137513851395140514151425143514451455146514751485149515051515152515351545155515651575158515951605161516251635164516551665167516851695170517151725173517451755176517751785179518051815182518351845185518651875188518951905191519251935194519551965197519851995200520152025203520452055206520752085209521052115212521352145215521652175218521952205221522252235224522552265227522852295230523152325233523452355236523752385239524052415242524352445245524652475248524952505251525252535254525552565257525852595260526152625263526452655266526752685269527052715272527352745275527652775278527952805281528252835284528552865287528852895290529152925293529452955296529752985299530053015302530353045305530653075308530953105311531253135314531553165317531853195320532153225323532453255326532753285329533053315332533353345335533653375338533953405341534253435344534553465347534853495350535153525353535453555356535753585359536053615362536353645365536653675368536953705371537253735374537553765377
  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. import hadoop.api.common.HadoopServiceBase
  10. from ttypes import *
  11. from thrift.Thrift import TProcessor
  12. from thrift.transport import TTransport
  13. from thrift.protocol import TBinaryProtocol, TProtocol
  14. try:
  15. from thrift.protocol import fastbinary
  16. except:
  17. fastbinary = None
  18. class Iface(hadoop.api.common.HadoopServiceBase.Iface):
  19. """
  20. A proxy service onto a Jobtracker, exposing read-only methods for cluster monitoring
  21. """
  22. def getJobTrackerName(self, ctx):
  23. """
  24. Get the name of the tracker exporting this service
  25. Parameters:
  26. - ctx
  27. """
  28. pass
  29. def getClusterStatus(self, ctx):
  30. """
  31. Get the current cluster status
  32. Parameters:
  33. - ctx
  34. """
  35. pass
  36. def getQueues(self, ctx):
  37. """
  38. Get a list of job queues managed by this tracker
  39. Parameters:
  40. - ctx
  41. """
  42. pass
  43. def getJob(self, ctx, jobID):
  44. """
  45. Get a job by ID
  46. Parameters:
  47. - ctx
  48. - jobID
  49. """
  50. pass
  51. def getRunningJobs(self, ctx):
  52. """
  53. Get a list of currently running jobs
  54. Parameters:
  55. - ctx
  56. """
  57. pass
  58. def getCompletedJobs(self, ctx):
  59. """
  60. Get a list of completed jobs
  61. Parameters:
  62. - ctx
  63. """
  64. pass
  65. def getRetiredJob(self, ctx, jobID):
  66. """
  67. Get a retired job
  68. Parameters:
  69. - ctx
  70. - jobID
  71. """
  72. pass
  73. def getRetiredJobs(self, ctx, state):
  74. """
  75. Get a list of retired jobs
  76. Parameters:
  77. - ctx
  78. - state
  79. """
  80. pass
  81. def getFailedJobs(self, ctx):
  82. """
  83. Get a list of failed (due to error, not killed) jobs
  84. Parameters:
  85. - ctx
  86. """
  87. pass
  88. def getKilledJobs(self, ctx):
  89. """
  90. Get a list of killed jobs
  91. Parameters:
  92. - ctx
  93. """
  94. pass
  95. def getAllJobs(self, ctx):
  96. """
  97. Get a list of all failed, completed and running jobs (could be expensive!)
  98. Parameters:
  99. - ctx
  100. """
  101. pass
  102. def getUserJobCounts(self, ctx, user):
  103. """
  104. Get the count of jobs by status for a given user
  105. Parameters:
  106. - ctx
  107. - user
  108. """
  109. pass
  110. def getTaskList(self, ctx, jobID, types, states, text, count, offset):
  111. """
  112. Get a (possibly incomplete) list of tasks
  113. Parameters:
  114. - ctx
  115. - jobID
  116. - types
  117. - states
  118. - text
  119. - count
  120. - offset
  121. """
  122. pass
  123. def getTask(self, ctx, taskID):
  124. """
  125. Get details of a task
  126. Parameters:
  127. - ctx
  128. - taskID
  129. """
  130. pass
  131. def getJobCounters(self, ctx, jobID):
  132. """
  133. Get a list of groups of counters attached to the job with provided id.
  134. This returns the total counters
  135. Parameters:
  136. - ctx
  137. - jobID
  138. """
  139. pass
  140. def getJobCounterRollups(self, ctx, jobID):
  141. """
  142. Return job counters rolled up by map, reduce, and total
  143. Parameters:
  144. - ctx
  145. - jobID
  146. """
  147. pass
  148. def getActiveTrackers(self, ctx):
  149. """
  150. Get all active trackers
  151. Parameters:
  152. - ctx
  153. """
  154. pass
  155. def getBlacklistedTrackers(self, ctx):
  156. """
  157. Get all blacklisted trackers
  158. Parameters:
  159. - ctx
  160. """
  161. pass
  162. def getAllTrackers(self, ctx):
  163. """
  164. Get all trackers
  165. Parameters:
  166. - ctx
  167. """
  168. pass
  169. def getTracker(self, ctx, name):
  170. """
  171. Get a single task tracker by name
  172. Parameters:
  173. - ctx
  174. - name
  175. """
  176. pass
  177. def getCurrentTime(self, ctx):
  178. """
  179. Get the current time in ms according to the JT
  180. Parameters:
  181. - ctx
  182. """
  183. pass
  184. def getJobConfXML(self, ctx, jobID):
  185. """
  186. Get the xml for a job's configuration, serialised from the local filesystem on the JT
  187. Parameters:
  188. - ctx
  189. - jobID
  190. """
  191. pass
  192. def killJob(self, ctx, jobID):
  193. """
  194. Kill a job
  195. Parameters:
  196. - ctx
  197. - jobID
  198. """
  199. pass
  200. def killTaskAttempt(self, ctx, attemptID):
  201. """
  202. Kill a task attempt
  203. Parameters:
  204. - ctx
  205. - attemptID
  206. """
  207. pass
  208. def setJobPriority(self, ctx, jobID, priority):
  209. """
  210. Set a job's priority
  211. Parameters:
  212. - ctx
  213. - jobID
  214. - priority
  215. """
  216. pass
  217. def getDelegationToken(self, ctx, renewer):
  218. """
  219. Get an MR delegation token.
  220. Parameters:
  221. - ctx
  222. - renewer
  223. """
  224. pass
  225. class Client(hadoop.api.common.HadoopServiceBase.Client, Iface):
  226. """
  227. A proxy service onto a Jobtracker, exposing read-only methods for cluster monitoring
  228. """
  229. def __init__(self, iprot, oprot=None):
  230. hadoop.api.common.HadoopServiceBase.Client.__init__(self, iprot, oprot)
  231. def getJobTrackerName(self, ctx):
  232. """
  233. Get the name of the tracker exporting this service
  234. Parameters:
  235. - ctx
  236. """
  237. self.send_getJobTrackerName(ctx)
  238. return self.recv_getJobTrackerName()
  239. def send_getJobTrackerName(self, ctx):
  240. self._oprot.writeMessageBegin('getJobTrackerName', TMessageType.CALL, self._seqid)
  241. args = getJobTrackerName_args()
  242. args.ctx = ctx
  243. args.write(self._oprot)
  244. self._oprot.writeMessageEnd()
  245. self._oprot.trans.flush()
  246. def recv_getJobTrackerName(self, ):
  247. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  248. if mtype == TMessageType.EXCEPTION:
  249. x = TApplicationException()
  250. x.read(self._iprot)
  251. self._iprot.readMessageEnd()
  252. raise x
  253. result = getJobTrackerName_result()
  254. result.read(self._iprot)
  255. self._iprot.readMessageEnd()
  256. if result.success is not None:
  257. return result.success
  258. raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobTrackerName failed: unknown result");
  259. def getClusterStatus(self, ctx):
  260. """
  261. Get the current cluster status
  262. Parameters:
  263. - ctx
  264. """
  265. self.send_getClusterStatus(ctx)
  266. return self.recv_getClusterStatus()
  267. def send_getClusterStatus(self, ctx):
  268. self._oprot.writeMessageBegin('getClusterStatus', TMessageType.CALL, self._seqid)
  269. args = getClusterStatus_args()
  270. args.ctx = ctx
  271. args.write(self._oprot)
  272. self._oprot.writeMessageEnd()
  273. self._oprot.trans.flush()
  274. def recv_getClusterStatus(self, ):
  275. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  276. if mtype == TMessageType.EXCEPTION:
  277. x = TApplicationException()
  278. x.read(self._iprot)
  279. self._iprot.readMessageEnd()
  280. raise x
  281. result = getClusterStatus_result()
  282. result.read(self._iprot)
  283. self._iprot.readMessageEnd()
  284. if result.success is not None:
  285. return result.success
  286. raise TApplicationException(TApplicationException.MISSING_RESULT, "getClusterStatus failed: unknown result");
  287. def getQueues(self, ctx):
  288. """
  289. Get a list of job queues managed by this tracker
  290. Parameters:
  291. - ctx
  292. """
  293. self.send_getQueues(ctx)
  294. return self.recv_getQueues()
  295. def send_getQueues(self, ctx):
  296. self._oprot.writeMessageBegin('getQueues', TMessageType.CALL, self._seqid)
  297. args = getQueues_args()
  298. args.ctx = ctx
  299. args.write(self._oprot)
  300. self._oprot.writeMessageEnd()
  301. self._oprot.trans.flush()
  302. def recv_getQueues(self, ):
  303. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  304. if mtype == TMessageType.EXCEPTION:
  305. x = TApplicationException()
  306. x.read(self._iprot)
  307. self._iprot.readMessageEnd()
  308. raise x
  309. result = getQueues_result()
  310. result.read(self._iprot)
  311. self._iprot.readMessageEnd()
  312. if result.success is not None:
  313. return result.success
  314. if result.err is not None:
  315. raise result.err
  316. raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueues failed: unknown result");
  317. def getJob(self, ctx, jobID):
  318. """
  319. Get a job by ID
  320. Parameters:
  321. - ctx
  322. - jobID
  323. """
  324. self.send_getJob(ctx, jobID)
  325. return self.recv_getJob()
  326. def send_getJob(self, ctx, jobID):
  327. self._oprot.writeMessageBegin('getJob', TMessageType.CALL, self._seqid)
  328. args = getJob_args()
  329. args.ctx = ctx
  330. args.jobID = jobID
  331. args.write(self._oprot)
  332. self._oprot.writeMessageEnd()
  333. self._oprot.trans.flush()
  334. def recv_getJob(self, ):
  335. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  336. if mtype == TMessageType.EXCEPTION:
  337. x = TApplicationException()
  338. x.read(self._iprot)
  339. self._iprot.readMessageEnd()
  340. raise x
  341. result = getJob_result()
  342. result.read(self._iprot)
  343. self._iprot.readMessageEnd()
  344. if result.success is not None:
  345. return result.success
  346. if result.err is not None:
  347. raise result.err
  348. raise TApplicationException(TApplicationException.MISSING_RESULT, "getJob failed: unknown result");
  349. def getRunningJobs(self, ctx):
  350. """
  351. Get a list of currently running jobs
  352. Parameters:
  353. - ctx
  354. """
  355. self.send_getRunningJobs(ctx)
  356. return self.recv_getRunningJobs()
  357. def send_getRunningJobs(self, ctx):
  358. self._oprot.writeMessageBegin('getRunningJobs', TMessageType.CALL, self._seqid)
  359. args = getRunningJobs_args()
  360. args.ctx = ctx
  361. args.write(self._oprot)
  362. self._oprot.writeMessageEnd()
  363. self._oprot.trans.flush()
  364. def recv_getRunningJobs(self, ):
  365. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  366. if mtype == TMessageType.EXCEPTION:
  367. x = TApplicationException()
  368. x.read(self._iprot)
  369. self._iprot.readMessageEnd()
  370. raise x
  371. result = getRunningJobs_result()
  372. result.read(self._iprot)
  373. self._iprot.readMessageEnd()
  374. if result.success is not None:
  375. return result.success
  376. raise TApplicationException(TApplicationException.MISSING_RESULT, "getRunningJobs failed: unknown result");
  377. def getCompletedJobs(self, ctx):
  378. """
  379. Get a list of completed jobs
  380. Parameters:
  381. - ctx
  382. """
  383. self.send_getCompletedJobs(ctx)
  384. return self.recv_getCompletedJobs()
  385. def send_getCompletedJobs(self, ctx):
  386. self._oprot.writeMessageBegin('getCompletedJobs', TMessageType.CALL, self._seqid)
  387. args = getCompletedJobs_args()
  388. args.ctx = ctx
  389. args.write(self._oprot)
  390. self._oprot.writeMessageEnd()
  391. self._oprot.trans.flush()
  392. def recv_getCompletedJobs(self, ):
  393. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  394. if mtype == TMessageType.EXCEPTION:
  395. x = TApplicationException()
  396. x.read(self._iprot)
  397. self._iprot.readMessageEnd()
  398. raise x
  399. result = getCompletedJobs_result()
  400. result.read(self._iprot)
  401. self._iprot.readMessageEnd()
  402. if result.success is not None:
  403. return result.success
  404. raise TApplicationException(TApplicationException.MISSING_RESULT, "getCompletedJobs failed: unknown result");
  405. def getRetiredJob(self, ctx, jobID):
  406. """
  407. Get a retired job
  408. Parameters:
  409. - ctx
  410. - jobID
  411. """
  412. self.send_getRetiredJob(ctx, jobID)
  413. return self.recv_getRetiredJob()
  414. def send_getRetiredJob(self, ctx, jobID):
  415. self._oprot.writeMessageBegin('getRetiredJob', TMessageType.CALL, self._seqid)
  416. args = getRetiredJob_args()
  417. args.ctx = ctx
  418. args.jobID = jobID
  419. args.write(self._oprot)
  420. self._oprot.writeMessageEnd()
  421. self._oprot.trans.flush()
  422. def recv_getRetiredJob(self, ):
  423. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  424. if mtype == TMessageType.EXCEPTION:
  425. x = TApplicationException()
  426. x.read(self._iprot)
  427. self._iprot.readMessageEnd()
  428. raise x
  429. result = getRetiredJob_result()
  430. result.read(self._iprot)
  431. self._iprot.readMessageEnd()
  432. if result.success is not None:
  433. return result.success
  434. if result.err is not None:
  435. raise result.err
  436. raise TApplicationException(TApplicationException.MISSING_RESULT, "getRetiredJob failed: unknown result");
  437. def getRetiredJobs(self, ctx, state):
  438. """
  439. Get a list of retired jobs
  440. Parameters:
  441. - ctx
  442. - state
  443. """
  444. self.send_getRetiredJobs(ctx, state)
  445. return self.recv_getRetiredJobs()
  446. def send_getRetiredJobs(self, ctx, state):
  447. self._oprot.writeMessageBegin('getRetiredJobs', TMessageType.CALL, self._seqid)
  448. args = getRetiredJobs_args()
  449. args.ctx = ctx
  450. args.state = state
  451. args.write(self._oprot)
  452. self._oprot.writeMessageEnd()
  453. self._oprot.trans.flush()
  454. def recv_getRetiredJobs(self, ):
  455. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  456. if mtype == TMessageType.EXCEPTION:
  457. x = TApplicationException()
  458. x.read(self._iprot)
  459. self._iprot.readMessageEnd()
  460. raise x
  461. result = getRetiredJobs_result()
  462. result.read(self._iprot)
  463. self._iprot.readMessageEnd()
  464. if result.success is not None:
  465. return result.success
  466. raise TApplicationException(TApplicationException.MISSING_RESULT, "getRetiredJobs failed: unknown result");
  467. def getFailedJobs(self, ctx):
  468. """
  469. Get a list of failed (due to error, not killed) jobs
  470. Parameters:
  471. - ctx
  472. """
  473. self.send_getFailedJobs(ctx)
  474. return self.recv_getFailedJobs()
  475. def send_getFailedJobs(self, ctx):
  476. self._oprot.writeMessageBegin('getFailedJobs', TMessageType.CALL, self._seqid)
  477. args = getFailedJobs_args()
  478. args.ctx = ctx
  479. args.write(self._oprot)
  480. self._oprot.writeMessageEnd()
  481. self._oprot.trans.flush()
  482. def recv_getFailedJobs(self, ):
  483. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  484. if mtype == TMessageType.EXCEPTION:
  485. x = TApplicationException()
  486. x.read(self._iprot)
  487. self._iprot.readMessageEnd()
  488. raise x
  489. result = getFailedJobs_result()
  490. result.read(self._iprot)
  491. self._iprot.readMessageEnd()
  492. if result.success is not None:
  493. return result.success
  494. raise TApplicationException(TApplicationException.MISSING_RESULT, "getFailedJobs failed: unknown result");
  495. def getKilledJobs(self, ctx):
  496. """
  497. Get a list of killed jobs
  498. Parameters:
  499. - ctx
  500. """
  501. self.send_getKilledJobs(ctx)
  502. return self.recv_getKilledJobs()
  503. def send_getKilledJobs(self, ctx):
  504. self._oprot.writeMessageBegin('getKilledJobs', TMessageType.CALL, self._seqid)
  505. args = getKilledJobs_args()
  506. args.ctx = ctx
  507. args.write(self._oprot)
  508. self._oprot.writeMessageEnd()
  509. self._oprot.trans.flush()
  510. def recv_getKilledJobs(self, ):
  511. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  512. if mtype == TMessageType.EXCEPTION:
  513. x = TApplicationException()
  514. x.read(self._iprot)
  515. self._iprot.readMessageEnd()
  516. raise x
  517. result = getKilledJobs_result()
  518. result.read(self._iprot)
  519. self._iprot.readMessageEnd()
  520. if result.success is not None:
  521. return result.success
  522. raise TApplicationException(TApplicationException.MISSING_RESULT, "getKilledJobs failed: unknown result");
  523. def getAllJobs(self, ctx):
  524. """
  525. Get a list of all failed, completed and running jobs (could be expensive!)
  526. Parameters:
  527. - ctx
  528. """
  529. self.send_getAllJobs(ctx)
  530. return self.recv_getAllJobs()
  531. def send_getAllJobs(self, ctx):
  532. self._oprot.writeMessageBegin('getAllJobs', TMessageType.CALL, self._seqid)
  533. args = getAllJobs_args()
  534. args.ctx = ctx
  535. args.write(self._oprot)
  536. self._oprot.writeMessageEnd()
  537. self._oprot.trans.flush()
  538. def recv_getAllJobs(self, ):
  539. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  540. if mtype == TMessageType.EXCEPTION:
  541. x = TApplicationException()
  542. x.read(self._iprot)
  543. self._iprot.readMessageEnd()
  544. raise x
  545. result = getAllJobs_result()
  546. result.read(self._iprot)
  547. self._iprot.readMessageEnd()
  548. if result.success is not None:
  549. return result.success
  550. raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllJobs failed: unknown result");
  551. def getUserJobCounts(self, ctx, user):
  552. """
  553. Get the count of jobs by status for a given user
  554. Parameters:
  555. - ctx
  556. - user
  557. """
  558. self.send_getUserJobCounts(ctx, user)
  559. return self.recv_getUserJobCounts()
  560. def send_getUserJobCounts(self, ctx, user):
  561. self._oprot.writeMessageBegin('getUserJobCounts', TMessageType.CALL, self._seqid)
  562. args = getUserJobCounts_args()
  563. args.ctx = ctx
  564. args.user = user
  565. args.write(self._oprot)
  566. self._oprot.writeMessageEnd()
  567. self._oprot.trans.flush()
  568. def recv_getUserJobCounts(self, ):
  569. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  570. if mtype == TMessageType.EXCEPTION:
  571. x = TApplicationException()
  572. x.read(self._iprot)
  573. self._iprot.readMessageEnd()
  574. raise x
  575. result = getUserJobCounts_result()
  576. result.read(self._iprot)
  577. self._iprot.readMessageEnd()
  578. if result.success is not None:
  579. return result.success
  580. raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserJobCounts failed: unknown result");
  581. def getTaskList(self, ctx, jobID, types, states, text, count, offset):
  582. """
  583. Get a (possibly incomplete) list of tasks
  584. Parameters:
  585. - ctx
  586. - jobID
  587. - types
  588. - states
  589. - text
  590. - count
  591. - offset
  592. """
  593. self.send_getTaskList(ctx, jobID, types, states, text, count, offset)
  594. return self.recv_getTaskList()
  595. def send_getTaskList(self, ctx, jobID, types, states, text, count, offset):
  596. self._oprot.writeMessageBegin('getTaskList', TMessageType.CALL, self._seqid)
  597. args = getTaskList_args()
  598. args.ctx = ctx
  599. args.jobID = jobID
  600. args.types = types
  601. args.states = states
  602. args.text = text
  603. args.count = count
  604. args.offset = offset
  605. args.write(self._oprot)
  606. self._oprot.writeMessageEnd()
  607. self._oprot.trans.flush()
  608. def recv_getTaskList(self, ):
  609. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  610. if mtype == TMessageType.EXCEPTION:
  611. x = TApplicationException()
  612. x.read(self._iprot)
  613. self._iprot.readMessageEnd()
  614. raise x
  615. result = getTaskList_result()
  616. result.read(self._iprot)
  617. self._iprot.readMessageEnd()
  618. if result.success is not None:
  619. return result.success
  620. if result.err is not None:
  621. raise result.err
  622. raise TApplicationException(TApplicationException.MISSING_RESULT, "getTaskList failed: unknown result");
  623. def getTask(self, ctx, taskID):
  624. """
  625. Get details of a task
  626. Parameters:
  627. - ctx
  628. - taskID
  629. """
  630. self.send_getTask(ctx, taskID)
  631. return self.recv_getTask()
  632. def send_getTask(self, ctx, taskID):
  633. self._oprot.writeMessageBegin('getTask', TMessageType.CALL, self._seqid)
  634. args = getTask_args()
  635. args.ctx = ctx
  636. args.taskID = taskID
  637. args.write(self._oprot)
  638. self._oprot.writeMessageEnd()
  639. self._oprot.trans.flush()
  640. def recv_getTask(self, ):
  641. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  642. if mtype == TMessageType.EXCEPTION:
  643. x = TApplicationException()
  644. x.read(self._iprot)
  645. self._iprot.readMessageEnd()
  646. raise x
  647. result = getTask_result()
  648. result.read(self._iprot)
  649. self._iprot.readMessageEnd()
  650. if result.success is not None:
  651. return result.success
  652. if result.jnf is not None:
  653. raise result.jnf
  654. if result.tnf is not None:
  655. raise result.tnf
  656. raise TApplicationException(TApplicationException.MISSING_RESULT, "getTask failed: unknown result");
  657. def getJobCounters(self, ctx, jobID):
  658. """
  659. Get a list of groups of counters attached to the job with provided id.
  660. This returns the total counters
  661. Parameters:
  662. - ctx
  663. - jobID
  664. """
  665. self.send_getJobCounters(ctx, jobID)
  666. return self.recv_getJobCounters()
  667. def send_getJobCounters(self, ctx, jobID):
  668. self._oprot.writeMessageBegin('getJobCounters', TMessageType.CALL, self._seqid)
  669. args = getJobCounters_args()
  670. args.ctx = ctx
  671. args.jobID = jobID
  672. args.write(self._oprot)
  673. self._oprot.writeMessageEnd()
  674. self._oprot.trans.flush()
  675. def recv_getJobCounters(self, ):
  676. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  677. if mtype == TMessageType.EXCEPTION:
  678. x = TApplicationException()
  679. x.read(self._iprot)
  680. self._iprot.readMessageEnd()
  681. raise x
  682. result = getJobCounters_result()
  683. result.read(self._iprot)
  684. self._iprot.readMessageEnd()
  685. if result.success is not None:
  686. return result.success
  687. if result.err is not None:
  688. raise result.err
  689. raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobCounters failed: unknown result");
  690. def getJobCounterRollups(self, ctx, jobID):
  691. """
  692. Return job counters rolled up by map, reduce, and total
  693. Parameters:
  694. - ctx
  695. - jobID
  696. """
  697. self.send_getJobCounterRollups(ctx, jobID)
  698. return self.recv_getJobCounterRollups()
  699. def send_getJobCounterRollups(self, ctx, jobID):
  700. self._oprot.writeMessageBegin('getJobCounterRollups', TMessageType.CALL, self._seqid)
  701. args = getJobCounterRollups_args()
  702. args.ctx = ctx
  703. args.jobID = jobID
  704. args.write(self._oprot)
  705. self._oprot.writeMessageEnd()
  706. self._oprot.trans.flush()
  707. def recv_getJobCounterRollups(self, ):
  708. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  709. if mtype == TMessageType.EXCEPTION:
  710. x = TApplicationException()
  711. x.read(self._iprot)
  712. self._iprot.readMessageEnd()
  713. raise x
  714. result = getJobCounterRollups_result()
  715. result.read(self._iprot)
  716. self._iprot.readMessageEnd()
  717. if result.success is not None:
  718. return result.success
  719. if result.err is not None:
  720. raise result.err
  721. raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobCounterRollups failed: unknown result");
  722. def getActiveTrackers(self, ctx):
  723. """
  724. Get all active trackers
  725. Parameters:
  726. - ctx
  727. """
  728. self.send_getActiveTrackers(ctx)
  729. return self.recv_getActiveTrackers()
  730. def send_getActiveTrackers(self, ctx):
  731. self._oprot.writeMessageBegin('getActiveTrackers', TMessageType.CALL, self._seqid)
  732. args = getActiveTrackers_args()
  733. args.ctx = ctx
  734. args.write(self._oprot)
  735. self._oprot.writeMessageEnd()
  736. self._oprot.trans.flush()
  737. def recv_getActiveTrackers(self, ):
  738. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  739. if mtype == TMessageType.EXCEPTION:
  740. x = TApplicationException()
  741. x.read(self._iprot)
  742. self._iprot.readMessageEnd()
  743. raise x
  744. result = getActiveTrackers_result()
  745. result.read(self._iprot)
  746. self._iprot.readMessageEnd()
  747. if result.success is not None:
  748. return result.success
  749. raise TApplicationException(TApplicationException.MISSING_RESULT, "getActiveTrackers failed: unknown result");
  750. def getBlacklistedTrackers(self, ctx):
  751. """
  752. Get all blacklisted trackers
  753. Parameters:
  754. - ctx
  755. """
  756. self.send_getBlacklistedTrackers(ctx)
  757. return self.recv_getBlacklistedTrackers()
  758. def send_getBlacklistedTrackers(self, ctx):
  759. self._oprot.writeMessageBegin('getBlacklistedTrackers', TMessageType.CALL, self._seqid)
  760. args = getBlacklistedTrackers_args()
  761. args.ctx = ctx
  762. args.write(self._oprot)
  763. self._oprot.writeMessageEnd()
  764. self._oprot.trans.flush()
  765. def recv_getBlacklistedTrackers(self, ):
  766. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  767. if mtype == TMessageType.EXCEPTION:
  768. x = TApplicationException()
  769. x.read(self._iprot)
  770. self._iprot.readMessageEnd()
  771. raise x
  772. result = getBlacklistedTrackers_result()
  773. result.read(self._iprot)
  774. self._iprot.readMessageEnd()
  775. if result.success is not None:
  776. return result.success
  777. raise TApplicationException(TApplicationException.MISSING_RESULT, "getBlacklistedTrackers failed: unknown result");
  778. def getAllTrackers(self, ctx):
  779. """
  780. Get all trackers
  781. Parameters:
  782. - ctx
  783. """
  784. self.send_getAllTrackers(ctx)
  785. return self.recv_getAllTrackers()
  786. def send_getAllTrackers(self, ctx):
  787. self._oprot.writeMessageBegin('getAllTrackers', TMessageType.CALL, self._seqid)
  788. args = getAllTrackers_args()
  789. args.ctx = ctx
  790. args.write(self._oprot)
  791. self._oprot.writeMessageEnd()
  792. self._oprot.trans.flush()
  793. def recv_getAllTrackers(self, ):
  794. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  795. if mtype == TMessageType.EXCEPTION:
  796. x = TApplicationException()
  797. x.read(self._iprot)
  798. self._iprot.readMessageEnd()
  799. raise x
  800. result = getAllTrackers_result()
  801. result.read(self._iprot)
  802. self._iprot.readMessageEnd()
  803. if result.success is not None:
  804. return result.success
  805. raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllTrackers failed: unknown result");
  806. def getTracker(self, ctx, name):
  807. """
  808. Get a single task tracker by name
  809. Parameters:
  810. - ctx
  811. - name
  812. """
  813. self.send_getTracker(ctx, name)
  814. return self.recv_getTracker()
  815. def send_getTracker(self, ctx, name):
  816. self._oprot.writeMessageBegin('getTracker', TMessageType.CALL, self._seqid)
  817. args = getTracker_args()
  818. args.ctx = ctx
  819. args.name = name
  820. args.write(self._oprot)
  821. self._oprot.writeMessageEnd()
  822. self._oprot.trans.flush()
  823. def recv_getTracker(self, ):
  824. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  825. if mtype == TMessageType.EXCEPTION:
  826. x = TApplicationException()
  827. x.read(self._iprot)
  828. self._iprot.readMessageEnd()
  829. raise x
  830. result = getTracker_result()
  831. result.read(self._iprot)
  832. self._iprot.readMessageEnd()
  833. if result.success is not None:
  834. return result.success
  835. if result.tne is not None:
  836. raise result.tne
  837. raise TApplicationException(TApplicationException.MISSING_RESULT, "getTracker failed: unknown result");
  838. def getCurrentTime(self, ctx):
  839. """
  840. Get the current time in ms according to the JT
  841. Parameters:
  842. - ctx
  843. """
  844. self.send_getCurrentTime(ctx)
  845. return self.recv_getCurrentTime()
  846. def send_getCurrentTime(self, ctx):
  847. self._oprot.writeMessageBegin('getCurrentTime', TMessageType.CALL, self._seqid)
  848. args = getCurrentTime_args()
  849. args.ctx = ctx
  850. args.write(self._oprot)
  851. self._oprot.writeMessageEnd()
  852. self._oprot.trans.flush()
  853. def recv_getCurrentTime(self, ):
  854. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  855. if mtype == TMessageType.EXCEPTION:
  856. x = TApplicationException()
  857. x.read(self._iprot)
  858. self._iprot.readMessageEnd()
  859. raise x
  860. result = getCurrentTime_result()
  861. result.read(self._iprot)
  862. self._iprot.readMessageEnd()
  863. if result.success is not None:
  864. return result.success
  865. raise TApplicationException(TApplicationException.MISSING_RESULT, "getCurrentTime failed: unknown result");
  866. def getJobConfXML(self, ctx, jobID):
  867. """
  868. Get the xml for a job's configuration, serialised from the local filesystem on the JT
  869. Parameters:
  870. - ctx
  871. - jobID
  872. """
  873. self.send_getJobConfXML(ctx, jobID)
  874. return self.recv_getJobConfXML()
  875. def send_getJobConfXML(self, ctx, jobID):
  876. self._oprot.writeMessageBegin('getJobConfXML', TMessageType.CALL, self._seqid)
  877. args = getJobConfXML_args()
  878. args.ctx = ctx
  879. args.jobID = jobID
  880. args.write(self._oprot)
  881. self._oprot.writeMessageEnd()
  882. self._oprot.trans.flush()
  883. def recv_getJobConfXML(self, ):
  884. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  885. if mtype == TMessageType.EXCEPTION:
  886. x = TApplicationException()
  887. x.read(self._iprot)
  888. self._iprot.readMessageEnd()
  889. raise x
  890. result = getJobConfXML_result()
  891. result.read(self._iprot)
  892. self._iprot.readMessageEnd()
  893. if result.success is not None:
  894. return result.success
  895. if result.err is not None:
  896. raise result.err
  897. raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobConfXML failed: unknown result");
  898. def killJob(self, ctx, jobID):
  899. """
  900. Kill a job
  901. Parameters:
  902. - ctx
  903. - jobID
  904. """
  905. self.send_killJob(ctx, jobID)
  906. self.recv_killJob()
  907. def send_killJob(self, ctx, jobID):
  908. self._oprot.writeMessageBegin('killJob', TMessageType.CALL, self._seqid)
  909. args = killJob_args()
  910. args.ctx = ctx
  911. args.jobID = jobID
  912. args.write(self._oprot)
  913. self._oprot.writeMessageEnd()
  914. self._oprot.trans.flush()
  915. def recv_killJob(self, ):
  916. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  917. if mtype == TMessageType.EXCEPTION:
  918. x = TApplicationException()
  919. x.read(self._iprot)
  920. self._iprot.readMessageEnd()
  921. raise x
  922. result = killJob_result()
  923. result.read(self._iprot)
  924. self._iprot.readMessageEnd()
  925. if result.err is not None:
  926. raise result.err
  927. if result.jne is not None:
  928. raise result.jne
  929. return
  930. def killTaskAttempt(self, ctx, attemptID):
  931. """
  932. Kill a task attempt
  933. Parameters:
  934. - ctx
  935. - attemptID
  936. """
  937. self.send_killTaskAttempt(ctx, attemptID)
  938. self.recv_killTaskAttempt()
  939. def send_killTaskAttempt(self, ctx, attemptID):
  940. self._oprot.writeMessageBegin('killTaskAttempt', TMessageType.CALL, self._seqid)
  941. args = killTaskAttempt_args()
  942. args.ctx = ctx
  943. args.attemptID = attemptID
  944. args.write(self._oprot)
  945. self._oprot.writeMessageEnd()
  946. self._oprot.trans.flush()
  947. def recv_killTaskAttempt(self, ):
  948. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  949. if mtype == TMessageType.EXCEPTION:
  950. x = TApplicationException()
  951. x.read(self._iprot)
  952. self._iprot.readMessageEnd()
  953. raise x
  954. result = killTaskAttempt_result()
  955. result.read(self._iprot)
  956. self._iprot.readMessageEnd()
  957. if result.err is not None:
  958. raise result.err
  959. if result.tne is not None:
  960. raise result.tne
  961. if result.jne is not None:
  962. raise result.jne
  963. return
  964. def setJobPriority(self, ctx, jobID, priority):
  965. """
  966. Set a job's priority
  967. Parameters:
  968. - ctx
  969. - jobID
  970. - priority
  971. """
  972. self.send_setJobPriority(ctx, jobID, priority)
  973. self.recv_setJobPriority()
  974. def send_setJobPriority(self, ctx, jobID, priority):
  975. self._oprot.writeMessageBegin('setJobPriority', TMessageType.CALL, self._seqid)
  976. args = setJobPriority_args()
  977. args.ctx = ctx
  978. args.jobID = jobID
  979. args.priority = priority
  980. args.write(self._oprot)
  981. self._oprot.writeMessageEnd()
  982. self._oprot.trans.flush()
  983. def recv_setJobPriority(self, ):
  984. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  985. if mtype == TMessageType.EXCEPTION:
  986. x = TApplicationException()
  987. x.read(self._iprot)
  988. self._iprot.readMessageEnd()
  989. raise x
  990. result = setJobPriority_result()
  991. result.read(self._iprot)
  992. self._iprot.readMessageEnd()
  993. if result.err is not None:
  994. raise result.err
  995. if result.jne is not None:
  996. raise result.jne
  997. return
  998. def getDelegationToken(self, ctx, renewer):
  999. """
  1000. Get an MR delegation token.
  1001. Parameters:
  1002. - ctx
  1003. - renewer
  1004. """
  1005. self.send_getDelegationToken(ctx, renewer)
  1006. return self.recv_getDelegationToken()
  1007. def send_getDelegationToken(self, ctx, renewer):
  1008. self._oprot.writeMessageBegin('getDelegationToken', TMessageType.CALL, self._seqid)
  1009. args = getDelegationToken_args()
  1010. args.ctx = ctx
  1011. args.renewer = renewer
  1012. args.write(self._oprot)
  1013. self._oprot.writeMessageEnd()
  1014. self._oprot.trans.flush()
  1015. def recv_getDelegationToken(self, ):
  1016. (fname, mtype, rseqid) = self._iprot.readMessageBegin()
  1017. if mtype == TMessageType.EXCEPTION:
  1018. x = TApplicationException()
  1019. x.read(self._iprot)
  1020. self._iprot.readMessageEnd()
  1021. raise x
  1022. result = getDelegationToken_result()
  1023. result.read(self._iprot)
  1024. self._iprot.readMessageEnd()
  1025. if result.success is not None:
  1026. return result.success
  1027. if result.err is not None:
  1028. raise result.err
  1029. raise TApplicationException(TApplicationException.MISSING_RESULT, "getDelegationToken failed: unknown result");
  1030. class Processor(hadoop.api.common.HadoopServiceBase.Processor, Iface, TProcessor):
  1031. def __init__(self, handler):
  1032. hadoop.api.common.HadoopServiceBase.Processor.__init__(self, handler)
  1033. self._processMap["getJobTrackerName"] = Processor.process_getJobTrackerName
  1034. self._processMap["getClusterStatus"] = Processor.process_getClusterStatus
  1035. self._processMap["getQueues"] = Processor.process_getQueues
  1036. self._processMap["getJob"] = Processor.process_getJob
  1037. self._processMap["getRunningJobs"] = Processor.process_getRunningJobs
  1038. self._processMap["getCompletedJobs"] = Processor.process_getCompletedJobs
  1039. self._processMap["getRetiredJob"] = Processor.process_getRetiredJob
  1040. self._processMap["getRetiredJobs"] = Processor.process_getRetiredJobs
  1041. self._processMap["getFailedJobs"] = Processor.process_getFailedJobs
  1042. self._processMap["getKilledJobs"] = Processor.process_getKilledJobs
  1043. self._processMap["getAllJobs"] = Processor.process_getAllJobs
  1044. self._processMap["getUserJobCounts"] = Processor.process_getUserJobCounts
  1045. self._processMap["getTaskList"] = Processor.process_getTaskList
  1046. self._processMap["getTask"] = Processor.process_getTask
  1047. self._processMap["getJobCounters"] = Processor.process_getJobCounters
  1048. self._processMap["getJobCounterRollups"] = Processor.process_getJobCounterRollups
  1049. self._processMap["getActiveTrackers"] = Processor.process_getActiveTrackers
  1050. self._processMap["getBlacklistedTrackers"] = Processor.process_getBlacklistedTrackers
  1051. self._processMap["getAllTrackers"] = Processor.process_getAllTrackers
  1052. self._processMap["getTracker"] = Processor.process_getTracker
  1053. self._processMap["getCurrentTime"] = Processor.process_getCurrentTime
  1054. self._processMap["getJobConfXML"] = Processor.process_getJobConfXML
  1055. self._processMap["killJob"] = Processor.process_killJob
  1056. self._processMap["killTaskAttempt"] = Processor.process_killTaskAttempt
  1057. self._processMap["setJobPriority"] = Processor.process_setJobPriority
  1058. self._processMap["getDelegationToken"] = Processor.process_getDelegationToken
  1059. def process(self, iprot, oprot):
  1060. (name, type, seqid) = iprot.readMessageBegin()
  1061. if name not in self._processMap:
  1062. iprot.skip(TType.STRUCT)
  1063. iprot.readMessageEnd()
  1064. x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
  1065. oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
  1066. x.write(oprot)
  1067. oprot.writeMessageEnd()
  1068. oprot.trans.flush()
  1069. return
  1070. else:
  1071. self._processMap[name](self, seqid, iprot, oprot)
  1072. return True
  1073. def process_getJobTrackerName(self, seqid, iprot, oprot):
  1074. args = getJobTrackerName_args()
  1075. args.read(iprot)
  1076. iprot.readMessageEnd()
  1077. result = getJobTrackerName_result()
  1078. result.success = self._handler.getJobTrackerName(args.ctx)
  1079. oprot.writeMessageBegin("getJobTrackerName", TMessageType.REPLY, seqid)
  1080. result.write(oprot)
  1081. oprot.writeMessageEnd()
  1082. oprot.trans.flush()
  1083. def process_getClusterStatus(self, seqid, iprot, oprot):
  1084. args = getClusterStatus_args()
  1085. args.read(iprot)
  1086. iprot.readMessageEnd()
  1087. result = getClusterStatus_result()
  1088. result.success = self._handler.getClusterStatus(args.ctx)
  1089. oprot.writeMessageBegin("getClusterStatus", TMessageType.REPLY, seqid)
  1090. result.write(oprot)
  1091. oprot.writeMessageEnd()
  1092. oprot.trans.flush()
  1093. def process_getQueues(self, seqid, iprot, oprot):
  1094. args = getQueues_args()
  1095. args.read(iprot)
  1096. iprot.readMessageEnd()
  1097. result = getQueues_result()
  1098. try:
  1099. result.success = self._handler.getQueues(args.ctx)
  1100. except hadoop.api.common.ttypes.IOException, err:
  1101. result.err = err
  1102. oprot.writeMessageBegin("getQueues", TMessageType.REPLY, seqid)
  1103. result.write(oprot)
  1104. oprot.writeMessageEnd()
  1105. oprot.trans.flush()
  1106. def process_getJob(self, seqid, iprot, oprot):
  1107. args = getJob_args()
  1108. args.read(iprot)
  1109. iprot.readMessageEnd()
  1110. result = getJob_result()
  1111. try:
  1112. result.success = self._handler.getJob(args.ctx, args.jobID)
  1113. except JobNotFoundException, err:
  1114. result.err = err
  1115. oprot.writeMessageBegin("getJob", TMessageType.REPLY, seqid)
  1116. result.write(oprot)
  1117. oprot.writeMessageEnd()
  1118. oprot.trans.flush()
  1119. def process_getRunningJobs(self, seqid, iprot, oprot):
  1120. args = getRunningJobs_args()
  1121. args.read(iprot)
  1122. iprot.readMessageEnd()
  1123. result = getRunningJobs_result()
  1124. result.success = self._handler.getRunningJobs(args.ctx)
  1125. oprot.writeMessageBegin("getRunningJobs", TMessageType.REPLY, seqid)
  1126. result.write(oprot)
  1127. oprot.writeMessageEnd()
  1128. oprot.trans.flush()
  1129. def process_getCompletedJobs(self, seqid, iprot, oprot):
  1130. args = getCompletedJobs_args()
  1131. args.read(iprot)
  1132. iprot.readMessageEnd()
  1133. result = getCompletedJobs_result()
  1134. result.success = self._handler.getCompletedJobs(args.ctx)
  1135. oprot.writeMessageBegin("getCompletedJobs", TMessageType.REPLY, seqid)
  1136. result.write(oprot)
  1137. oprot.writeMessageEnd()
  1138. oprot.trans.flush()
  1139. def process_getRetiredJob(self, seqid, iprot, oprot):
  1140. args = getRetiredJob_args()
  1141. args.read(iprot)
  1142. iprot.readMessageEnd()
  1143. result = getRetiredJob_result()
  1144. try:
  1145. result.success = self._handler.getRetiredJob(args.ctx, args.jobID)
  1146. except JobNotFoundException, err:
  1147. result.err = err
  1148. oprot.writeMessageBegin("getRetiredJob", TMessageType.REPLY, seqid)
  1149. result.write(oprot)
  1150. oprot.writeMessageEnd()
  1151. oprot.trans.flush()
  1152. def process_getRetiredJobs(self, seqid, iprot, oprot):
  1153. args = getRetiredJobs_args()
  1154. args.read(iprot)
  1155. iprot.readMessageEnd()
  1156. result = getRetiredJobs_result()
  1157. result.success = self._handler.getRetiredJobs(args.ctx, args.state)
  1158. oprot.writeMessageBegin("getRetiredJobs", TMessageType.REPLY, seqid)
  1159. result.write(oprot)
  1160. oprot.writeMessageEnd()
  1161. oprot.trans.flush()
  1162. def process_getFailedJobs(self, seqid, iprot, oprot):
  1163. args = getFailedJobs_args()
  1164. args.read(iprot)
  1165. iprot.readMessageEnd()
  1166. result = getFailedJobs_result()
  1167. result.success = self._handler.getFailedJobs(args.ctx)
  1168. oprot.writeMessageBegin("getFailedJobs", TMessageType.REPLY, seqid)
  1169. result.write(oprot)
  1170. oprot.writeMessageEnd()
  1171. oprot.trans.flush()
  1172. def process_getKilledJobs(self, seqid, iprot, oprot):
  1173. args = getKilledJobs_args()
  1174. args.read(iprot)
  1175. iprot.readMessageEnd()
  1176. result = getKilledJobs_result()
  1177. result.success = self._handler.getKilledJobs(args.ctx)
  1178. oprot.writeMessageBegin("getKilledJobs", TMessageType.REPLY, seqid)
  1179. result.write(oprot)
  1180. oprot.writeMessageEnd()
  1181. oprot.trans.flush()
  1182. def process_getAllJobs(self, seqid, iprot, oprot):
  1183. args = getAllJobs_args()
  1184. args.read(iprot)
  1185. iprot.readMessageEnd()
  1186. result = getAllJobs_result()
  1187. result.success = self._handler.getAllJobs(args.ctx)
  1188. oprot.writeMessageBegin("getAllJobs", TMessageType.REPLY, seqid)
  1189. result.write(oprot)
  1190. oprot.writeMessageEnd()
  1191. oprot.trans.flush()
  1192. def process_getUserJobCounts(self, seqid, iprot, oprot):
  1193. args = getUserJobCounts_args()
  1194. args.read(iprot)
  1195. iprot.readMessageEnd()
  1196. result = getUserJobCounts_result()
  1197. result.success = self._handler.getUserJobCounts(args.ctx, args.user)
  1198. oprot.writeMessageBegin("getUserJobCounts", TMessageType.REPLY, seqid)
  1199. result.write(oprot)
  1200. oprot.writeMessageEnd()
  1201. oprot.trans.flush()
  1202. def process_getTaskList(self, seqid, iprot, oprot):
  1203. args = getTaskList_args()
  1204. args.read(iprot)
  1205. iprot.readMessageEnd()
  1206. result = getTaskList_result()
  1207. try:
  1208. result.success = self._handler.getTaskList(args.ctx, args.jobID, args.types, args.states, args.text, args.count, args.offset)
  1209. except JobNotFoundException, err:
  1210. result.err = err
  1211. oprot.writeMessageBegin("getTaskList", TMessageType.REPLY, seqid)
  1212. result.write(oprot)
  1213. oprot.writeMessageEnd()
  1214. oprot.trans.flush()
  1215. def process_getTask(self, seqid, iprot, oprot):
  1216. args = getTask_args()
  1217. args.read(iprot)
  1218. iprot.readMessageEnd()
  1219. result = getTask_result()
  1220. try:
  1221. result.success = self._handler.getTask(args.ctx, args.taskID)
  1222. except JobNotFoundException, jnf:
  1223. result.jnf = jnf
  1224. except TaskNotFoundException, tnf:
  1225. result.tnf = tnf
  1226. oprot.writeMessageBegin("getTask", TMessageType.REPLY, seqid)
  1227. result.write(oprot)
  1228. oprot.writeMessageEnd()
  1229. oprot.trans.flush()
  1230. def process_getJobCounters(self, seqid, iprot, oprot):
  1231. args = getJobCounters_args()
  1232. args.read(iprot)
  1233. iprot.readMessageEnd()
  1234. result = getJobCounters_result()
  1235. try:
  1236. result.success = self._handler.getJobCounters(args.ctx, args.jobID)
  1237. except JobNotFoundException, err:
  1238. result.err = err
  1239. oprot.writeMessageBegin("getJobCounters", TMessageType.REPLY, seqid)
  1240. result.write(oprot)
  1241. oprot.writeMessageEnd()
  1242. oprot.trans.flush()
  1243. def process_getJobCounterRollups(self, seqid, iprot, oprot):
  1244. args = getJobCounterRollups_args()
  1245. args.read(iprot)
  1246. iprot.readMessageEnd()
  1247. result = getJobCounterRollups_result()
  1248. try:
  1249. result.success = self._handler.getJobCounterRollups(args.ctx, args.jobID)
  1250. except JobNotFoundException, err:
  1251. result.err = err
  1252. oprot.writeMessageBegin("getJobCounterRollups", TMessageType.REPLY, seqid)
  1253. result.write(oprot)
  1254. oprot.writeMessageEnd()
  1255. oprot.trans.flush()
  1256. def process_getActiveTrackers(self, seqid, iprot, oprot):
  1257. args = getActiveTrackers_args()
  1258. args.read(iprot)
  1259. iprot.readMessageEnd()
  1260. result = getActiveTrackers_result()
  1261. result.success = self._handler.getActiveTrackers(args.ctx)
  1262. oprot.writeMessageBegin("getActiveTrackers", TMessageType.REPLY, seqid)
  1263. result.write(oprot)
  1264. oprot.writeMessageEnd()
  1265. oprot.trans.flush()
  1266. def process_getBlacklistedTrackers(self, seqid, iprot, oprot):
  1267. args = getBlacklistedTrackers_args()
  1268. args.read(iprot)
  1269. iprot.readMessageEnd()
  1270. result = getBlacklistedTrackers_result()
  1271. result.success = self._handler.getBlacklistedTrackers(args.ctx)
  1272. oprot.writeMessageBegin("getBlacklistedTrackers", TMessageType.REPLY, seqid)
  1273. result.write(oprot)
  1274. oprot.writeMessageEnd()
  1275. oprot.trans.flush()
  1276. def process_getAllTrackers(self, seqid, iprot, oprot):
  1277. args = getAllTrackers_args()
  1278. args.read(iprot)
  1279. iprot.readMessageEnd()
  1280. result = getAllTrackers_result()
  1281. result.success = self._handler.getAllTrackers(args.ctx)
  1282. oprot.writeMessageBegin("getAllTrackers", TMessageType.REPLY, seqid)
  1283. result.write(oprot)
  1284. oprot.writeMessageEnd()
  1285. oprot.trans.flush()
  1286. def process_getTracker(self, seqid, iprot, oprot):
  1287. args = getTracker_args()
  1288. args.read(iprot)
  1289. iprot.readMessageEnd()
  1290. result = getTracker_result()
  1291. try:
  1292. result.success = self._handler.getTracker(args.ctx, args.name)
  1293. except TaskTrackerNotFoundException, tne:
  1294. result.tne = tne
  1295. oprot.writeMessageBegin("getTracker", TMessageType.REPLY, seqid)
  1296. result.write(oprot)
  1297. oprot.writeMessageEnd()
  1298. oprot.trans.flush()
  1299. def process_getCurrentTime(self, seqid, iprot, oprot):
  1300. args = getCurrentTime_args()
  1301. args.read(iprot)
  1302. iprot.readMessageEnd()
  1303. result = getCurrentTime_result()
  1304. result.success = self._handler.getCurrentTime(args.ctx)
  1305. oprot.writeMessageBegin("getCurrentTime", TMessageType.REPLY, seqid)
  1306. result.write(oprot)
  1307. oprot.writeMessageEnd()
  1308. oprot.trans.flush()
  1309. def process_getJobConfXML(self, seqid, iprot, oprot):
  1310. args = getJobConfXML_args()
  1311. args.read(iprot)
  1312. iprot.readMessageEnd()
  1313. result = getJobConfXML_result()
  1314. try:
  1315. result.success = self._handler.getJobConfXML(args.ctx, args.jobID)
  1316. except hadoop.api.common.ttypes.IOException, err:
  1317. result.err = err
  1318. oprot.writeMessageBegin("getJobConfXML", TMessageType.REPLY, seqid)
  1319. result.write(oprot)
  1320. oprot.writeMessageEnd()
  1321. oprot.trans.flush()
  1322. def process_killJob(self, seqid, iprot, oprot):
  1323. args = killJob_args()
  1324. args.read(iprot)
  1325. iprot.readMessageEnd()
  1326. result = killJob_result()
  1327. try:
  1328. self._handler.killJob(args.ctx, args.jobID)
  1329. except hadoop.api.common.ttypes.IOException, err:
  1330. result.err = err
  1331. except JobNotFoundException, jne:
  1332. result.jne = jne
  1333. oprot.writeMessageBegin("killJob", TMessageType.REPLY, seqid)
  1334. result.write(oprot)
  1335. oprot.writeMessageEnd()
  1336. oprot.trans.flush()
  1337. def process_killTaskAttempt(self, seqid, iprot, oprot):
  1338. args = killTaskAttempt_args()
  1339. args.read(iprot)
  1340. iprot.readMessageEnd()
  1341. result = killTaskAttempt_result()
  1342. try:
  1343. self._handler.killTaskAttempt(args.ctx, args.attemptID)
  1344. except hadoop.api.common.ttypes.IOException, err:
  1345. result.err = err
  1346. except TaskAttemptNotFoundException, tne:
  1347. result.tne = tne
  1348. except JobNotFoundException, jne:
  1349. result.jne = jne
  1350. oprot.writeMessageBegin("killTaskAttempt", TMessageType.REPLY, seqid)
  1351. result.write(oprot)
  1352. oprot.writeMessageEnd()
  1353. oprot.trans.flush()
  1354. def process_setJobPriority(self, seqid, iprot, oprot):
  1355. args = setJobPriority_args()
  1356. args.read(iprot)
  1357. iprot.readMessageEnd()
  1358. result = setJobPriority_result()
  1359. try:
  1360. self._handler.setJobPriority(args.ctx, args.jobID, args.priority)
  1361. except hadoop.api.common.ttypes.IOException, err:
  1362. result.err = err
  1363. except JobNotFoundException, jne:
  1364. result.jne = jne
  1365. oprot.writeMessageBegin("setJobPriority", TMessageType.REPLY, seqid)
  1366. result.write(oprot)
  1367. oprot.writeMessageEnd()
  1368. oprot.trans.flush()
  1369. def process_getDelegationToken(self, seqid, iprot, oprot):
  1370. args = getDelegationToken_args()
  1371. args.read(iprot)
  1372. iprot.readMessageEnd()
  1373. result = getDelegationToken_result()
  1374. try:
  1375. result.success = self._handler.getDelegationToken(args.ctx, args.renewer)
  1376. except hadoop.api.common.ttypes.IOException, err:
  1377. result.err = err
  1378. oprot.writeMessageBegin("getDelegationToken", TMessageType.REPLY, seqid)
  1379. result.write(oprot)
  1380. oprot.writeMessageEnd()
  1381. oprot.trans.flush()
  1382. # HELPER FUNCTIONS AND STRUCTURES
  1383. class getJobTrackerName_args(object):
  1384. """
  1385. Attributes:
  1386. - ctx
  1387. """
  1388. thrift_spec = (
  1389. None, # 0
  1390. None, # 1
  1391. None, # 2
  1392. None, # 3
  1393. None, # 4
  1394. None, # 5
  1395. None, # 6
  1396. None, # 7
  1397. None, # 8
  1398. None, # 9
  1399. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  1400. )
  1401. def __init__(self, ctx=None,):
  1402. self.ctx = ctx
  1403. def read(self, iprot):
  1404. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1405. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1406. return
  1407. iprot.readStructBegin()
  1408. while True:
  1409. (fname, ftype, fid) = iprot.readFieldBegin()
  1410. if ftype == TType.STOP:
  1411. break
  1412. if fid == 10:
  1413. if ftype == TType.STRUCT:
  1414. self.ctx = hadoop.api.common.ttypes.RequestContext()
  1415. self.ctx.read(iprot)
  1416. else:
  1417. iprot.skip(ftype)
  1418. else:
  1419. iprot.skip(ftype)
  1420. iprot.readFieldEnd()
  1421. iprot.readStructEnd()
  1422. def write(self, oprot):
  1423. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1424. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1425. return
  1426. oprot.writeStructBegin('getJobTrackerName_args')
  1427. if self.ctx is not None:
  1428. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  1429. self.ctx.write(oprot)
  1430. oprot.writeFieldEnd()
  1431. oprot.writeFieldStop()
  1432. oprot.writeStructEnd()
  1433. def validate(self):
  1434. return
  1435. def __repr__(self):
  1436. L = ['%s=%r' % (key, value)
  1437. for key, value in self.__dict__.iteritems()]
  1438. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1439. def __eq__(self, other):
  1440. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1441. def __ne__(self, other):
  1442. return not (self == other)
  1443. class getJobTrackerName_result(object):
  1444. """
  1445. Attributes:
  1446. - success
  1447. """
  1448. thrift_spec = (
  1449. (0, TType.STRING, 'success', None, None, ), # 0
  1450. )
  1451. def __init__(self, success=None,):
  1452. self.success = success
  1453. def read(self, iprot):
  1454. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1455. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1456. return
  1457. iprot.readStructBegin()
  1458. while True:
  1459. (fname, ftype, fid) = iprot.readFieldBegin()
  1460. if ftype == TType.STOP:
  1461. break
  1462. if fid == 0:
  1463. if ftype == TType.STRING:
  1464. self.success = iprot.readString();
  1465. else:
  1466. iprot.skip(ftype)
  1467. else:
  1468. iprot.skip(ftype)
  1469. iprot.readFieldEnd()
  1470. iprot.readStructEnd()
  1471. def write(self, oprot):
  1472. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1473. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1474. return
  1475. oprot.writeStructBegin('getJobTrackerName_result')
  1476. if self.success is not None:
  1477. oprot.writeFieldBegin('success', TType.STRING, 0)
  1478. oprot.writeString(self.success)
  1479. oprot.writeFieldEnd()
  1480. oprot.writeFieldStop()
  1481. oprot.writeStructEnd()
  1482. def validate(self):
  1483. return
  1484. def __repr__(self):
  1485. L = ['%s=%r' % (key, value)
  1486. for key, value in self.__dict__.iteritems()]
  1487. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1488. def __eq__(self, other):
  1489. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1490. def __ne__(self, other):
  1491. return not (self == other)
  1492. class getClusterStatus_args(object):
  1493. """
  1494. Attributes:
  1495. - ctx
  1496. """
  1497. thrift_spec = (
  1498. None, # 0
  1499. None, # 1
  1500. None, # 2
  1501. None, # 3
  1502. None, # 4
  1503. None, # 5
  1504. None, # 6
  1505. None, # 7
  1506. None, # 8
  1507. None, # 9
  1508. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  1509. )
  1510. def __init__(self, ctx=None,):
  1511. self.ctx = ctx
  1512. def read(self, iprot):
  1513. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1514. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1515. return
  1516. iprot.readStructBegin()
  1517. while True:
  1518. (fname, ftype, fid) = iprot.readFieldBegin()
  1519. if ftype == TType.STOP:
  1520. break
  1521. if fid == 10:
  1522. if ftype == TType.STRUCT:
  1523. self.ctx = hadoop.api.common.ttypes.RequestContext()
  1524. self.ctx.read(iprot)
  1525. else:
  1526. iprot.skip(ftype)
  1527. else:
  1528. iprot.skip(ftype)
  1529. iprot.readFieldEnd()
  1530. iprot.readStructEnd()
  1531. def write(self, oprot):
  1532. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1533. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1534. return
  1535. oprot.writeStructBegin('getClusterStatus_args')
  1536. if self.ctx is not None:
  1537. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  1538. self.ctx.write(oprot)
  1539. oprot.writeFieldEnd()
  1540. oprot.writeFieldStop()
  1541. oprot.writeStructEnd()
  1542. def validate(self):
  1543. return
  1544. def __repr__(self):
  1545. L = ['%s=%r' % (key, value)
  1546. for key, value in self.__dict__.iteritems()]
  1547. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1548. def __eq__(self, other):
  1549. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1550. def __ne__(self, other):
  1551. return not (self == other)
  1552. class getClusterStatus_result(object):
  1553. """
  1554. Attributes:
  1555. - success
  1556. """
  1557. thrift_spec = (
  1558. (0, TType.STRUCT, 'success', (ThriftClusterStatus, ThriftClusterStatus.thrift_spec), None, ), # 0
  1559. )
  1560. def __init__(self, success=None,):
  1561. self.success = success
  1562. def read(self, iprot):
  1563. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1564. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1565. return
  1566. iprot.readStructBegin()
  1567. while True:
  1568. (fname, ftype, fid) = iprot.readFieldBegin()
  1569. if ftype == TType.STOP:
  1570. break
  1571. if fid == 0:
  1572. if ftype == TType.STRUCT:
  1573. self.success = ThriftClusterStatus()
  1574. self.success.read(iprot)
  1575. else:
  1576. iprot.skip(ftype)
  1577. else:
  1578. iprot.skip(ftype)
  1579. iprot.readFieldEnd()
  1580. iprot.readStructEnd()
  1581. def write(self, oprot):
  1582. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1583. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1584. return
  1585. oprot.writeStructBegin('getClusterStatus_result')
  1586. if self.success is not None:
  1587. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1588. self.success.write(oprot)
  1589. oprot.writeFieldEnd()
  1590. oprot.writeFieldStop()
  1591. oprot.writeStructEnd()
  1592. def validate(self):
  1593. return
  1594. def __repr__(self):
  1595. L = ['%s=%r' % (key, value)
  1596. for key, value in self.__dict__.iteritems()]
  1597. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1598. def __eq__(self, other):
  1599. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1600. def __ne__(self, other):
  1601. return not (self == other)
  1602. class getQueues_args(object):
  1603. """
  1604. Attributes:
  1605. - ctx
  1606. """
  1607. thrift_spec = (
  1608. None, # 0
  1609. None, # 1
  1610. None, # 2
  1611. None, # 3
  1612. None, # 4
  1613. None, # 5
  1614. None, # 6
  1615. None, # 7
  1616. None, # 8
  1617. None, # 9
  1618. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  1619. )
  1620. def __init__(self, ctx=None,):
  1621. self.ctx = ctx
  1622. def read(self, iprot):
  1623. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1624. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1625. return
  1626. iprot.readStructBegin()
  1627. while True:
  1628. (fname, ftype, fid) = iprot.readFieldBegin()
  1629. if ftype == TType.STOP:
  1630. break
  1631. if fid == 10:
  1632. if ftype == TType.STRUCT:
  1633. self.ctx = hadoop.api.common.ttypes.RequestContext()
  1634. self.ctx.read(iprot)
  1635. else:
  1636. iprot.skip(ftype)
  1637. else:
  1638. iprot.skip(ftype)
  1639. iprot.readFieldEnd()
  1640. iprot.readStructEnd()
  1641. def write(self, oprot):
  1642. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1643. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1644. return
  1645. oprot.writeStructBegin('getQueues_args')
  1646. if self.ctx is not None:
  1647. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  1648. self.ctx.write(oprot)
  1649. oprot.writeFieldEnd()
  1650. oprot.writeFieldStop()
  1651. oprot.writeStructEnd()
  1652. def validate(self):
  1653. return
  1654. def __repr__(self):
  1655. L = ['%s=%r' % (key, value)
  1656. for key, value in self.__dict__.iteritems()]
  1657. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1658. def __eq__(self, other):
  1659. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1660. def __ne__(self, other):
  1661. return not (self == other)
  1662. class getQueues_result(object):
  1663. """
  1664. Attributes:
  1665. - success
  1666. - err
  1667. """
  1668. thrift_spec = (
  1669. (0, TType.STRUCT, 'success', (ThriftJobQueueList, ThriftJobQueueList.thrift_spec), None, ), # 0
  1670. (1, TType.STRUCT, 'err', (hadoop.api.common.ttypes.IOException, hadoop.api.common.ttypes.IOException.thrift_spec), None, ), # 1
  1671. )
  1672. def __init__(self, success=None, err=None,):
  1673. self.success = success
  1674. self.err = err
  1675. def read(self, iprot):
  1676. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1677. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1678. return
  1679. iprot.readStructBegin()
  1680. while True:
  1681. (fname, ftype, fid) = iprot.readFieldBegin()
  1682. if ftype == TType.STOP:
  1683. break
  1684. if fid == 0:
  1685. if ftype == TType.STRUCT:
  1686. self.success = ThriftJobQueueList()
  1687. self.success.read(iprot)
  1688. else:
  1689. iprot.skip(ftype)
  1690. elif fid == 1:
  1691. if ftype == TType.STRUCT:
  1692. self.err = hadoop.api.common.ttypes.IOException()
  1693. self.err.read(iprot)
  1694. else:
  1695. iprot.skip(ftype)
  1696. else:
  1697. iprot.skip(ftype)
  1698. iprot.readFieldEnd()
  1699. iprot.readStructEnd()
  1700. def write(self, oprot):
  1701. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1702. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1703. return
  1704. oprot.writeStructBegin('getQueues_result')
  1705. if self.success is not None:
  1706. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1707. self.success.write(oprot)
  1708. oprot.writeFieldEnd()
  1709. if self.err is not None:
  1710. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  1711. self.err.write(oprot)
  1712. oprot.writeFieldEnd()
  1713. oprot.writeFieldStop()
  1714. oprot.writeStructEnd()
  1715. def validate(self):
  1716. return
  1717. def __repr__(self):
  1718. L = ['%s=%r' % (key, value)
  1719. for key, value in self.__dict__.iteritems()]
  1720. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1721. def __eq__(self, other):
  1722. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1723. def __ne__(self, other):
  1724. return not (self == other)
  1725. class getJob_args(object):
  1726. """
  1727. Attributes:
  1728. - ctx
  1729. - jobID
  1730. """
  1731. thrift_spec = (
  1732. None, # 0
  1733. (1, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 1
  1734. None, # 2
  1735. None, # 3
  1736. None, # 4
  1737. None, # 5
  1738. None, # 6
  1739. None, # 7
  1740. None, # 8
  1741. None, # 9
  1742. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  1743. )
  1744. def __init__(self, ctx=None, jobID=None,):
  1745. self.ctx = ctx
  1746. self.jobID = jobID
  1747. def read(self, iprot):
  1748. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1749. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1750. return
  1751. iprot.readStructBegin()
  1752. while True:
  1753. (fname, ftype, fid) = iprot.readFieldBegin()
  1754. if ftype == TType.STOP:
  1755. break
  1756. if fid == 10:
  1757. if ftype == TType.STRUCT:
  1758. self.ctx = hadoop.api.common.ttypes.RequestContext()
  1759. self.ctx.read(iprot)
  1760. else:
  1761. iprot.skip(ftype)
  1762. elif fid == 1:
  1763. if ftype == TType.STRUCT:
  1764. self.jobID = ThriftJobID()
  1765. self.jobID.read(iprot)
  1766. else:
  1767. iprot.skip(ftype)
  1768. else:
  1769. iprot.skip(ftype)
  1770. iprot.readFieldEnd()
  1771. iprot.readStructEnd()
  1772. def write(self, oprot):
  1773. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1774. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1775. return
  1776. oprot.writeStructBegin('getJob_args')
  1777. if self.jobID is not None:
  1778. oprot.writeFieldBegin('jobID', TType.STRUCT, 1)
  1779. self.jobID.write(oprot)
  1780. oprot.writeFieldEnd()
  1781. if self.ctx is not None:
  1782. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  1783. self.ctx.write(oprot)
  1784. oprot.writeFieldEnd()
  1785. oprot.writeFieldStop()
  1786. oprot.writeStructEnd()
  1787. def validate(self):
  1788. return
  1789. def __repr__(self):
  1790. L = ['%s=%r' % (key, value)
  1791. for key, value in self.__dict__.iteritems()]
  1792. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1793. def __eq__(self, other):
  1794. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1795. def __ne__(self, other):
  1796. return not (self == other)
  1797. class getJob_result(object):
  1798. """
  1799. Attributes:
  1800. - success
  1801. - err
  1802. """
  1803. thrift_spec = (
  1804. (0, TType.STRUCT, 'success', (ThriftJobInProgress, ThriftJobInProgress.thrift_spec), None, ), # 0
  1805. (1, TType.STRUCT, 'err', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 1
  1806. )
  1807. def __init__(self, success=None, err=None,):
  1808. self.success = success
  1809. self.err = err
  1810. def read(self, iprot):
  1811. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1812. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1813. return
  1814. iprot.readStructBegin()
  1815. while True:
  1816. (fname, ftype, fid) = iprot.readFieldBegin()
  1817. if ftype == TType.STOP:
  1818. break
  1819. if fid == 0:
  1820. if ftype == TType.STRUCT:
  1821. self.success = ThriftJobInProgress()
  1822. self.success.read(iprot)
  1823. else:
  1824. iprot.skip(ftype)
  1825. elif fid == 1:
  1826. if ftype == TType.STRUCT:
  1827. self.err = JobNotFoundException()
  1828. self.err.read(iprot)
  1829. else:
  1830. iprot.skip(ftype)
  1831. else:
  1832. iprot.skip(ftype)
  1833. iprot.readFieldEnd()
  1834. iprot.readStructEnd()
  1835. def write(self, oprot):
  1836. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1837. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1838. return
  1839. oprot.writeStructBegin('getJob_result')
  1840. if self.success is not None:
  1841. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1842. self.success.write(oprot)
  1843. oprot.writeFieldEnd()
  1844. if self.err is not None:
  1845. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  1846. self.err.write(oprot)
  1847. oprot.writeFieldEnd()
  1848. oprot.writeFieldStop()
  1849. oprot.writeStructEnd()
  1850. def validate(self):
  1851. return
  1852. def __repr__(self):
  1853. L = ['%s=%r' % (key, value)
  1854. for key, value in self.__dict__.iteritems()]
  1855. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1856. def __eq__(self, other):
  1857. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1858. def __ne__(self, other):
  1859. return not (self == other)
  1860. class getRunningJobs_args(object):
  1861. """
  1862. Attributes:
  1863. - ctx
  1864. """
  1865. thrift_spec = (
  1866. None, # 0
  1867. None, # 1
  1868. None, # 2
  1869. None, # 3
  1870. None, # 4
  1871. None, # 5
  1872. None, # 6
  1873. None, # 7
  1874. None, # 8
  1875. None, # 9
  1876. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  1877. )
  1878. def __init__(self, ctx=None,):
  1879. self.ctx = ctx
  1880. def read(self, iprot):
  1881. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1882. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1883. return
  1884. iprot.readStructBegin()
  1885. while True:
  1886. (fname, ftype, fid) = iprot.readFieldBegin()
  1887. if ftype == TType.STOP:
  1888. break
  1889. if fid == 10:
  1890. if ftype == TType.STRUCT:
  1891. self.ctx = hadoop.api.common.ttypes.RequestContext()
  1892. self.ctx.read(iprot)
  1893. else:
  1894. iprot.skip(ftype)
  1895. else:
  1896. iprot.skip(ftype)
  1897. iprot.readFieldEnd()
  1898. iprot.readStructEnd()
  1899. def write(self, oprot):
  1900. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1901. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1902. return
  1903. oprot.writeStructBegin('getRunningJobs_args')
  1904. if self.ctx is not None:
  1905. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  1906. self.ctx.write(oprot)
  1907. oprot.writeFieldEnd()
  1908. oprot.writeFieldStop()
  1909. oprot.writeStructEnd()
  1910. def validate(self):
  1911. return
  1912. def __repr__(self):
  1913. L = ['%s=%r' % (key, value)
  1914. for key, value in self.__dict__.iteritems()]
  1915. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1916. def __eq__(self, other):
  1917. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1918. def __ne__(self, other):
  1919. return not (self == other)
  1920. class getRunningJobs_result(object):
  1921. """
  1922. Attributes:
  1923. - success
  1924. """
  1925. thrift_spec = (
  1926. (0, TType.STRUCT, 'success', (ThriftJobList, ThriftJobList.thrift_spec), None, ), # 0
  1927. )
  1928. def __init__(self, success=None,):
  1929. self.success = success
  1930. def read(self, iprot):
  1931. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1932. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1933. return
  1934. iprot.readStructBegin()
  1935. while True:
  1936. (fname, ftype, fid) = iprot.readFieldBegin()
  1937. if ftype == TType.STOP:
  1938. break
  1939. if fid == 0:
  1940. if ftype == TType.STRUCT:
  1941. self.success = ThriftJobList()
  1942. self.success.read(iprot)
  1943. else:
  1944. iprot.skip(ftype)
  1945. else:
  1946. iprot.skip(ftype)
  1947. iprot.readFieldEnd()
  1948. iprot.readStructEnd()
  1949. def write(self, oprot):
  1950. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  1951. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  1952. return
  1953. oprot.writeStructBegin('getRunningJobs_result')
  1954. if self.success is not None:
  1955. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  1956. self.success.write(oprot)
  1957. oprot.writeFieldEnd()
  1958. oprot.writeFieldStop()
  1959. oprot.writeStructEnd()
  1960. def validate(self):
  1961. return
  1962. def __repr__(self):
  1963. L = ['%s=%r' % (key, value)
  1964. for key, value in self.__dict__.iteritems()]
  1965. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  1966. def __eq__(self, other):
  1967. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  1968. def __ne__(self, other):
  1969. return not (self == other)
  1970. class getCompletedJobs_args(object):
  1971. """
  1972. Attributes:
  1973. - ctx
  1974. """
  1975. thrift_spec = (
  1976. None, # 0
  1977. None, # 1
  1978. None, # 2
  1979. None, # 3
  1980. None, # 4
  1981. None, # 5
  1982. None, # 6
  1983. None, # 7
  1984. None, # 8
  1985. None, # 9
  1986. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  1987. )
  1988. def __init__(self, ctx=None,):
  1989. self.ctx = ctx
  1990. def read(self, iprot):
  1991. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  1992. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  1993. return
  1994. iprot.readStructBegin()
  1995. while True:
  1996. (fname, ftype, fid) = iprot.readFieldBegin()
  1997. if ftype == TType.STOP:
  1998. break
  1999. if fid == 10:
  2000. if ftype == TType.STRUCT:
  2001. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2002. self.ctx.read(iprot)
  2003. else:
  2004. iprot.skip(ftype)
  2005. else:
  2006. iprot.skip(ftype)
  2007. iprot.readFieldEnd()
  2008. iprot.readStructEnd()
  2009. def write(self, oprot):
  2010. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2011. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2012. return
  2013. oprot.writeStructBegin('getCompletedJobs_args')
  2014. if self.ctx is not None:
  2015. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  2016. self.ctx.write(oprot)
  2017. oprot.writeFieldEnd()
  2018. oprot.writeFieldStop()
  2019. oprot.writeStructEnd()
  2020. def validate(self):
  2021. return
  2022. def __repr__(self):
  2023. L = ['%s=%r' % (key, value)
  2024. for key, value in self.__dict__.iteritems()]
  2025. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2026. def __eq__(self, other):
  2027. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2028. def __ne__(self, other):
  2029. return not (self == other)
  2030. class getCompletedJobs_result(object):
  2031. """
  2032. Attributes:
  2033. - success
  2034. """
  2035. thrift_spec = (
  2036. (0, TType.STRUCT, 'success', (ThriftJobList, ThriftJobList.thrift_spec), None, ), # 0
  2037. )
  2038. def __init__(self, success=None,):
  2039. self.success = success
  2040. def read(self, iprot):
  2041. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2042. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2043. return
  2044. iprot.readStructBegin()
  2045. while True:
  2046. (fname, ftype, fid) = iprot.readFieldBegin()
  2047. if ftype == TType.STOP:
  2048. break
  2049. if fid == 0:
  2050. if ftype == TType.STRUCT:
  2051. self.success = ThriftJobList()
  2052. self.success.read(iprot)
  2053. else:
  2054. iprot.skip(ftype)
  2055. else:
  2056. iprot.skip(ftype)
  2057. iprot.readFieldEnd()
  2058. iprot.readStructEnd()
  2059. def write(self, oprot):
  2060. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2061. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2062. return
  2063. oprot.writeStructBegin('getCompletedJobs_result')
  2064. if self.success is not None:
  2065. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2066. self.success.write(oprot)
  2067. oprot.writeFieldEnd()
  2068. oprot.writeFieldStop()
  2069. oprot.writeStructEnd()
  2070. def validate(self):
  2071. return
  2072. def __repr__(self):
  2073. L = ['%s=%r' % (key, value)
  2074. for key, value in self.__dict__.iteritems()]
  2075. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2076. def __eq__(self, other):
  2077. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2078. def __ne__(self, other):
  2079. return not (self == other)
  2080. class getRetiredJob_args(object):
  2081. """
  2082. Attributes:
  2083. - ctx
  2084. - jobID
  2085. """
  2086. thrift_spec = (
  2087. None, # 0
  2088. (1, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 1
  2089. None, # 2
  2090. None, # 3
  2091. None, # 4
  2092. None, # 5
  2093. None, # 6
  2094. None, # 7
  2095. None, # 8
  2096. None, # 9
  2097. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  2098. )
  2099. def __init__(self, ctx=None, jobID=None,):
  2100. self.ctx = ctx
  2101. self.jobID = jobID
  2102. def read(self, iprot):
  2103. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2104. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2105. return
  2106. iprot.readStructBegin()
  2107. while True:
  2108. (fname, ftype, fid) = iprot.readFieldBegin()
  2109. if ftype == TType.STOP:
  2110. break
  2111. if fid == 10:
  2112. if ftype == TType.STRUCT:
  2113. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2114. self.ctx.read(iprot)
  2115. else:
  2116. iprot.skip(ftype)
  2117. elif fid == 1:
  2118. if ftype == TType.STRUCT:
  2119. self.jobID = ThriftJobID()
  2120. self.jobID.read(iprot)
  2121. else:
  2122. iprot.skip(ftype)
  2123. else:
  2124. iprot.skip(ftype)
  2125. iprot.readFieldEnd()
  2126. iprot.readStructEnd()
  2127. def write(self, oprot):
  2128. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2129. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2130. return
  2131. oprot.writeStructBegin('getRetiredJob_args')
  2132. if self.jobID is not None:
  2133. oprot.writeFieldBegin('jobID', TType.STRUCT, 1)
  2134. self.jobID.write(oprot)
  2135. oprot.writeFieldEnd()
  2136. if self.ctx is not None:
  2137. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  2138. self.ctx.write(oprot)
  2139. oprot.writeFieldEnd()
  2140. oprot.writeFieldStop()
  2141. oprot.writeStructEnd()
  2142. def validate(self):
  2143. return
  2144. def __repr__(self):
  2145. L = ['%s=%r' % (key, value)
  2146. for key, value in self.__dict__.iteritems()]
  2147. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2148. def __eq__(self, other):
  2149. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2150. def __ne__(self, other):
  2151. return not (self == other)
  2152. class getRetiredJob_result(object):
  2153. """
  2154. Attributes:
  2155. - success
  2156. - err
  2157. """
  2158. thrift_spec = (
  2159. (0, TType.STRUCT, 'success', (ThriftJobInProgress, ThriftJobInProgress.thrift_spec), None, ), # 0
  2160. (1, TType.STRUCT, 'err', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 1
  2161. )
  2162. def __init__(self, success=None, err=None,):
  2163. self.success = success
  2164. self.err = err
  2165. def read(self, iprot):
  2166. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2167. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2168. return
  2169. iprot.readStructBegin()
  2170. while True:
  2171. (fname, ftype, fid) = iprot.readFieldBegin()
  2172. if ftype == TType.STOP:
  2173. break
  2174. if fid == 0:
  2175. if ftype == TType.STRUCT:
  2176. self.success = ThriftJobInProgress()
  2177. self.success.read(iprot)
  2178. else:
  2179. iprot.skip(ftype)
  2180. elif fid == 1:
  2181. if ftype == TType.STRUCT:
  2182. self.err = JobNotFoundException()
  2183. self.err.read(iprot)
  2184. else:
  2185. iprot.skip(ftype)
  2186. else:
  2187. iprot.skip(ftype)
  2188. iprot.readFieldEnd()
  2189. iprot.readStructEnd()
  2190. def write(self, oprot):
  2191. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2192. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2193. return
  2194. oprot.writeStructBegin('getRetiredJob_result')
  2195. if self.success is not None:
  2196. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2197. self.success.write(oprot)
  2198. oprot.writeFieldEnd()
  2199. if self.err is not None:
  2200. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  2201. self.err.write(oprot)
  2202. oprot.writeFieldEnd()
  2203. oprot.writeFieldStop()
  2204. oprot.writeStructEnd()
  2205. def validate(self):
  2206. return
  2207. def __repr__(self):
  2208. L = ['%s=%r' % (key, value)
  2209. for key, value in self.__dict__.iteritems()]
  2210. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2211. def __eq__(self, other):
  2212. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2213. def __ne__(self, other):
  2214. return not (self == other)
  2215. class getRetiredJobs_args(object):
  2216. """
  2217. Attributes:
  2218. - ctx
  2219. - state
  2220. """
  2221. thrift_spec = (
  2222. None, # 0
  2223. (1, TType.I32, 'state', None, None, ), # 1
  2224. None, # 2
  2225. None, # 3
  2226. None, # 4
  2227. None, # 5
  2228. None, # 6
  2229. None, # 7
  2230. None, # 8
  2231. None, # 9
  2232. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  2233. )
  2234. def __init__(self, ctx=None, state=None,):
  2235. self.ctx = ctx
  2236. self.state = state
  2237. def read(self, iprot):
  2238. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2239. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2240. return
  2241. iprot.readStructBegin()
  2242. while True:
  2243. (fname, ftype, fid) = iprot.readFieldBegin()
  2244. if ftype == TType.STOP:
  2245. break
  2246. if fid == 10:
  2247. if ftype == TType.STRUCT:
  2248. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2249. self.ctx.read(iprot)
  2250. else:
  2251. iprot.skip(ftype)
  2252. elif fid == 1:
  2253. if ftype == TType.I32:
  2254. self.state = iprot.readI32();
  2255. else:
  2256. iprot.skip(ftype)
  2257. else:
  2258. iprot.skip(ftype)
  2259. iprot.readFieldEnd()
  2260. iprot.readStructEnd()
  2261. def write(self, oprot):
  2262. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2263. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2264. return
  2265. oprot.writeStructBegin('getRetiredJobs_args')
  2266. if self.state is not None:
  2267. oprot.writeFieldBegin('state', TType.I32, 1)
  2268. oprot.writeI32(self.state)
  2269. oprot.writeFieldEnd()
  2270. if self.ctx is not None:
  2271. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  2272. self.ctx.write(oprot)
  2273. oprot.writeFieldEnd()
  2274. oprot.writeFieldStop()
  2275. oprot.writeStructEnd()
  2276. def validate(self):
  2277. return
  2278. def __repr__(self):
  2279. L = ['%s=%r' % (key, value)
  2280. for key, value in self.__dict__.iteritems()]
  2281. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2282. def __eq__(self, other):
  2283. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2284. def __ne__(self, other):
  2285. return not (self == other)
  2286. class getRetiredJobs_result(object):
  2287. """
  2288. Attributes:
  2289. - success
  2290. """
  2291. thrift_spec = (
  2292. (0, TType.STRUCT, 'success', (ThriftJobList, ThriftJobList.thrift_spec), None, ), # 0
  2293. )
  2294. def __init__(self, success=None,):
  2295. self.success = success
  2296. def read(self, iprot):
  2297. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2298. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2299. return
  2300. iprot.readStructBegin()
  2301. while True:
  2302. (fname, ftype, fid) = iprot.readFieldBegin()
  2303. if ftype == TType.STOP:
  2304. break
  2305. if fid == 0:
  2306. if ftype == TType.STRUCT:
  2307. self.success = ThriftJobList()
  2308. self.success.read(iprot)
  2309. else:
  2310. iprot.skip(ftype)
  2311. else:
  2312. iprot.skip(ftype)
  2313. iprot.readFieldEnd()
  2314. iprot.readStructEnd()
  2315. def write(self, oprot):
  2316. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2317. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2318. return
  2319. oprot.writeStructBegin('getRetiredJobs_result')
  2320. if self.success is not None:
  2321. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2322. self.success.write(oprot)
  2323. oprot.writeFieldEnd()
  2324. oprot.writeFieldStop()
  2325. oprot.writeStructEnd()
  2326. def validate(self):
  2327. return
  2328. def __repr__(self):
  2329. L = ['%s=%r' % (key, value)
  2330. for key, value in self.__dict__.iteritems()]
  2331. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2332. def __eq__(self, other):
  2333. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2334. def __ne__(self, other):
  2335. return not (self == other)
  2336. class getFailedJobs_args(object):
  2337. """
  2338. Attributes:
  2339. - ctx
  2340. """
  2341. thrift_spec = (
  2342. None, # 0
  2343. None, # 1
  2344. None, # 2
  2345. None, # 3
  2346. None, # 4
  2347. None, # 5
  2348. None, # 6
  2349. None, # 7
  2350. None, # 8
  2351. None, # 9
  2352. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  2353. )
  2354. def __init__(self, ctx=None,):
  2355. self.ctx = ctx
  2356. def read(self, iprot):
  2357. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2358. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2359. return
  2360. iprot.readStructBegin()
  2361. while True:
  2362. (fname, ftype, fid) = iprot.readFieldBegin()
  2363. if ftype == TType.STOP:
  2364. break
  2365. if fid == 10:
  2366. if ftype == TType.STRUCT:
  2367. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2368. self.ctx.read(iprot)
  2369. else:
  2370. iprot.skip(ftype)
  2371. else:
  2372. iprot.skip(ftype)
  2373. iprot.readFieldEnd()
  2374. iprot.readStructEnd()
  2375. def write(self, oprot):
  2376. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2377. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2378. return
  2379. oprot.writeStructBegin('getFailedJobs_args')
  2380. if self.ctx is not None:
  2381. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  2382. self.ctx.write(oprot)
  2383. oprot.writeFieldEnd()
  2384. oprot.writeFieldStop()
  2385. oprot.writeStructEnd()
  2386. def validate(self):
  2387. return
  2388. def __repr__(self):
  2389. L = ['%s=%r' % (key, value)
  2390. for key, value in self.__dict__.iteritems()]
  2391. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2392. def __eq__(self, other):
  2393. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2394. def __ne__(self, other):
  2395. return not (self == other)
  2396. class getFailedJobs_result(object):
  2397. """
  2398. Attributes:
  2399. - success
  2400. """
  2401. thrift_spec = (
  2402. (0, TType.STRUCT, 'success', (ThriftJobList, ThriftJobList.thrift_spec), None, ), # 0
  2403. )
  2404. def __init__(self, success=None,):
  2405. self.success = success
  2406. def read(self, iprot):
  2407. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2408. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2409. return
  2410. iprot.readStructBegin()
  2411. while True:
  2412. (fname, ftype, fid) = iprot.readFieldBegin()
  2413. if ftype == TType.STOP:
  2414. break
  2415. if fid == 0:
  2416. if ftype == TType.STRUCT:
  2417. self.success = ThriftJobList()
  2418. self.success.read(iprot)
  2419. else:
  2420. iprot.skip(ftype)
  2421. else:
  2422. iprot.skip(ftype)
  2423. iprot.readFieldEnd()
  2424. iprot.readStructEnd()
  2425. def write(self, oprot):
  2426. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2427. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2428. return
  2429. oprot.writeStructBegin('getFailedJobs_result')
  2430. if self.success is not None:
  2431. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2432. self.success.write(oprot)
  2433. oprot.writeFieldEnd()
  2434. oprot.writeFieldStop()
  2435. oprot.writeStructEnd()
  2436. def validate(self):
  2437. return
  2438. def __repr__(self):
  2439. L = ['%s=%r' % (key, value)
  2440. for key, value in self.__dict__.iteritems()]
  2441. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2442. def __eq__(self, other):
  2443. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2444. def __ne__(self, other):
  2445. return not (self == other)
  2446. class getKilledJobs_args(object):
  2447. """
  2448. Attributes:
  2449. - ctx
  2450. """
  2451. thrift_spec = (
  2452. None, # 0
  2453. None, # 1
  2454. None, # 2
  2455. None, # 3
  2456. None, # 4
  2457. None, # 5
  2458. None, # 6
  2459. None, # 7
  2460. None, # 8
  2461. None, # 9
  2462. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  2463. )
  2464. def __init__(self, ctx=None,):
  2465. self.ctx = ctx
  2466. def read(self, iprot):
  2467. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2468. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2469. return
  2470. iprot.readStructBegin()
  2471. while True:
  2472. (fname, ftype, fid) = iprot.readFieldBegin()
  2473. if ftype == TType.STOP:
  2474. break
  2475. if fid == 10:
  2476. if ftype == TType.STRUCT:
  2477. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2478. self.ctx.read(iprot)
  2479. else:
  2480. iprot.skip(ftype)
  2481. else:
  2482. iprot.skip(ftype)
  2483. iprot.readFieldEnd()
  2484. iprot.readStructEnd()
  2485. def write(self, oprot):
  2486. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2487. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2488. return
  2489. oprot.writeStructBegin('getKilledJobs_args')
  2490. if self.ctx is not None:
  2491. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  2492. self.ctx.write(oprot)
  2493. oprot.writeFieldEnd()
  2494. oprot.writeFieldStop()
  2495. oprot.writeStructEnd()
  2496. def validate(self):
  2497. return
  2498. def __repr__(self):
  2499. L = ['%s=%r' % (key, value)
  2500. for key, value in self.__dict__.iteritems()]
  2501. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2502. def __eq__(self, other):
  2503. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2504. def __ne__(self, other):
  2505. return not (self == other)
  2506. class getKilledJobs_result(object):
  2507. """
  2508. Attributes:
  2509. - success
  2510. """
  2511. thrift_spec = (
  2512. (0, TType.STRUCT, 'success', (ThriftJobList, ThriftJobList.thrift_spec), None, ), # 0
  2513. )
  2514. def __init__(self, success=None,):
  2515. self.success = success
  2516. def read(self, iprot):
  2517. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2518. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2519. return
  2520. iprot.readStructBegin()
  2521. while True:
  2522. (fname, ftype, fid) = iprot.readFieldBegin()
  2523. if ftype == TType.STOP:
  2524. break
  2525. if fid == 0:
  2526. if ftype == TType.STRUCT:
  2527. self.success = ThriftJobList()
  2528. self.success.read(iprot)
  2529. else:
  2530. iprot.skip(ftype)
  2531. else:
  2532. iprot.skip(ftype)
  2533. iprot.readFieldEnd()
  2534. iprot.readStructEnd()
  2535. def write(self, oprot):
  2536. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2537. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2538. return
  2539. oprot.writeStructBegin('getKilledJobs_result')
  2540. if self.success is not None:
  2541. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2542. self.success.write(oprot)
  2543. oprot.writeFieldEnd()
  2544. oprot.writeFieldStop()
  2545. oprot.writeStructEnd()
  2546. def validate(self):
  2547. return
  2548. def __repr__(self):
  2549. L = ['%s=%r' % (key, value)
  2550. for key, value in self.__dict__.iteritems()]
  2551. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2552. def __eq__(self, other):
  2553. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2554. def __ne__(self, other):
  2555. return not (self == other)
  2556. class getAllJobs_args(object):
  2557. """
  2558. Attributes:
  2559. - ctx
  2560. """
  2561. thrift_spec = (
  2562. None, # 0
  2563. None, # 1
  2564. None, # 2
  2565. None, # 3
  2566. None, # 4
  2567. None, # 5
  2568. None, # 6
  2569. None, # 7
  2570. None, # 8
  2571. None, # 9
  2572. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  2573. )
  2574. def __init__(self, ctx=None,):
  2575. self.ctx = ctx
  2576. def read(self, iprot):
  2577. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2578. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2579. return
  2580. iprot.readStructBegin()
  2581. while True:
  2582. (fname, ftype, fid) = iprot.readFieldBegin()
  2583. if ftype == TType.STOP:
  2584. break
  2585. if fid == 10:
  2586. if ftype == TType.STRUCT:
  2587. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2588. self.ctx.read(iprot)
  2589. else:
  2590. iprot.skip(ftype)
  2591. else:
  2592. iprot.skip(ftype)
  2593. iprot.readFieldEnd()
  2594. iprot.readStructEnd()
  2595. def write(self, oprot):
  2596. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2597. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2598. return
  2599. oprot.writeStructBegin('getAllJobs_args')
  2600. if self.ctx is not None:
  2601. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  2602. self.ctx.write(oprot)
  2603. oprot.writeFieldEnd()
  2604. oprot.writeFieldStop()
  2605. oprot.writeStructEnd()
  2606. def validate(self):
  2607. return
  2608. def __repr__(self):
  2609. L = ['%s=%r' % (key, value)
  2610. for key, value in self.__dict__.iteritems()]
  2611. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2612. def __eq__(self, other):
  2613. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2614. def __ne__(self, other):
  2615. return not (self == other)
  2616. class getAllJobs_result(object):
  2617. """
  2618. Attributes:
  2619. - success
  2620. """
  2621. thrift_spec = (
  2622. (0, TType.STRUCT, 'success', (ThriftJobList, ThriftJobList.thrift_spec), None, ), # 0
  2623. )
  2624. def __init__(self, success=None,):
  2625. self.success = success
  2626. def read(self, iprot):
  2627. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2628. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2629. return
  2630. iprot.readStructBegin()
  2631. while True:
  2632. (fname, ftype, fid) = iprot.readFieldBegin()
  2633. if ftype == TType.STOP:
  2634. break
  2635. if fid == 0:
  2636. if ftype == TType.STRUCT:
  2637. self.success = ThriftJobList()
  2638. self.success.read(iprot)
  2639. else:
  2640. iprot.skip(ftype)
  2641. else:
  2642. iprot.skip(ftype)
  2643. iprot.readFieldEnd()
  2644. iprot.readStructEnd()
  2645. def write(self, oprot):
  2646. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2647. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2648. return
  2649. oprot.writeStructBegin('getAllJobs_result')
  2650. if self.success is not None:
  2651. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2652. self.success.write(oprot)
  2653. oprot.writeFieldEnd()
  2654. oprot.writeFieldStop()
  2655. oprot.writeStructEnd()
  2656. def validate(self):
  2657. return
  2658. def __repr__(self):
  2659. L = ['%s=%r' % (key, value)
  2660. for key, value in self.__dict__.iteritems()]
  2661. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2662. def __eq__(self, other):
  2663. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2664. def __ne__(self, other):
  2665. return not (self == other)
  2666. class getUserJobCounts_args(object):
  2667. """
  2668. Attributes:
  2669. - ctx
  2670. - user
  2671. """
  2672. thrift_spec = (
  2673. None, # 0
  2674. (1, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 1
  2675. (2, TType.STRING, 'user', None, None, ), # 2
  2676. )
  2677. def __init__(self, ctx=None, user=None,):
  2678. self.ctx = ctx
  2679. self.user = user
  2680. def read(self, iprot):
  2681. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2682. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2683. return
  2684. iprot.readStructBegin()
  2685. while True:
  2686. (fname, ftype, fid) = iprot.readFieldBegin()
  2687. if ftype == TType.STOP:
  2688. break
  2689. if fid == 1:
  2690. if ftype == TType.STRUCT:
  2691. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2692. self.ctx.read(iprot)
  2693. else:
  2694. iprot.skip(ftype)
  2695. elif fid == 2:
  2696. if ftype == TType.STRING:
  2697. self.user = iprot.readString();
  2698. else:
  2699. iprot.skip(ftype)
  2700. else:
  2701. iprot.skip(ftype)
  2702. iprot.readFieldEnd()
  2703. iprot.readStructEnd()
  2704. def write(self, oprot):
  2705. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2706. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2707. return
  2708. oprot.writeStructBegin('getUserJobCounts_args')
  2709. if self.ctx is not None:
  2710. oprot.writeFieldBegin('ctx', TType.STRUCT, 1)
  2711. self.ctx.write(oprot)
  2712. oprot.writeFieldEnd()
  2713. if self.user is not None:
  2714. oprot.writeFieldBegin('user', TType.STRING, 2)
  2715. oprot.writeString(self.user)
  2716. oprot.writeFieldEnd()
  2717. oprot.writeFieldStop()
  2718. oprot.writeStructEnd()
  2719. def validate(self):
  2720. return
  2721. def __repr__(self):
  2722. L = ['%s=%r' % (key, value)
  2723. for key, value in self.__dict__.iteritems()]
  2724. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2725. def __eq__(self, other):
  2726. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2727. def __ne__(self, other):
  2728. return not (self == other)
  2729. class getUserJobCounts_result(object):
  2730. """
  2731. Attributes:
  2732. - success
  2733. """
  2734. thrift_spec = (
  2735. (0, TType.STRUCT, 'success', (ThriftUserJobCounts, ThriftUserJobCounts.thrift_spec), None, ), # 0
  2736. )
  2737. def __init__(self, success=None,):
  2738. self.success = success
  2739. def read(self, iprot):
  2740. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2741. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2742. return
  2743. iprot.readStructBegin()
  2744. while True:
  2745. (fname, ftype, fid) = iprot.readFieldBegin()
  2746. if ftype == TType.STOP:
  2747. break
  2748. if fid == 0:
  2749. if ftype == TType.STRUCT:
  2750. self.success = ThriftUserJobCounts()
  2751. self.success.read(iprot)
  2752. else:
  2753. iprot.skip(ftype)
  2754. else:
  2755. iprot.skip(ftype)
  2756. iprot.readFieldEnd()
  2757. iprot.readStructEnd()
  2758. def write(self, oprot):
  2759. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2760. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2761. return
  2762. oprot.writeStructBegin('getUserJobCounts_result')
  2763. if self.success is not None:
  2764. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2765. self.success.write(oprot)
  2766. oprot.writeFieldEnd()
  2767. oprot.writeFieldStop()
  2768. oprot.writeStructEnd()
  2769. def validate(self):
  2770. return
  2771. def __repr__(self):
  2772. L = ['%s=%r' % (key, value)
  2773. for key, value in self.__dict__.iteritems()]
  2774. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2775. def __eq__(self, other):
  2776. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2777. def __ne__(self, other):
  2778. return not (self == other)
  2779. class getTaskList_args(object):
  2780. """
  2781. Attributes:
  2782. - ctx
  2783. - jobID
  2784. - types
  2785. - states
  2786. - text
  2787. - count
  2788. - offset
  2789. """
  2790. thrift_spec = (
  2791. None, # 0
  2792. (1, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 1
  2793. (2, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 2
  2794. (3, TType.SET, 'types', (TType.I32,None), None, ), # 3
  2795. (4, TType.SET, 'states', (TType.I32,None), None, ), # 4
  2796. (5, TType.STRING, 'text', None, None, ), # 5
  2797. (6, TType.I32, 'count', None, None, ), # 6
  2798. (7, TType.I32, 'offset', None, None, ), # 7
  2799. )
  2800. def __init__(self, ctx=None, jobID=None, types=None, states=None, text=None, count=None, offset=None,):
  2801. self.ctx = ctx
  2802. self.jobID = jobID
  2803. self.types = types
  2804. self.states = states
  2805. self.text = text
  2806. self.count = count
  2807. self.offset = offset
  2808. def read(self, iprot):
  2809. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2810. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2811. return
  2812. iprot.readStructBegin()
  2813. while True:
  2814. (fname, ftype, fid) = iprot.readFieldBegin()
  2815. if ftype == TType.STOP:
  2816. break
  2817. if fid == 1:
  2818. if ftype == TType.STRUCT:
  2819. self.ctx = hadoop.api.common.ttypes.RequestContext()
  2820. self.ctx.read(iprot)
  2821. else:
  2822. iprot.skip(ftype)
  2823. elif fid == 2:
  2824. if ftype == TType.STRUCT:
  2825. self.jobID = ThriftJobID()
  2826. self.jobID.read(iprot)
  2827. else:
  2828. iprot.skip(ftype)
  2829. elif fid == 3:
  2830. if ftype == TType.SET:
  2831. self.types = set()
  2832. (_etype107, _size104) = iprot.readSetBegin()
  2833. for _i108 in xrange(_size104):
  2834. _elem109 = iprot.readI32();
  2835. self.types.add(_elem109)
  2836. iprot.readSetEnd()
  2837. else:
  2838. iprot.skip(ftype)
  2839. elif fid == 4:
  2840. if ftype == TType.SET:
  2841. self.states = set()
  2842. (_etype113, _size110) = iprot.readSetBegin()
  2843. for _i114 in xrange(_size110):
  2844. _elem115 = iprot.readI32();
  2845. self.states.add(_elem115)
  2846. iprot.readSetEnd()
  2847. else:
  2848. iprot.skip(ftype)
  2849. elif fid == 5:
  2850. if ftype == TType.STRING:
  2851. self.text = iprot.readString();
  2852. else:
  2853. iprot.skip(ftype)
  2854. elif fid == 6:
  2855. if ftype == TType.I32:
  2856. self.count = iprot.readI32();
  2857. else:
  2858. iprot.skip(ftype)
  2859. elif fid == 7:
  2860. if ftype == TType.I32:
  2861. self.offset = iprot.readI32();
  2862. else:
  2863. iprot.skip(ftype)
  2864. else:
  2865. iprot.skip(ftype)
  2866. iprot.readFieldEnd()
  2867. iprot.readStructEnd()
  2868. def write(self, oprot):
  2869. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2870. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2871. return
  2872. oprot.writeStructBegin('getTaskList_args')
  2873. if self.ctx is not None:
  2874. oprot.writeFieldBegin('ctx', TType.STRUCT, 1)
  2875. self.ctx.write(oprot)
  2876. oprot.writeFieldEnd()
  2877. if self.jobID is not None:
  2878. oprot.writeFieldBegin('jobID', TType.STRUCT, 2)
  2879. self.jobID.write(oprot)
  2880. oprot.writeFieldEnd()
  2881. if self.types is not None:
  2882. oprot.writeFieldBegin('types', TType.SET, 3)
  2883. oprot.writeSetBegin(TType.I32, len(self.types))
  2884. for iter116 in self.types:
  2885. oprot.writeI32(iter116)
  2886. oprot.writeSetEnd()
  2887. oprot.writeFieldEnd()
  2888. if self.states is not None:
  2889. oprot.writeFieldBegin('states', TType.SET, 4)
  2890. oprot.writeSetBegin(TType.I32, len(self.states))
  2891. for iter117 in self.states:
  2892. oprot.writeI32(iter117)
  2893. oprot.writeSetEnd()
  2894. oprot.writeFieldEnd()
  2895. if self.text is not None:
  2896. oprot.writeFieldBegin('text', TType.STRING, 5)
  2897. oprot.writeString(self.text)
  2898. oprot.writeFieldEnd()
  2899. if self.count is not None:
  2900. oprot.writeFieldBegin('count', TType.I32, 6)
  2901. oprot.writeI32(self.count)
  2902. oprot.writeFieldEnd()
  2903. if self.offset is not None:
  2904. oprot.writeFieldBegin('offset', TType.I32, 7)
  2905. oprot.writeI32(self.offset)
  2906. oprot.writeFieldEnd()
  2907. oprot.writeFieldStop()
  2908. oprot.writeStructEnd()
  2909. def validate(self):
  2910. return
  2911. def __repr__(self):
  2912. L = ['%s=%r' % (key, value)
  2913. for key, value in self.__dict__.iteritems()]
  2914. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2915. def __eq__(self, other):
  2916. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2917. def __ne__(self, other):
  2918. return not (self == other)
  2919. class getTaskList_result(object):
  2920. """
  2921. Attributes:
  2922. - success
  2923. - err
  2924. """
  2925. thrift_spec = (
  2926. (0, TType.STRUCT, 'success', (ThriftTaskInProgressList, ThriftTaskInProgressList.thrift_spec), None, ), # 0
  2927. (1, TType.STRUCT, 'err', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 1
  2928. )
  2929. def __init__(self, success=None, err=None,):
  2930. self.success = success
  2931. self.err = err
  2932. def read(self, iprot):
  2933. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2934. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2935. return
  2936. iprot.readStructBegin()
  2937. while True:
  2938. (fname, ftype, fid) = iprot.readFieldBegin()
  2939. if ftype == TType.STOP:
  2940. break
  2941. if fid == 0:
  2942. if ftype == TType.STRUCT:
  2943. self.success = ThriftTaskInProgressList()
  2944. self.success.read(iprot)
  2945. else:
  2946. iprot.skip(ftype)
  2947. elif fid == 1:
  2948. if ftype == TType.STRUCT:
  2949. self.err = JobNotFoundException()
  2950. self.err.read(iprot)
  2951. else:
  2952. iprot.skip(ftype)
  2953. else:
  2954. iprot.skip(ftype)
  2955. iprot.readFieldEnd()
  2956. iprot.readStructEnd()
  2957. def write(self, oprot):
  2958. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  2959. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  2960. return
  2961. oprot.writeStructBegin('getTaskList_result')
  2962. if self.success is not None:
  2963. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  2964. self.success.write(oprot)
  2965. oprot.writeFieldEnd()
  2966. if self.err is not None:
  2967. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  2968. self.err.write(oprot)
  2969. oprot.writeFieldEnd()
  2970. oprot.writeFieldStop()
  2971. oprot.writeStructEnd()
  2972. def validate(self):
  2973. return
  2974. def __repr__(self):
  2975. L = ['%s=%r' % (key, value)
  2976. for key, value in self.__dict__.iteritems()]
  2977. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  2978. def __eq__(self, other):
  2979. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  2980. def __ne__(self, other):
  2981. return not (self == other)
  2982. class getTask_args(object):
  2983. """
  2984. Attributes:
  2985. - ctx
  2986. - taskID
  2987. """
  2988. thrift_spec = (
  2989. None, # 0
  2990. (1, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 1
  2991. (2, TType.STRUCT, 'taskID', (ThriftTaskID, ThriftTaskID.thrift_spec), None, ), # 2
  2992. )
  2993. def __init__(self, ctx=None, taskID=None,):
  2994. self.ctx = ctx
  2995. self.taskID = taskID
  2996. def read(self, iprot):
  2997. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  2998. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  2999. return
  3000. iprot.readStructBegin()
  3001. while True:
  3002. (fname, ftype, fid) = iprot.readFieldBegin()
  3003. if ftype == TType.STOP:
  3004. break
  3005. if fid == 1:
  3006. if ftype == TType.STRUCT:
  3007. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3008. self.ctx.read(iprot)
  3009. else:
  3010. iprot.skip(ftype)
  3011. elif fid == 2:
  3012. if ftype == TType.STRUCT:
  3013. self.taskID = ThriftTaskID()
  3014. self.taskID.read(iprot)
  3015. else:
  3016. iprot.skip(ftype)
  3017. else:
  3018. iprot.skip(ftype)
  3019. iprot.readFieldEnd()
  3020. iprot.readStructEnd()
  3021. def write(self, oprot):
  3022. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3023. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3024. return
  3025. oprot.writeStructBegin('getTask_args')
  3026. if self.ctx is not None:
  3027. oprot.writeFieldBegin('ctx', TType.STRUCT, 1)
  3028. self.ctx.write(oprot)
  3029. oprot.writeFieldEnd()
  3030. if self.taskID is not None:
  3031. oprot.writeFieldBegin('taskID', TType.STRUCT, 2)
  3032. self.taskID.write(oprot)
  3033. oprot.writeFieldEnd()
  3034. oprot.writeFieldStop()
  3035. oprot.writeStructEnd()
  3036. def validate(self):
  3037. return
  3038. def __repr__(self):
  3039. L = ['%s=%r' % (key, value)
  3040. for key, value in self.__dict__.iteritems()]
  3041. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3042. def __eq__(self, other):
  3043. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3044. def __ne__(self, other):
  3045. return not (self == other)
  3046. class getTask_result(object):
  3047. """
  3048. Attributes:
  3049. - success
  3050. - jnf
  3051. - tnf
  3052. """
  3053. thrift_spec = (
  3054. (0, TType.STRUCT, 'success', (ThriftTaskInProgress, ThriftTaskInProgress.thrift_spec), None, ), # 0
  3055. (1, TType.STRUCT, 'jnf', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 1
  3056. (2, TType.STRUCT, 'tnf', (TaskNotFoundException, TaskNotFoundException.thrift_spec), None, ), # 2
  3057. )
  3058. def __init__(self, success=None, jnf=None, tnf=None,):
  3059. self.success = success
  3060. self.jnf = jnf
  3061. self.tnf = tnf
  3062. def read(self, iprot):
  3063. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3064. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3065. return
  3066. iprot.readStructBegin()
  3067. while True:
  3068. (fname, ftype, fid) = iprot.readFieldBegin()
  3069. if ftype == TType.STOP:
  3070. break
  3071. if fid == 0:
  3072. if ftype == TType.STRUCT:
  3073. self.success = ThriftTaskInProgress()
  3074. self.success.read(iprot)
  3075. else:
  3076. iprot.skip(ftype)
  3077. elif fid == 1:
  3078. if ftype == TType.STRUCT:
  3079. self.jnf = JobNotFoundException()
  3080. self.jnf.read(iprot)
  3081. else:
  3082. iprot.skip(ftype)
  3083. elif fid == 2:
  3084. if ftype == TType.STRUCT:
  3085. self.tnf = TaskNotFoundException()
  3086. self.tnf.read(iprot)
  3087. else:
  3088. iprot.skip(ftype)
  3089. else:
  3090. iprot.skip(ftype)
  3091. iprot.readFieldEnd()
  3092. iprot.readStructEnd()
  3093. def write(self, oprot):
  3094. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3095. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3096. return
  3097. oprot.writeStructBegin('getTask_result')
  3098. if self.success is not None:
  3099. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3100. self.success.write(oprot)
  3101. oprot.writeFieldEnd()
  3102. if self.jnf is not None:
  3103. oprot.writeFieldBegin('jnf', TType.STRUCT, 1)
  3104. self.jnf.write(oprot)
  3105. oprot.writeFieldEnd()
  3106. if self.tnf is not None:
  3107. oprot.writeFieldBegin('tnf', TType.STRUCT, 2)
  3108. self.tnf.write(oprot)
  3109. oprot.writeFieldEnd()
  3110. oprot.writeFieldStop()
  3111. oprot.writeStructEnd()
  3112. def validate(self):
  3113. return
  3114. def __repr__(self):
  3115. L = ['%s=%r' % (key, value)
  3116. for key, value in self.__dict__.iteritems()]
  3117. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3118. def __eq__(self, other):
  3119. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3120. def __ne__(self, other):
  3121. return not (self == other)
  3122. class getJobCounters_args(object):
  3123. """
  3124. Attributes:
  3125. - ctx
  3126. - jobID
  3127. """
  3128. thrift_spec = (
  3129. None, # 0
  3130. (1, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 1
  3131. None, # 2
  3132. None, # 3
  3133. None, # 4
  3134. None, # 5
  3135. None, # 6
  3136. None, # 7
  3137. None, # 8
  3138. None, # 9
  3139. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3140. )
  3141. def __init__(self, ctx=None, jobID=None,):
  3142. self.ctx = ctx
  3143. self.jobID = jobID
  3144. def read(self, iprot):
  3145. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3146. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3147. return
  3148. iprot.readStructBegin()
  3149. while True:
  3150. (fname, ftype, fid) = iprot.readFieldBegin()
  3151. if ftype == TType.STOP:
  3152. break
  3153. if fid == 10:
  3154. if ftype == TType.STRUCT:
  3155. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3156. self.ctx.read(iprot)
  3157. else:
  3158. iprot.skip(ftype)
  3159. elif fid == 1:
  3160. if ftype == TType.STRUCT:
  3161. self.jobID = ThriftJobID()
  3162. self.jobID.read(iprot)
  3163. else:
  3164. iprot.skip(ftype)
  3165. else:
  3166. iprot.skip(ftype)
  3167. iprot.readFieldEnd()
  3168. iprot.readStructEnd()
  3169. def write(self, oprot):
  3170. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3171. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3172. return
  3173. oprot.writeStructBegin('getJobCounters_args')
  3174. if self.jobID is not None:
  3175. oprot.writeFieldBegin('jobID', TType.STRUCT, 1)
  3176. self.jobID.write(oprot)
  3177. oprot.writeFieldEnd()
  3178. if self.ctx is not None:
  3179. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  3180. self.ctx.write(oprot)
  3181. oprot.writeFieldEnd()
  3182. oprot.writeFieldStop()
  3183. oprot.writeStructEnd()
  3184. def validate(self):
  3185. return
  3186. def __repr__(self):
  3187. L = ['%s=%r' % (key, value)
  3188. for key, value in self.__dict__.iteritems()]
  3189. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3190. def __eq__(self, other):
  3191. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3192. def __ne__(self, other):
  3193. return not (self == other)
  3194. class getJobCounters_result(object):
  3195. """
  3196. Attributes:
  3197. - success
  3198. - err
  3199. """
  3200. thrift_spec = (
  3201. (0, TType.STRUCT, 'success', (ThriftGroupList, ThriftGroupList.thrift_spec), None, ), # 0
  3202. (1, TType.STRUCT, 'err', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 1
  3203. )
  3204. def __init__(self, success=None, err=None,):
  3205. self.success = success
  3206. self.err = err
  3207. def read(self, iprot):
  3208. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3209. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3210. return
  3211. iprot.readStructBegin()
  3212. while True:
  3213. (fname, ftype, fid) = iprot.readFieldBegin()
  3214. if ftype == TType.STOP:
  3215. break
  3216. if fid == 0:
  3217. if ftype == TType.STRUCT:
  3218. self.success = ThriftGroupList()
  3219. self.success.read(iprot)
  3220. else:
  3221. iprot.skip(ftype)
  3222. elif fid == 1:
  3223. if ftype == TType.STRUCT:
  3224. self.err = JobNotFoundException()
  3225. self.err.read(iprot)
  3226. else:
  3227. iprot.skip(ftype)
  3228. else:
  3229. iprot.skip(ftype)
  3230. iprot.readFieldEnd()
  3231. iprot.readStructEnd()
  3232. def write(self, oprot):
  3233. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3234. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3235. return
  3236. oprot.writeStructBegin('getJobCounters_result')
  3237. if self.success is not None:
  3238. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3239. self.success.write(oprot)
  3240. oprot.writeFieldEnd()
  3241. if self.err is not None:
  3242. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  3243. self.err.write(oprot)
  3244. oprot.writeFieldEnd()
  3245. oprot.writeFieldStop()
  3246. oprot.writeStructEnd()
  3247. def validate(self):
  3248. return
  3249. def __repr__(self):
  3250. L = ['%s=%r' % (key, value)
  3251. for key, value in self.__dict__.iteritems()]
  3252. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3253. def __eq__(self, other):
  3254. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3255. def __ne__(self, other):
  3256. return not (self == other)
  3257. class getJobCounterRollups_args(object):
  3258. """
  3259. Attributes:
  3260. - ctx
  3261. - jobID
  3262. """
  3263. thrift_spec = (
  3264. None, # 0
  3265. (1, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 1
  3266. None, # 2
  3267. None, # 3
  3268. None, # 4
  3269. None, # 5
  3270. None, # 6
  3271. None, # 7
  3272. None, # 8
  3273. None, # 9
  3274. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3275. )
  3276. def __init__(self, ctx=None, jobID=None,):
  3277. self.ctx = ctx
  3278. self.jobID = jobID
  3279. def read(self, iprot):
  3280. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3281. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3282. return
  3283. iprot.readStructBegin()
  3284. while True:
  3285. (fname, ftype, fid) = iprot.readFieldBegin()
  3286. if ftype == TType.STOP:
  3287. break
  3288. if fid == 10:
  3289. if ftype == TType.STRUCT:
  3290. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3291. self.ctx.read(iprot)
  3292. else:
  3293. iprot.skip(ftype)
  3294. elif fid == 1:
  3295. if ftype == TType.STRUCT:
  3296. self.jobID = ThriftJobID()
  3297. self.jobID.read(iprot)
  3298. else:
  3299. iprot.skip(ftype)
  3300. else:
  3301. iprot.skip(ftype)
  3302. iprot.readFieldEnd()
  3303. iprot.readStructEnd()
  3304. def write(self, oprot):
  3305. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3306. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3307. return
  3308. oprot.writeStructBegin('getJobCounterRollups_args')
  3309. if self.jobID is not None:
  3310. oprot.writeFieldBegin('jobID', TType.STRUCT, 1)
  3311. self.jobID.write(oprot)
  3312. oprot.writeFieldEnd()
  3313. if self.ctx is not None:
  3314. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  3315. self.ctx.write(oprot)
  3316. oprot.writeFieldEnd()
  3317. oprot.writeFieldStop()
  3318. oprot.writeStructEnd()
  3319. def validate(self):
  3320. return
  3321. def __repr__(self):
  3322. L = ['%s=%r' % (key, value)
  3323. for key, value in self.__dict__.iteritems()]
  3324. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3325. def __eq__(self, other):
  3326. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3327. def __ne__(self, other):
  3328. return not (self == other)
  3329. class getJobCounterRollups_result(object):
  3330. """
  3331. Attributes:
  3332. - success
  3333. - err
  3334. """
  3335. thrift_spec = (
  3336. (0, TType.STRUCT, 'success', (ThriftJobCounterRollups, ThriftJobCounterRollups.thrift_spec), None, ), # 0
  3337. (1, TType.STRUCT, 'err', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 1
  3338. )
  3339. def __init__(self, success=None, err=None,):
  3340. self.success = success
  3341. self.err = err
  3342. def read(self, iprot):
  3343. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3344. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3345. return
  3346. iprot.readStructBegin()
  3347. while True:
  3348. (fname, ftype, fid) = iprot.readFieldBegin()
  3349. if ftype == TType.STOP:
  3350. break
  3351. if fid == 0:
  3352. if ftype == TType.STRUCT:
  3353. self.success = ThriftJobCounterRollups()
  3354. self.success.read(iprot)
  3355. else:
  3356. iprot.skip(ftype)
  3357. elif fid == 1:
  3358. if ftype == TType.STRUCT:
  3359. self.err = JobNotFoundException()
  3360. self.err.read(iprot)
  3361. else:
  3362. iprot.skip(ftype)
  3363. else:
  3364. iprot.skip(ftype)
  3365. iprot.readFieldEnd()
  3366. iprot.readStructEnd()
  3367. def write(self, oprot):
  3368. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3369. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3370. return
  3371. oprot.writeStructBegin('getJobCounterRollups_result')
  3372. if self.success is not None:
  3373. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3374. self.success.write(oprot)
  3375. oprot.writeFieldEnd()
  3376. if self.err is not None:
  3377. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  3378. self.err.write(oprot)
  3379. oprot.writeFieldEnd()
  3380. oprot.writeFieldStop()
  3381. oprot.writeStructEnd()
  3382. def validate(self):
  3383. return
  3384. def __repr__(self):
  3385. L = ['%s=%r' % (key, value)
  3386. for key, value in self.__dict__.iteritems()]
  3387. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3388. def __eq__(self, other):
  3389. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3390. def __ne__(self, other):
  3391. return not (self == other)
  3392. class getActiveTrackers_args(object):
  3393. """
  3394. Attributes:
  3395. - ctx
  3396. """
  3397. thrift_spec = (
  3398. None, # 0
  3399. None, # 1
  3400. None, # 2
  3401. None, # 3
  3402. None, # 4
  3403. None, # 5
  3404. None, # 6
  3405. None, # 7
  3406. None, # 8
  3407. None, # 9
  3408. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3409. )
  3410. def __init__(self, ctx=None,):
  3411. self.ctx = ctx
  3412. def read(self, iprot):
  3413. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3414. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3415. return
  3416. iprot.readStructBegin()
  3417. while True:
  3418. (fname, ftype, fid) = iprot.readFieldBegin()
  3419. if ftype == TType.STOP:
  3420. break
  3421. if fid == 10:
  3422. if ftype == TType.STRUCT:
  3423. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3424. self.ctx.read(iprot)
  3425. else:
  3426. iprot.skip(ftype)
  3427. else:
  3428. iprot.skip(ftype)
  3429. iprot.readFieldEnd()
  3430. iprot.readStructEnd()
  3431. def write(self, oprot):
  3432. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3433. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3434. return
  3435. oprot.writeStructBegin('getActiveTrackers_args')
  3436. if self.ctx is not None:
  3437. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  3438. self.ctx.write(oprot)
  3439. oprot.writeFieldEnd()
  3440. oprot.writeFieldStop()
  3441. oprot.writeStructEnd()
  3442. def validate(self):
  3443. return
  3444. def __repr__(self):
  3445. L = ['%s=%r' % (key, value)
  3446. for key, value in self.__dict__.iteritems()]
  3447. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3448. def __eq__(self, other):
  3449. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3450. def __ne__(self, other):
  3451. return not (self == other)
  3452. class getActiveTrackers_result(object):
  3453. """
  3454. Attributes:
  3455. - success
  3456. """
  3457. thrift_spec = (
  3458. (0, TType.STRUCT, 'success', (ThriftTaskTrackerStatusList, ThriftTaskTrackerStatusList.thrift_spec), None, ), # 0
  3459. )
  3460. def __init__(self, success=None,):
  3461. self.success = success
  3462. def read(self, iprot):
  3463. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3464. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3465. return
  3466. iprot.readStructBegin()
  3467. while True:
  3468. (fname, ftype, fid) = iprot.readFieldBegin()
  3469. if ftype == TType.STOP:
  3470. break
  3471. if fid == 0:
  3472. if ftype == TType.STRUCT:
  3473. self.success = ThriftTaskTrackerStatusList()
  3474. self.success.read(iprot)
  3475. else:
  3476. iprot.skip(ftype)
  3477. else:
  3478. iprot.skip(ftype)
  3479. iprot.readFieldEnd()
  3480. iprot.readStructEnd()
  3481. def write(self, oprot):
  3482. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3483. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3484. return
  3485. oprot.writeStructBegin('getActiveTrackers_result')
  3486. if self.success is not None:
  3487. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3488. self.success.write(oprot)
  3489. oprot.writeFieldEnd()
  3490. oprot.writeFieldStop()
  3491. oprot.writeStructEnd()
  3492. def validate(self):
  3493. return
  3494. def __repr__(self):
  3495. L = ['%s=%r' % (key, value)
  3496. for key, value in self.__dict__.iteritems()]
  3497. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3498. def __eq__(self, other):
  3499. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3500. def __ne__(self, other):
  3501. return not (self == other)
  3502. class getBlacklistedTrackers_args(object):
  3503. """
  3504. Attributes:
  3505. - ctx
  3506. """
  3507. thrift_spec = (
  3508. None, # 0
  3509. None, # 1
  3510. None, # 2
  3511. None, # 3
  3512. None, # 4
  3513. None, # 5
  3514. None, # 6
  3515. None, # 7
  3516. None, # 8
  3517. None, # 9
  3518. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3519. )
  3520. def __init__(self, ctx=None,):
  3521. self.ctx = ctx
  3522. def read(self, iprot):
  3523. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3524. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3525. return
  3526. iprot.readStructBegin()
  3527. while True:
  3528. (fname, ftype, fid) = iprot.readFieldBegin()
  3529. if ftype == TType.STOP:
  3530. break
  3531. if fid == 10:
  3532. if ftype == TType.STRUCT:
  3533. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3534. self.ctx.read(iprot)
  3535. else:
  3536. iprot.skip(ftype)
  3537. else:
  3538. iprot.skip(ftype)
  3539. iprot.readFieldEnd()
  3540. iprot.readStructEnd()
  3541. def write(self, oprot):
  3542. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3543. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3544. return
  3545. oprot.writeStructBegin('getBlacklistedTrackers_args')
  3546. if self.ctx is not None:
  3547. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  3548. self.ctx.write(oprot)
  3549. oprot.writeFieldEnd()
  3550. oprot.writeFieldStop()
  3551. oprot.writeStructEnd()
  3552. def validate(self):
  3553. return
  3554. def __repr__(self):
  3555. L = ['%s=%r' % (key, value)
  3556. for key, value in self.__dict__.iteritems()]
  3557. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3558. def __eq__(self, other):
  3559. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3560. def __ne__(self, other):
  3561. return not (self == other)
  3562. class getBlacklistedTrackers_result(object):
  3563. """
  3564. Attributes:
  3565. - success
  3566. """
  3567. thrift_spec = (
  3568. (0, TType.STRUCT, 'success', (ThriftTaskTrackerStatusList, ThriftTaskTrackerStatusList.thrift_spec), None, ), # 0
  3569. )
  3570. def __init__(self, success=None,):
  3571. self.success = success
  3572. def read(self, iprot):
  3573. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3574. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3575. return
  3576. iprot.readStructBegin()
  3577. while True:
  3578. (fname, ftype, fid) = iprot.readFieldBegin()
  3579. if ftype == TType.STOP:
  3580. break
  3581. if fid == 0:
  3582. if ftype == TType.STRUCT:
  3583. self.success = ThriftTaskTrackerStatusList()
  3584. self.success.read(iprot)
  3585. else:
  3586. iprot.skip(ftype)
  3587. else:
  3588. iprot.skip(ftype)
  3589. iprot.readFieldEnd()
  3590. iprot.readStructEnd()
  3591. def write(self, oprot):
  3592. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3593. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3594. return
  3595. oprot.writeStructBegin('getBlacklistedTrackers_result')
  3596. if self.success is not None:
  3597. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3598. self.success.write(oprot)
  3599. oprot.writeFieldEnd()
  3600. oprot.writeFieldStop()
  3601. oprot.writeStructEnd()
  3602. def validate(self):
  3603. return
  3604. def __repr__(self):
  3605. L = ['%s=%r' % (key, value)
  3606. for key, value in self.__dict__.iteritems()]
  3607. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3608. def __eq__(self, other):
  3609. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3610. def __ne__(self, other):
  3611. return not (self == other)
  3612. class getAllTrackers_args(object):
  3613. """
  3614. Attributes:
  3615. - ctx
  3616. """
  3617. thrift_spec = (
  3618. None, # 0
  3619. None, # 1
  3620. None, # 2
  3621. None, # 3
  3622. None, # 4
  3623. None, # 5
  3624. None, # 6
  3625. None, # 7
  3626. None, # 8
  3627. None, # 9
  3628. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3629. )
  3630. def __init__(self, ctx=None,):
  3631. self.ctx = ctx
  3632. def read(self, iprot):
  3633. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3634. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3635. return
  3636. iprot.readStructBegin()
  3637. while True:
  3638. (fname, ftype, fid) = iprot.readFieldBegin()
  3639. if ftype == TType.STOP:
  3640. break
  3641. if fid == 10:
  3642. if ftype == TType.STRUCT:
  3643. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3644. self.ctx.read(iprot)
  3645. else:
  3646. iprot.skip(ftype)
  3647. else:
  3648. iprot.skip(ftype)
  3649. iprot.readFieldEnd()
  3650. iprot.readStructEnd()
  3651. def write(self, oprot):
  3652. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3653. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3654. return
  3655. oprot.writeStructBegin('getAllTrackers_args')
  3656. if self.ctx is not None:
  3657. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  3658. self.ctx.write(oprot)
  3659. oprot.writeFieldEnd()
  3660. oprot.writeFieldStop()
  3661. oprot.writeStructEnd()
  3662. def validate(self):
  3663. return
  3664. def __repr__(self):
  3665. L = ['%s=%r' % (key, value)
  3666. for key, value in self.__dict__.iteritems()]
  3667. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3668. def __eq__(self, other):
  3669. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3670. def __ne__(self, other):
  3671. return not (self == other)
  3672. class getAllTrackers_result(object):
  3673. """
  3674. Attributes:
  3675. - success
  3676. """
  3677. thrift_spec = (
  3678. (0, TType.STRUCT, 'success', (ThriftTaskTrackerStatusList, ThriftTaskTrackerStatusList.thrift_spec), None, ), # 0
  3679. )
  3680. def __init__(self, success=None,):
  3681. self.success = success
  3682. def read(self, iprot):
  3683. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3684. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3685. return
  3686. iprot.readStructBegin()
  3687. while True:
  3688. (fname, ftype, fid) = iprot.readFieldBegin()
  3689. if ftype == TType.STOP:
  3690. break
  3691. if fid == 0:
  3692. if ftype == TType.STRUCT:
  3693. self.success = ThriftTaskTrackerStatusList()
  3694. self.success.read(iprot)
  3695. else:
  3696. iprot.skip(ftype)
  3697. else:
  3698. iprot.skip(ftype)
  3699. iprot.readFieldEnd()
  3700. iprot.readStructEnd()
  3701. def write(self, oprot):
  3702. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3703. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3704. return
  3705. oprot.writeStructBegin('getAllTrackers_result')
  3706. if self.success is not None:
  3707. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3708. self.success.write(oprot)
  3709. oprot.writeFieldEnd()
  3710. oprot.writeFieldStop()
  3711. oprot.writeStructEnd()
  3712. def validate(self):
  3713. return
  3714. def __repr__(self):
  3715. L = ['%s=%r' % (key, value)
  3716. for key, value in self.__dict__.iteritems()]
  3717. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3718. def __eq__(self, other):
  3719. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3720. def __ne__(self, other):
  3721. return not (self == other)
  3722. class getTracker_args(object):
  3723. """
  3724. Attributes:
  3725. - ctx
  3726. - name
  3727. """
  3728. thrift_spec = (
  3729. None, # 0
  3730. (1, TType.STRING, 'name', None, None, ), # 1
  3731. None, # 2
  3732. None, # 3
  3733. None, # 4
  3734. None, # 5
  3735. None, # 6
  3736. None, # 7
  3737. None, # 8
  3738. None, # 9
  3739. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3740. )
  3741. def __init__(self, ctx=None, name=None,):
  3742. self.ctx = ctx
  3743. self.name = name
  3744. def read(self, iprot):
  3745. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3746. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3747. return
  3748. iprot.readStructBegin()
  3749. while True:
  3750. (fname, ftype, fid) = iprot.readFieldBegin()
  3751. if ftype == TType.STOP:
  3752. break
  3753. if fid == 10:
  3754. if ftype == TType.STRUCT:
  3755. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3756. self.ctx.read(iprot)
  3757. else:
  3758. iprot.skip(ftype)
  3759. elif fid == 1:
  3760. if ftype == TType.STRING:
  3761. self.name = iprot.readString();
  3762. else:
  3763. iprot.skip(ftype)
  3764. else:
  3765. iprot.skip(ftype)
  3766. iprot.readFieldEnd()
  3767. iprot.readStructEnd()
  3768. def write(self, oprot):
  3769. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3770. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3771. return
  3772. oprot.writeStructBegin('getTracker_args')
  3773. if self.name is not None:
  3774. oprot.writeFieldBegin('name', TType.STRING, 1)
  3775. oprot.writeString(self.name)
  3776. oprot.writeFieldEnd()
  3777. if self.ctx is not None:
  3778. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  3779. self.ctx.write(oprot)
  3780. oprot.writeFieldEnd()
  3781. oprot.writeFieldStop()
  3782. oprot.writeStructEnd()
  3783. def validate(self):
  3784. return
  3785. def __repr__(self):
  3786. L = ['%s=%r' % (key, value)
  3787. for key, value in self.__dict__.iteritems()]
  3788. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3789. def __eq__(self, other):
  3790. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3791. def __ne__(self, other):
  3792. return not (self == other)
  3793. class getTracker_result(object):
  3794. """
  3795. Attributes:
  3796. - success
  3797. - tne
  3798. """
  3799. thrift_spec = (
  3800. (0, TType.STRUCT, 'success', (ThriftTaskTrackerStatus, ThriftTaskTrackerStatus.thrift_spec), None, ), # 0
  3801. (1, TType.STRUCT, 'tne', (TaskTrackerNotFoundException, TaskTrackerNotFoundException.thrift_spec), None, ), # 1
  3802. )
  3803. def __init__(self, success=None, tne=None,):
  3804. self.success = success
  3805. self.tne = tne
  3806. def read(self, iprot):
  3807. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3808. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3809. return
  3810. iprot.readStructBegin()
  3811. while True:
  3812. (fname, ftype, fid) = iprot.readFieldBegin()
  3813. if ftype == TType.STOP:
  3814. break
  3815. if fid == 0:
  3816. if ftype == TType.STRUCT:
  3817. self.success = ThriftTaskTrackerStatus()
  3818. self.success.read(iprot)
  3819. else:
  3820. iprot.skip(ftype)
  3821. elif fid == 1:
  3822. if ftype == TType.STRUCT:
  3823. self.tne = TaskTrackerNotFoundException()
  3824. self.tne.read(iprot)
  3825. else:
  3826. iprot.skip(ftype)
  3827. else:
  3828. iprot.skip(ftype)
  3829. iprot.readFieldEnd()
  3830. iprot.readStructEnd()
  3831. def write(self, oprot):
  3832. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3833. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3834. return
  3835. oprot.writeStructBegin('getTracker_result')
  3836. if self.success is not None:
  3837. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  3838. self.success.write(oprot)
  3839. oprot.writeFieldEnd()
  3840. if self.tne is not None:
  3841. oprot.writeFieldBegin('tne', TType.STRUCT, 1)
  3842. self.tne.write(oprot)
  3843. oprot.writeFieldEnd()
  3844. oprot.writeFieldStop()
  3845. oprot.writeStructEnd()
  3846. def validate(self):
  3847. return
  3848. def __repr__(self):
  3849. L = ['%s=%r' % (key, value)
  3850. for key, value in self.__dict__.iteritems()]
  3851. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3852. def __eq__(self, other):
  3853. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3854. def __ne__(self, other):
  3855. return not (self == other)
  3856. class getCurrentTime_args(object):
  3857. """
  3858. Attributes:
  3859. - ctx
  3860. """
  3861. thrift_spec = (
  3862. None, # 0
  3863. None, # 1
  3864. None, # 2
  3865. None, # 3
  3866. None, # 4
  3867. None, # 5
  3868. None, # 6
  3869. None, # 7
  3870. None, # 8
  3871. None, # 9
  3872. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3873. )
  3874. def __init__(self, ctx=None,):
  3875. self.ctx = ctx
  3876. def read(self, iprot):
  3877. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3878. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3879. return
  3880. iprot.readStructBegin()
  3881. while True:
  3882. (fname, ftype, fid) = iprot.readFieldBegin()
  3883. if ftype == TType.STOP:
  3884. break
  3885. if fid == 10:
  3886. if ftype == TType.STRUCT:
  3887. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3888. self.ctx.read(iprot)
  3889. else:
  3890. iprot.skip(ftype)
  3891. else:
  3892. iprot.skip(ftype)
  3893. iprot.readFieldEnd()
  3894. iprot.readStructEnd()
  3895. def write(self, oprot):
  3896. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3897. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3898. return
  3899. oprot.writeStructBegin('getCurrentTime_args')
  3900. if self.ctx is not None:
  3901. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  3902. self.ctx.write(oprot)
  3903. oprot.writeFieldEnd()
  3904. oprot.writeFieldStop()
  3905. oprot.writeStructEnd()
  3906. def validate(self):
  3907. return
  3908. def __repr__(self):
  3909. L = ['%s=%r' % (key, value)
  3910. for key, value in self.__dict__.iteritems()]
  3911. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3912. def __eq__(self, other):
  3913. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3914. def __ne__(self, other):
  3915. return not (self == other)
  3916. class getCurrentTime_result(object):
  3917. """
  3918. Attributes:
  3919. - success
  3920. """
  3921. thrift_spec = (
  3922. (0, TType.I64, 'success', None, None, ), # 0
  3923. )
  3924. def __init__(self, success=None,):
  3925. self.success = success
  3926. def read(self, iprot):
  3927. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3928. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3929. return
  3930. iprot.readStructBegin()
  3931. while True:
  3932. (fname, ftype, fid) = iprot.readFieldBegin()
  3933. if ftype == TType.STOP:
  3934. break
  3935. if fid == 0:
  3936. if ftype == TType.I64:
  3937. self.success = iprot.readI64();
  3938. else:
  3939. iprot.skip(ftype)
  3940. else:
  3941. iprot.skip(ftype)
  3942. iprot.readFieldEnd()
  3943. iprot.readStructEnd()
  3944. def write(self, oprot):
  3945. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  3946. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  3947. return
  3948. oprot.writeStructBegin('getCurrentTime_result')
  3949. if self.success is not None:
  3950. oprot.writeFieldBegin('success', TType.I64, 0)
  3951. oprot.writeI64(self.success)
  3952. oprot.writeFieldEnd()
  3953. oprot.writeFieldStop()
  3954. oprot.writeStructEnd()
  3955. def validate(self):
  3956. return
  3957. def __repr__(self):
  3958. L = ['%s=%r' % (key, value)
  3959. for key, value in self.__dict__.iteritems()]
  3960. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  3961. def __eq__(self, other):
  3962. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  3963. def __ne__(self, other):
  3964. return not (self == other)
  3965. class getJobConfXML_args(object):
  3966. """
  3967. Attributes:
  3968. - ctx
  3969. - jobID
  3970. """
  3971. thrift_spec = (
  3972. None, # 0
  3973. (1, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 1
  3974. None, # 2
  3975. None, # 3
  3976. None, # 4
  3977. None, # 5
  3978. None, # 6
  3979. None, # 7
  3980. None, # 8
  3981. None, # 9
  3982. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  3983. )
  3984. def __init__(self, ctx=None, jobID=None,):
  3985. self.ctx = ctx
  3986. self.jobID = jobID
  3987. def read(self, iprot):
  3988. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  3989. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  3990. return
  3991. iprot.readStructBegin()
  3992. while True:
  3993. (fname, ftype, fid) = iprot.readFieldBegin()
  3994. if ftype == TType.STOP:
  3995. break
  3996. if fid == 10:
  3997. if ftype == TType.STRUCT:
  3998. self.ctx = hadoop.api.common.ttypes.RequestContext()
  3999. self.ctx.read(iprot)
  4000. else:
  4001. iprot.skip(ftype)
  4002. elif fid == 1:
  4003. if ftype == TType.STRUCT:
  4004. self.jobID = ThriftJobID()
  4005. self.jobID.read(iprot)
  4006. else:
  4007. iprot.skip(ftype)
  4008. else:
  4009. iprot.skip(ftype)
  4010. iprot.readFieldEnd()
  4011. iprot.readStructEnd()
  4012. def write(self, oprot):
  4013. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4014. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4015. return
  4016. oprot.writeStructBegin('getJobConfXML_args')
  4017. if self.jobID is not None:
  4018. oprot.writeFieldBegin('jobID', TType.STRUCT, 1)
  4019. self.jobID.write(oprot)
  4020. oprot.writeFieldEnd()
  4021. if self.ctx is not None:
  4022. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  4023. self.ctx.write(oprot)
  4024. oprot.writeFieldEnd()
  4025. oprot.writeFieldStop()
  4026. oprot.writeStructEnd()
  4027. def validate(self):
  4028. return
  4029. def __repr__(self):
  4030. L = ['%s=%r' % (key, value)
  4031. for key, value in self.__dict__.iteritems()]
  4032. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4033. def __eq__(self, other):
  4034. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4035. def __ne__(self, other):
  4036. return not (self == other)
  4037. class getJobConfXML_result(object):
  4038. """
  4039. Attributes:
  4040. - success
  4041. - err
  4042. """
  4043. thrift_spec = (
  4044. (0, TType.STRING, 'success', None, None, ), # 0
  4045. (1, TType.STRUCT, 'err', (hadoop.api.common.ttypes.IOException, hadoop.api.common.ttypes.IOException.thrift_spec), None, ), # 1
  4046. )
  4047. def __init__(self, success=None, err=None,):
  4048. self.success = success
  4049. self.err = err
  4050. def read(self, iprot):
  4051. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4052. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4053. return
  4054. iprot.readStructBegin()
  4055. while True:
  4056. (fname, ftype, fid) = iprot.readFieldBegin()
  4057. if ftype == TType.STOP:
  4058. break
  4059. if fid == 0:
  4060. if ftype == TType.STRING:
  4061. self.success = iprot.readString();
  4062. else:
  4063. iprot.skip(ftype)
  4064. elif fid == 1:
  4065. if ftype == TType.STRUCT:
  4066. self.err = hadoop.api.common.ttypes.IOException()
  4067. self.err.read(iprot)
  4068. else:
  4069. iprot.skip(ftype)
  4070. else:
  4071. iprot.skip(ftype)
  4072. iprot.readFieldEnd()
  4073. iprot.readStructEnd()
  4074. def write(self, oprot):
  4075. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4076. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4077. return
  4078. oprot.writeStructBegin('getJobConfXML_result')
  4079. if self.success is not None:
  4080. oprot.writeFieldBegin('success', TType.STRING, 0)
  4081. oprot.writeString(self.success)
  4082. oprot.writeFieldEnd()
  4083. if self.err is not None:
  4084. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  4085. self.err.write(oprot)
  4086. oprot.writeFieldEnd()
  4087. oprot.writeFieldStop()
  4088. oprot.writeStructEnd()
  4089. def validate(self):
  4090. return
  4091. def __repr__(self):
  4092. L = ['%s=%r' % (key, value)
  4093. for key, value in self.__dict__.iteritems()]
  4094. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4095. def __eq__(self, other):
  4096. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4097. def __ne__(self, other):
  4098. return not (self == other)
  4099. class killJob_args(object):
  4100. """
  4101. Attributes:
  4102. - ctx
  4103. - jobID
  4104. """
  4105. thrift_spec = (
  4106. None, # 0
  4107. (1, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 1
  4108. None, # 2
  4109. None, # 3
  4110. None, # 4
  4111. None, # 5
  4112. None, # 6
  4113. None, # 7
  4114. None, # 8
  4115. None, # 9
  4116. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  4117. )
  4118. def __init__(self, ctx=None, jobID=None,):
  4119. self.ctx = ctx
  4120. self.jobID = jobID
  4121. def read(self, iprot):
  4122. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4123. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4124. return
  4125. iprot.readStructBegin()
  4126. while True:
  4127. (fname, ftype, fid) = iprot.readFieldBegin()
  4128. if ftype == TType.STOP:
  4129. break
  4130. if fid == 10:
  4131. if ftype == TType.STRUCT:
  4132. self.ctx = hadoop.api.common.ttypes.RequestContext()
  4133. self.ctx.read(iprot)
  4134. else:
  4135. iprot.skip(ftype)
  4136. elif fid == 1:
  4137. if ftype == TType.STRUCT:
  4138. self.jobID = ThriftJobID()
  4139. self.jobID.read(iprot)
  4140. else:
  4141. iprot.skip(ftype)
  4142. else:
  4143. iprot.skip(ftype)
  4144. iprot.readFieldEnd()
  4145. iprot.readStructEnd()
  4146. def write(self, oprot):
  4147. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4148. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4149. return
  4150. oprot.writeStructBegin('killJob_args')
  4151. if self.jobID is not None:
  4152. oprot.writeFieldBegin('jobID', TType.STRUCT, 1)
  4153. self.jobID.write(oprot)
  4154. oprot.writeFieldEnd()
  4155. if self.ctx is not None:
  4156. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  4157. self.ctx.write(oprot)
  4158. oprot.writeFieldEnd()
  4159. oprot.writeFieldStop()
  4160. oprot.writeStructEnd()
  4161. def validate(self):
  4162. return
  4163. def __repr__(self):
  4164. L = ['%s=%r' % (key, value)
  4165. for key, value in self.__dict__.iteritems()]
  4166. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4167. def __eq__(self, other):
  4168. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4169. def __ne__(self, other):
  4170. return not (self == other)
  4171. class killJob_result(object):
  4172. """
  4173. Attributes:
  4174. - err
  4175. - jne
  4176. """
  4177. thrift_spec = (
  4178. None, # 0
  4179. (1, TType.STRUCT, 'err', (hadoop.api.common.ttypes.IOException, hadoop.api.common.ttypes.IOException.thrift_spec), None, ), # 1
  4180. (2, TType.STRUCT, 'jne', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 2
  4181. )
  4182. def __init__(self, err=None, jne=None,):
  4183. self.err = err
  4184. self.jne = jne
  4185. def read(self, iprot):
  4186. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4187. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4188. return
  4189. iprot.readStructBegin()
  4190. while True:
  4191. (fname, ftype, fid) = iprot.readFieldBegin()
  4192. if ftype == TType.STOP:
  4193. break
  4194. if fid == 1:
  4195. if ftype == TType.STRUCT:
  4196. self.err = hadoop.api.common.ttypes.IOException()
  4197. self.err.read(iprot)
  4198. else:
  4199. iprot.skip(ftype)
  4200. elif fid == 2:
  4201. if ftype == TType.STRUCT:
  4202. self.jne = JobNotFoundException()
  4203. self.jne.read(iprot)
  4204. else:
  4205. iprot.skip(ftype)
  4206. else:
  4207. iprot.skip(ftype)
  4208. iprot.readFieldEnd()
  4209. iprot.readStructEnd()
  4210. def write(self, oprot):
  4211. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4212. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4213. return
  4214. oprot.writeStructBegin('killJob_result')
  4215. if self.err is not None:
  4216. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  4217. self.err.write(oprot)
  4218. oprot.writeFieldEnd()
  4219. if self.jne is not None:
  4220. oprot.writeFieldBegin('jne', TType.STRUCT, 2)
  4221. self.jne.write(oprot)
  4222. oprot.writeFieldEnd()
  4223. oprot.writeFieldStop()
  4224. oprot.writeStructEnd()
  4225. def validate(self):
  4226. return
  4227. def __repr__(self):
  4228. L = ['%s=%r' % (key, value)
  4229. for key, value in self.__dict__.iteritems()]
  4230. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4231. def __eq__(self, other):
  4232. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4233. def __ne__(self, other):
  4234. return not (self == other)
  4235. class killTaskAttempt_args(object):
  4236. """
  4237. Attributes:
  4238. - ctx
  4239. - attemptID
  4240. """
  4241. thrift_spec = (
  4242. None, # 0
  4243. (1, TType.STRUCT, 'attemptID', (ThriftTaskAttemptID, ThriftTaskAttemptID.thrift_spec), None, ), # 1
  4244. None, # 2
  4245. None, # 3
  4246. None, # 4
  4247. None, # 5
  4248. None, # 6
  4249. None, # 7
  4250. None, # 8
  4251. None, # 9
  4252. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  4253. )
  4254. def __init__(self, ctx=None, attemptID=None,):
  4255. self.ctx = ctx
  4256. self.attemptID = attemptID
  4257. def read(self, iprot):
  4258. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4259. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4260. return
  4261. iprot.readStructBegin()
  4262. while True:
  4263. (fname, ftype, fid) = iprot.readFieldBegin()
  4264. if ftype == TType.STOP:
  4265. break
  4266. if fid == 10:
  4267. if ftype == TType.STRUCT:
  4268. self.ctx = hadoop.api.common.ttypes.RequestContext()
  4269. self.ctx.read(iprot)
  4270. else:
  4271. iprot.skip(ftype)
  4272. elif fid == 1:
  4273. if ftype == TType.STRUCT:
  4274. self.attemptID = ThriftTaskAttemptID()
  4275. self.attemptID.read(iprot)
  4276. else:
  4277. iprot.skip(ftype)
  4278. else:
  4279. iprot.skip(ftype)
  4280. iprot.readFieldEnd()
  4281. iprot.readStructEnd()
  4282. def write(self, oprot):
  4283. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4284. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4285. return
  4286. oprot.writeStructBegin('killTaskAttempt_args')
  4287. if self.attemptID is not None:
  4288. oprot.writeFieldBegin('attemptID', TType.STRUCT, 1)
  4289. self.attemptID.write(oprot)
  4290. oprot.writeFieldEnd()
  4291. if self.ctx is not None:
  4292. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  4293. self.ctx.write(oprot)
  4294. oprot.writeFieldEnd()
  4295. oprot.writeFieldStop()
  4296. oprot.writeStructEnd()
  4297. def validate(self):
  4298. return
  4299. def __repr__(self):
  4300. L = ['%s=%r' % (key, value)
  4301. for key, value in self.__dict__.iteritems()]
  4302. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4303. def __eq__(self, other):
  4304. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4305. def __ne__(self, other):
  4306. return not (self == other)
  4307. class killTaskAttempt_result(object):
  4308. """
  4309. Attributes:
  4310. - err
  4311. - tne
  4312. - jne
  4313. """
  4314. thrift_spec = (
  4315. None, # 0
  4316. (1, TType.STRUCT, 'err', (hadoop.api.common.ttypes.IOException, hadoop.api.common.ttypes.IOException.thrift_spec), None, ), # 1
  4317. (2, TType.STRUCT, 'tne', (TaskAttemptNotFoundException, TaskAttemptNotFoundException.thrift_spec), None, ), # 2
  4318. (3, TType.STRUCT, 'jne', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 3
  4319. )
  4320. def __init__(self, err=None, tne=None, jne=None,):
  4321. self.err = err
  4322. self.tne = tne
  4323. self.jne = jne
  4324. def read(self, iprot):
  4325. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4326. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4327. return
  4328. iprot.readStructBegin()
  4329. while True:
  4330. (fname, ftype, fid) = iprot.readFieldBegin()
  4331. if ftype == TType.STOP:
  4332. break
  4333. if fid == 1:
  4334. if ftype == TType.STRUCT:
  4335. self.err = hadoop.api.common.ttypes.IOException()
  4336. self.err.read(iprot)
  4337. else:
  4338. iprot.skip(ftype)
  4339. elif fid == 2:
  4340. if ftype == TType.STRUCT:
  4341. self.tne = TaskAttemptNotFoundException()
  4342. self.tne.read(iprot)
  4343. else:
  4344. iprot.skip(ftype)
  4345. elif fid == 3:
  4346. if ftype == TType.STRUCT:
  4347. self.jne = JobNotFoundException()
  4348. self.jne.read(iprot)
  4349. else:
  4350. iprot.skip(ftype)
  4351. else:
  4352. iprot.skip(ftype)
  4353. iprot.readFieldEnd()
  4354. iprot.readStructEnd()
  4355. def write(self, oprot):
  4356. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4357. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4358. return
  4359. oprot.writeStructBegin('killTaskAttempt_result')
  4360. if self.err is not None:
  4361. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  4362. self.err.write(oprot)
  4363. oprot.writeFieldEnd()
  4364. if self.tne is not None:
  4365. oprot.writeFieldBegin('tne', TType.STRUCT, 2)
  4366. self.tne.write(oprot)
  4367. oprot.writeFieldEnd()
  4368. if self.jne is not None:
  4369. oprot.writeFieldBegin('jne', TType.STRUCT, 3)
  4370. self.jne.write(oprot)
  4371. oprot.writeFieldEnd()
  4372. oprot.writeFieldStop()
  4373. oprot.writeStructEnd()
  4374. def validate(self):
  4375. return
  4376. def __repr__(self):
  4377. L = ['%s=%r' % (key, value)
  4378. for key, value in self.__dict__.iteritems()]
  4379. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4380. def __eq__(self, other):
  4381. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4382. def __ne__(self, other):
  4383. return not (self == other)
  4384. class setJobPriority_args(object):
  4385. """
  4386. Attributes:
  4387. - ctx
  4388. - jobID
  4389. - priority
  4390. """
  4391. thrift_spec = (
  4392. None, # 0
  4393. (1, TType.STRUCT, 'jobID', (ThriftJobID, ThriftJobID.thrift_spec), None, ), # 1
  4394. (2, TType.I32, 'priority', None, None, ), # 2
  4395. None, # 3
  4396. None, # 4
  4397. None, # 5
  4398. None, # 6
  4399. None, # 7
  4400. None, # 8
  4401. None, # 9
  4402. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  4403. )
  4404. def __init__(self, ctx=None, jobID=None, priority=None,):
  4405. self.ctx = ctx
  4406. self.jobID = jobID
  4407. self.priority = priority
  4408. def read(self, iprot):
  4409. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4410. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4411. return
  4412. iprot.readStructBegin()
  4413. while True:
  4414. (fname, ftype, fid) = iprot.readFieldBegin()
  4415. if ftype == TType.STOP:
  4416. break
  4417. if fid == 10:
  4418. if ftype == TType.STRUCT:
  4419. self.ctx = hadoop.api.common.ttypes.RequestContext()
  4420. self.ctx.read(iprot)
  4421. else:
  4422. iprot.skip(ftype)
  4423. elif fid == 1:
  4424. if ftype == TType.STRUCT:
  4425. self.jobID = ThriftJobID()
  4426. self.jobID.read(iprot)
  4427. else:
  4428. iprot.skip(ftype)
  4429. elif fid == 2:
  4430. if ftype == TType.I32:
  4431. self.priority = iprot.readI32();
  4432. else:
  4433. iprot.skip(ftype)
  4434. else:
  4435. iprot.skip(ftype)
  4436. iprot.readFieldEnd()
  4437. iprot.readStructEnd()
  4438. def write(self, oprot):
  4439. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4440. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4441. return
  4442. oprot.writeStructBegin('setJobPriority_args')
  4443. if self.jobID is not None:
  4444. oprot.writeFieldBegin('jobID', TType.STRUCT, 1)
  4445. self.jobID.write(oprot)
  4446. oprot.writeFieldEnd()
  4447. if self.priority is not None:
  4448. oprot.writeFieldBegin('priority', TType.I32, 2)
  4449. oprot.writeI32(self.priority)
  4450. oprot.writeFieldEnd()
  4451. if self.ctx is not None:
  4452. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  4453. self.ctx.write(oprot)
  4454. oprot.writeFieldEnd()
  4455. oprot.writeFieldStop()
  4456. oprot.writeStructEnd()
  4457. def validate(self):
  4458. return
  4459. def __repr__(self):
  4460. L = ['%s=%r' % (key, value)
  4461. for key, value in self.__dict__.iteritems()]
  4462. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4463. def __eq__(self, other):
  4464. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4465. def __ne__(self, other):
  4466. return not (self == other)
  4467. class setJobPriority_result(object):
  4468. """
  4469. Attributes:
  4470. - err
  4471. - jne
  4472. """
  4473. thrift_spec = (
  4474. None, # 0
  4475. (1, TType.STRUCT, 'err', (hadoop.api.common.ttypes.IOException, hadoop.api.common.ttypes.IOException.thrift_spec), None, ), # 1
  4476. (2, TType.STRUCT, 'jne', (JobNotFoundException, JobNotFoundException.thrift_spec), None, ), # 2
  4477. )
  4478. def __init__(self, err=None, jne=None,):
  4479. self.err = err
  4480. self.jne = jne
  4481. def read(self, iprot):
  4482. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4483. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4484. return
  4485. iprot.readStructBegin()
  4486. while True:
  4487. (fname, ftype, fid) = iprot.readFieldBegin()
  4488. if ftype == TType.STOP:
  4489. break
  4490. if fid == 1:
  4491. if ftype == TType.STRUCT:
  4492. self.err = hadoop.api.common.ttypes.IOException()
  4493. self.err.read(iprot)
  4494. else:
  4495. iprot.skip(ftype)
  4496. elif fid == 2:
  4497. if ftype == TType.STRUCT:
  4498. self.jne = JobNotFoundException()
  4499. self.jne.read(iprot)
  4500. else:
  4501. iprot.skip(ftype)
  4502. else:
  4503. iprot.skip(ftype)
  4504. iprot.readFieldEnd()
  4505. iprot.readStructEnd()
  4506. def write(self, oprot):
  4507. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4508. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4509. return
  4510. oprot.writeStructBegin('setJobPriority_result')
  4511. if self.err is not None:
  4512. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  4513. self.err.write(oprot)
  4514. oprot.writeFieldEnd()
  4515. if self.jne is not None:
  4516. oprot.writeFieldBegin('jne', TType.STRUCT, 2)
  4517. self.jne.write(oprot)
  4518. oprot.writeFieldEnd()
  4519. oprot.writeFieldStop()
  4520. oprot.writeStructEnd()
  4521. def validate(self):
  4522. return
  4523. def __repr__(self):
  4524. L = ['%s=%r' % (key, value)
  4525. for key, value in self.__dict__.iteritems()]
  4526. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4527. def __eq__(self, other):
  4528. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4529. def __ne__(self, other):
  4530. return not (self == other)
  4531. class getDelegationToken_args(object):
  4532. """
  4533. Attributes:
  4534. - ctx
  4535. - renewer
  4536. """
  4537. thrift_spec = (
  4538. None, # 0
  4539. (1, TType.STRING, 'renewer', None, None, ), # 1
  4540. None, # 2
  4541. None, # 3
  4542. None, # 4
  4543. None, # 5
  4544. None, # 6
  4545. None, # 7
  4546. None, # 8
  4547. None, # 9
  4548. (10, TType.STRUCT, 'ctx', (hadoop.api.common.ttypes.RequestContext, hadoop.api.common.ttypes.RequestContext.thrift_spec), None, ), # 10
  4549. )
  4550. def __init__(self, ctx=None, renewer=None,):
  4551. self.ctx = ctx
  4552. self.renewer = renewer
  4553. def read(self, iprot):
  4554. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4555. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4556. return
  4557. iprot.readStructBegin()
  4558. while True:
  4559. (fname, ftype, fid) = iprot.readFieldBegin()
  4560. if ftype == TType.STOP:
  4561. break
  4562. if fid == 10:
  4563. if ftype == TType.STRUCT:
  4564. self.ctx = hadoop.api.common.ttypes.RequestContext()
  4565. self.ctx.read(iprot)
  4566. else:
  4567. iprot.skip(ftype)
  4568. elif fid == 1:
  4569. if ftype == TType.STRING:
  4570. self.renewer = iprot.readString();
  4571. else:
  4572. iprot.skip(ftype)
  4573. else:
  4574. iprot.skip(ftype)
  4575. iprot.readFieldEnd()
  4576. iprot.readStructEnd()
  4577. def write(self, oprot):
  4578. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4579. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4580. return
  4581. oprot.writeStructBegin('getDelegationToken_args')
  4582. if self.renewer is not None:
  4583. oprot.writeFieldBegin('renewer', TType.STRING, 1)
  4584. oprot.writeString(self.renewer)
  4585. oprot.writeFieldEnd()
  4586. if self.ctx is not None:
  4587. oprot.writeFieldBegin('ctx', TType.STRUCT, 10)
  4588. self.ctx.write(oprot)
  4589. oprot.writeFieldEnd()
  4590. oprot.writeFieldStop()
  4591. oprot.writeStructEnd()
  4592. def validate(self):
  4593. return
  4594. def __repr__(self):
  4595. L = ['%s=%r' % (key, value)
  4596. for key, value in self.__dict__.iteritems()]
  4597. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4598. def __eq__(self, other):
  4599. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4600. def __ne__(self, other):
  4601. return not (self == other)
  4602. class getDelegationToken_result(object):
  4603. """
  4604. Attributes:
  4605. - success
  4606. - err
  4607. """
  4608. thrift_spec = (
  4609. (0, TType.STRUCT, 'success', (hadoop.api.common.ttypes.ThriftDelegationToken, hadoop.api.common.ttypes.ThriftDelegationToken.thrift_spec), None, ), # 0
  4610. (1, TType.STRUCT, 'err', (hadoop.api.common.ttypes.IOException, hadoop.api.common.ttypes.IOException.thrift_spec), None, ), # 1
  4611. )
  4612. def __init__(self, success=None, err=None,):
  4613. self.success = success
  4614. self.err = err
  4615. def read(self, iprot):
  4616. if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
  4617. fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
  4618. return
  4619. iprot.readStructBegin()
  4620. while True:
  4621. (fname, ftype, fid) = iprot.readFieldBegin()
  4622. if ftype == TType.STOP:
  4623. break
  4624. if fid == 0:
  4625. if ftype == TType.STRUCT:
  4626. self.success = hadoop.api.common.ttypes.ThriftDelegationToken()
  4627. self.success.read(iprot)
  4628. else:
  4629. iprot.skip(ftype)
  4630. elif fid == 1:
  4631. if ftype == TType.STRUCT:
  4632. self.err = hadoop.api.common.ttypes.IOException()
  4633. self.err.read(iprot)
  4634. else:
  4635. iprot.skip(ftype)
  4636. else:
  4637. iprot.skip(ftype)
  4638. iprot.readFieldEnd()
  4639. iprot.readStructEnd()
  4640. def write(self, oprot):
  4641. if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
  4642. oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
  4643. return
  4644. oprot.writeStructBegin('getDelegationToken_result')
  4645. if self.success is not None:
  4646. oprot.writeFieldBegin('success', TType.STRUCT, 0)
  4647. self.success.write(oprot)
  4648. oprot.writeFieldEnd()
  4649. if self.err is not None:
  4650. oprot.writeFieldBegin('err', TType.STRUCT, 1)
  4651. self.err.write(oprot)
  4652. oprot.writeFieldEnd()
  4653. oprot.writeFieldStop()
  4654. oprot.writeStructEnd()
  4655. def validate(self):
  4656. return
  4657. def __repr__(self):
  4658. L = ['%s=%r' % (key, value)
  4659. for key, value in self.__dict__.iteritems()]
  4660. return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
  4661. def __eq__(self, other):
  4662. return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
  4663. def __ne__(self, other):
  4664. return not (self == other)