googledataflow.pp 199 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569457045714572457345744575457645774578457945804581458245834584458545864587458845894590459145924593459445954596459745984599460046014602460346044605460646074608460946104611461246134614461546164617461846194620462146224623462446254626462746284629463046314632463346344635463646374638463946404641464246434644464546464647464846494650465146524653465446554656465746584659466046614662466346644665466646674668466946704671467246734674467546764677467846794680468146824683468446854686468746884689469046914692469346944695469646974698469947004701470247034704470547064707470847094710471147124713471447154716471747184719472047214722472347244725472647274728472947304731473247334734473547364737473847394740474147424743474447454746474747484749475047514752475347544755475647574758475947604761476247634764476547664767476847694770477147724773477447754776477747784779478047814782478347844785478647874788478947904791479247934794479547964797479847994800480148024803480448054806480748084809481048114812481348144815481648174818481948204821482248234824482548264827482848294830483148324833483448354836483748384839484048414842484348444845484648474848484948504851485248534854485548564857485848594860486148624863486448654866486748684869487048714872487348744875487648774878487948804881488248834884488548864887488848894890489148924893489448954896489748984899490049014902490349044905490649074908490949104911491249134914491549164917491849194920492149224923492449254926492749284929493049314932493349344935493649374938493949404941494249434944494549464947494849494950495149524953495449554956495749584959496049614962496349644965496649674968496949704971497249734974497549764977497849794980498149824983498449854986498749884989499049914992499349944995499649974998499950005001500250035004500550065007500850095010501150125013501450155016501750185019502050215022502350245025502650275028502950305031503250335034503550365037503850395040504150425043504450455046504750485049505050515052505350545055505650575058505950605061506250635064506550665067506850695070507150725073507450755076507750785079508050815082508350845085508650875088508950905091509250935094509550965097509850995100510151025103510451055106510751085109511051115112511351145115511651175118511951205121512251235124512551265127512851295130513151325133513451355136513751385139514051415142514351445145514651475148514951505151515251535154515551565157515851595160516151625163516451655166516751685169517051715172517351745175517651775178517951805181518251835184518551865187518851895190519151925193519451955196519751985199520052015202520352045205520652075208520952105211521252135214521552165217521852195220522152225223522452255226522752285229523052315232523352345235523652375238523952405241524252435244524552465247524852495250525152525253525452555256525752585259526052615262526352645265526652675268526952705271527252735274527552765277527852795280528152825283528452855286528752885289529052915292529352945295529652975298529953005301530253035304530553065307530853095310531153125313531453155316531753185319532053215322532353245325532653275328532953305331533253335334533553365337533853395340534153425343534453455346534753485349535053515352535353545355535653575358535953605361536253635364536553665367536853695370537153725373537453755376537753785379538053815382538353845385538653875388538953905391539253935394539553965397539853995400540154025403540454055406540754085409541054115412541354145415541654175418541954205421542254235424542554265427542854295430543154325433543454355436543754385439544054415442544354445445544654475448544954505451545254535454545554565457545854595460546154625463546454655466546754685469547054715472547354745475547654775478547954805481548254835484548554865487548854895490549154925493549454955496549754985499550055015502550355045505550655075508550955105511551255135514551555165517551855195520552155225523552455255526552755285529553055315532553355345535553655375538553955405541554255435544554555465547554855495550555155525553555455555556555755585559556055615562556355645565556655675568556955705571557255735574557555765577557855795580558155825583558455855586558755885589559055915592559355945595559655975598559956005601560256035604560556065607560856095610561156125613561456155616561756185619562056215622562356245625562656275628562956305631563256335634563556365637563856395640564156425643564456455646564756485649565056515652565356545655565656575658565956605661566256635664566556665667566856695670567156725673567456755676567756785679568056815682568356845685568656875688568956905691569256935694569556965697569856995700570157025703570457055706570757085709571057115712571357145715571657175718571957205721572257235724572557265727572857295730573157325733573457355736573757385739574057415742574357445745574657475748574957505751575257535754575557565757575857595760576157625763576457655766576757685769577057715772577357745775577657775778577957805781578257835784578557865787578857895790579157925793579457955796579757985799580058015802580358045805580658075808580958105811581258135814581558165817581858195820582158225823582458255826582758285829583058315832583358345835583658375838583958405841584258435844584558465847584858495850585158525853585458555856585758585859586058615862586358645865586658675868586958705871587258735874587558765877587858795880588158825883588458855886588758885889589058915892589358945895589658975898589959005901590259035904590559065907590859095910591159125913591459155916591759185919592059215922592359245925592659275928592959305931593259335934593559365937593859395940594159425943594459455946594759485949595059515952595359545955595659575958595959605961596259635964596559665967596859695970597159725973597459755976597759785979598059815982598359845985598659875988598959905991599259935994599559965997599859996000600160026003600460056006600760086009601060116012601360146015601660176018601960206021602260236024602560266027602860296030603160326033603460356036603760386039604060416042604360446045604660476048604960506051605260536054605560566057605860596060606160626063606460656066606760686069607060716072607360746075607660776078607960806081608260836084608560866087608860896090609160926093609460956096609760986099610061016102610361046105610661076108610961106111611261136114611561166117611861196120612161226123612461256126612761286129613061316132613361346135613661376138613961406141614261436144614561466147614861496150615161526153615461556156615761586159616061616162616361646165616661676168616961706171617261736174617561766177617861796180618161826183618461856186618761886189619061916192619361946195619661976198619962006201620262036204620562066207620862096210621162126213621462156216621762186219622062216222622362246225622662276228622962306231623262336234623562366237623862396240624162426243624462456246624762486249625062516252625362546255625662576258625962606261626262636264626562666267626862696270627162726273627462756276627762786279628062816282628362846285628662876288628962906291629262936294629562966297629862996300630163026303630463056306630763086309631063116312631363146315631663176318631963206321632263236324632563266327632863296330633163326333633463356336633763386339634063416342634363446345634663476348634963506351635263536354635563566357635863596360636163626363636463656366636763686369637063716372637363746375637663776378637963806381638263836384638563866387638863896390639163926393639463956396639763986399640064016402640364046405640664076408640964106411641264136414641564166417641864196420642164226423642464256426642764286429643064316432643364346435643664376438643964406441644264436444644564466447644864496450645164526453645464556456645764586459646064616462646364646465646664676468646964706471647264736474647564766477647864796480648164826483648464856486648764886489649064916492649364946495649664976498649965006501650265036504650565066507650865096510651165126513651465156516651765186519652065216522652365246525652665276528652965306531653265336534653565366537653865396540654165426543654465456546654765486549655065516552655365546555655665576558655965606561656265636564656565666567656865696570657165726573657465756576657765786579658065816582658365846585658665876588658965906591659265936594659565966597659865996600660166026603660466056606660766086609661066116612661366146615661666176618661966206621662266236624662566266627662866296630663166326633663466356636663766386639664066416642664366446645664666476648664966506651665266536654665566566657665866596660666166626663666466656666666766686669667066716672667366746675667666776678667966806681668266836684668566866687668866896690669166926693669466956696669766986699670067016702670367046705670667076708670967106711671267136714671567166717671867196720672167226723672467256726672767286729673067316732673367346735673667376738673967406741674267436744674567466747674867496750675167526753675467556756675767586759676067616762676367646765676667676768676967706771677267736774677567766777677867796780678167826783678467856786678767886789679067916792679367946795679667976798679968006801680268036804680568066807680868096810681168126813681468156816681768186819682068216822682368246825682668276828682968306831683268336834683568366837683868396840684168426843684468456846684768486849685068516852685368546855685668576858685968606861686268636864686568666867686868696870687168726873687468756876687768786879688068816882688368846885688668876888688968906891689268936894689568966897689868996900690169026903690469056906690769086909691069116912691369146915691669176918
  1. unit googledataflow;
  2. {
  3. **********************************************************************
  4. This file is part of the Free Component Library (FCL)
  5. Copyright (c) 2015 The free pascal team.
  6. See the file COPYING.FPC, included in this distribution,
  7. for details about the copyright.
  8. This program is distributed in the hope that it will be useful,
  9. but WITHOUT ANY WARRANTY; without even the implied warranty of
  10. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  11. **********************************************************************
  12. }
  13. //Generated on: 16-5-15 08:53:01
  14. {$MODE objfpc}
  15. {$H+}
  16. interface
  17. uses sysutils, classes, googleservice, restbase, googlebase;
  18. type
  19. //Top-level schema types
  20. TGoogleprotobufValue = TJSONSchema;
  21. TApproximateProgress = Class;
  22. TAutoscalingSettings = Class;
  23. TComputationTopology = Class;
  24. TDataDiskAssignment = Class;
  25. TDerivedSource = Class;
  26. TDisk = Class;
  27. TDynamicSourceSplit = Class;
  28. TEnvironment = Class;
  29. TFlattenInstruction = Class;
  30. TInstructionInput = Class;
  31. TInstructionOutput = Class;
  32. TJob = Class;
  33. TJobExecutionInfo = Class;
  34. TJobExecutionStageInfo = Class;
  35. TJobMessage = Class;
  36. TJobMetrics = Class;
  37. TKeyRangeDataDiskAssignment = Class;
  38. TKeyRangeLocation = Class;
  39. TLeaseWorkItemRequest = Class;
  40. TLeaseWorkItemResponse = Class;
  41. TListJobMessagesResponse = Class;
  42. TListJobsResponse = Class;
  43. TMapTask = Class;
  44. TMetricStructuredName = Class;
  45. TMetricUpdate = Class;
  46. TMountedDataDisk = Class;
  47. TMultiOutputInfo = Class;
  48. TPackage = Class;
  49. TParDoInstruction = Class;
  50. TParallelInstruction = Class;
  51. TPartialGroupByKeyInstruction = Class;
  52. TPosition = Class;
  53. TPubsubLocation = Class;
  54. TReadInstruction = Class;
  55. TReportWorkItemStatusRequest = Class;
  56. TReportWorkItemStatusResponse = Class;
  57. TSeqMapTask = Class;
  58. TSeqMapTaskOutputInfo = Class;
  59. TShellTask = Class;
  60. TSideInputInfo = Class;
  61. TSink = Class;
  62. TSource = Class;
  63. TSourceFork = Class;
  64. TSourceGetMetadataRequest = Class;
  65. TSourceGetMetadataResponse = Class;
  66. TSourceMetadata = Class;
  67. TSourceOperationRequest = Class;
  68. TSourceOperationResponse = Class;
  69. TSourceSplitOptions = Class;
  70. TSourceSplitRequest = Class;
  71. TSourceSplitResponse = Class;
  72. TSourceSplitShard = Class;
  73. TStatus = Class;
  74. TStep = Class;
  75. TStreamLocation = Class;
  76. TStreamingComputationRanges = Class;
  77. TStreamingComputationTask = Class;
  78. TStreamingSetupTask = Class;
  79. TStreamingSideInputLocation = Class;
  80. TStreamingStageLocation = Class;
  81. TTaskRunnerSettings = Class;
  82. TTopologyConfig = Class;
  83. TWorkItem = Class;
  84. TWorkItemServiceState = Class;
  85. TWorkItemStatus = Class;
  86. TWorkerPool = Class;
  87. TWorkerSettings = Class;
  88. TWriteInstruction = Class;
  89. TApproximateProgressArray = Array of TApproximateProgress;
  90. TAutoscalingSettingsArray = Array of TAutoscalingSettings;
  91. TComputationTopologyArray = Array of TComputationTopology;
  92. TDataDiskAssignmentArray = Array of TDataDiskAssignment;
  93. TDerivedSourceArray = Array of TDerivedSource;
  94. TDiskArray = Array of TDisk;
  95. TDynamicSourceSplitArray = Array of TDynamicSourceSplit;
  96. TEnvironmentArray = Array of TEnvironment;
  97. TFlattenInstructionArray = Array of TFlattenInstruction;
  98. TInstructionInputArray = Array of TInstructionInput;
  99. TInstructionOutputArray = Array of TInstructionOutput;
  100. TJobArray = Array of TJob;
  101. TJobExecutionInfoArray = Array of TJobExecutionInfo;
  102. TJobExecutionStageInfoArray = Array of TJobExecutionStageInfo;
  103. TJobMessageArray = Array of TJobMessage;
  104. TJobMetricsArray = Array of TJobMetrics;
  105. TKeyRangeDataDiskAssignmentArray = Array of TKeyRangeDataDiskAssignment;
  106. TKeyRangeLocationArray = Array of TKeyRangeLocation;
  107. TLeaseWorkItemRequestArray = Array of TLeaseWorkItemRequest;
  108. TLeaseWorkItemResponseArray = Array of TLeaseWorkItemResponse;
  109. TListJobMessagesResponseArray = Array of TListJobMessagesResponse;
  110. TListJobsResponseArray = Array of TListJobsResponse;
  111. TMapTaskArray = Array of TMapTask;
  112. TMetricStructuredNameArray = Array of TMetricStructuredName;
  113. TMetricUpdateArray = Array of TMetricUpdate;
  114. TMountedDataDiskArray = Array of TMountedDataDisk;
  115. TMultiOutputInfoArray = Array of TMultiOutputInfo;
  116. TPackageArray = Array of TPackage;
  117. TParDoInstructionArray = Array of TParDoInstruction;
  118. TParallelInstructionArray = Array of TParallelInstruction;
  119. TPartialGroupByKeyInstructionArray = Array of TPartialGroupByKeyInstruction;
  120. TPositionArray = Array of TPosition;
  121. TPubsubLocationArray = Array of TPubsubLocation;
  122. TReadInstructionArray = Array of TReadInstruction;
  123. TReportWorkItemStatusRequestArray = Array of TReportWorkItemStatusRequest;
  124. TReportWorkItemStatusResponseArray = Array of TReportWorkItemStatusResponse;
  125. TSeqMapTaskArray = Array of TSeqMapTask;
  126. TSeqMapTaskOutputInfoArray = Array of TSeqMapTaskOutputInfo;
  127. TShellTaskArray = Array of TShellTask;
  128. TSideInputInfoArray = Array of TSideInputInfo;
  129. TSinkArray = Array of TSink;
  130. TSourceArray = Array of TSource;
  131. TSourceForkArray = Array of TSourceFork;
  132. TSourceGetMetadataRequestArray = Array of TSourceGetMetadataRequest;
  133. TSourceGetMetadataResponseArray = Array of TSourceGetMetadataResponse;
  134. TSourceMetadataArray = Array of TSourceMetadata;
  135. TSourceOperationRequestArray = Array of TSourceOperationRequest;
  136. TSourceOperationResponseArray = Array of TSourceOperationResponse;
  137. TSourceSplitOptionsArray = Array of TSourceSplitOptions;
  138. TSourceSplitRequestArray = Array of TSourceSplitRequest;
  139. TSourceSplitResponseArray = Array of TSourceSplitResponse;
  140. TSourceSplitShardArray = Array of TSourceSplitShard;
  141. TStatusArray = Array of TStatus;
  142. TStepArray = Array of TStep;
  143. TStreamLocationArray = Array of TStreamLocation;
  144. TStreamingComputationRangesArray = Array of TStreamingComputationRanges;
  145. TStreamingComputationTaskArray = Array of TStreamingComputationTask;
  146. TStreamingSetupTaskArray = Array of TStreamingSetupTask;
  147. TStreamingSideInputLocationArray = Array of TStreamingSideInputLocation;
  148. TStreamingStageLocationArray = Array of TStreamingStageLocation;
  149. TTaskRunnerSettingsArray = Array of TTaskRunnerSettings;
  150. TTopologyConfigArray = Array of TTopologyConfig;
  151. TWorkItemArray = Array of TWorkItem;
  152. TWorkItemServiceStateArray = Array of TWorkItemServiceState;
  153. TWorkItemStatusArray = Array of TWorkItemStatus;
  154. TWorkerPoolArray = Array of TWorkerPool;
  155. TWorkerSettingsArray = Array of TWorkerSettings;
  156. TWriteInstructionArray = Array of TWriteInstruction;
  157. //Anonymous types, using auto-generated names
  158. TEnvironmentTypesdkPipelineOptions = Class;
  159. TEnvironmentTypeuserAgent = Class;
  160. TEnvironmentTypeversion = Class;
  161. TInstructionOutputTypecodec = Class;
  162. TJobExecutionInfoTypestages = Class;
  163. TMetricStructuredNameTypecontext = Class;
  164. TParDoInstructionTypeuserFn = Class;
  165. TPartialGroupByKeyInstructionTypeinputElementCodec = Class;
  166. TPartialGroupByKeyInstructionTypevalueCombiningFn = Class;
  167. TSeqMapTaskTypeuserFn = Class;
  168. TSideInputInfoTypekind = Class;
  169. TSinkTypecodec = Class;
  170. TSinkTypespec = Class;
  171. TSourceTypebaseSpecsItem = Class;
  172. TSourceTypecodec = Class;
  173. TSourceTypespec = Class;
  174. TStatusTypedetailsItem = Class;
  175. TStepTypeproperties = Class;
  176. TWorkItemServiceStateTypeharnessData = Class;
  177. TWorkerPoolTypemetadata = Class;
  178. TWorkerPoolTypepoolArgs = Class;
  179. TComputationTopologyTypeinputsArray = Array of TStreamLocation;
  180. TComputationTopologyTypekeyRangesArray = Array of TKeyRangeLocation;
  181. TComputationTopologyTypeoutputsArray = Array of TStreamLocation;
  182. TEnvironmentTypeworkerPoolsArray = Array of TWorkerPool;
  183. TFlattenInstructionTypeinputsArray = Array of TInstructionInput;
  184. TJobTypestepsArray = Array of TStep;
  185. TJobMetricsTypemetricsArray = Array of TMetricUpdate;
  186. TLeaseWorkItemResponseTypeworkItemsArray = Array of TWorkItem;
  187. TListJobMessagesResponseTypejobMessagesArray = Array of TJobMessage;
  188. TListJobsResponseTypejobsArray = Array of TJob;
  189. TMapTaskTypeinstructionsArray = Array of TParallelInstruction;
  190. TParDoInstructionTypemultiOutputInfosArray = Array of TMultiOutputInfo;
  191. TParDoInstructionTypesideInputsArray = Array of TSideInputInfo;
  192. TParallelInstructionTypeoutputsArray = Array of TInstructionOutput;
  193. TReportWorkItemStatusRequestTypeworkItemStatusesArray = Array of TWorkItemStatus;
  194. TReportWorkItemStatusResponseTypeworkItemServiceStatesArray = Array of TWorkItemServiceState;
  195. TSeqMapTaskTypeinputsArray = Array of TSideInputInfo;
  196. TSeqMapTaskTypeoutputInfosArray = Array of TSeqMapTaskOutputInfo;
  197. TSideInputInfoTypesourcesArray = Array of TSource;
  198. TSourceTypebaseSpecsArray = Array of TSourceTypebaseSpecsItem;
  199. TSourceSplitResponseTypebundlesArray = Array of TDerivedSource;
  200. TSourceSplitResponseTypeshardsArray = Array of TSourceSplitShard;
  201. TStatusTypedetailsArray = Array of TStatusTypedetailsItem;
  202. TStreamingComputationRangesTyperangeAssignmentsArray = Array of TKeyRangeDataDiskAssignment;
  203. TStreamingComputationTaskTypecomputationRangesArray = Array of TStreamingComputationRanges;
  204. TStreamingComputationTaskTypedataDisksArray = Array of TMountedDataDisk;
  205. TTopologyConfigTypecomputationsArray = Array of TComputationTopology;
  206. TTopologyConfigTypedataDiskAssignmentsArray = Array of TDataDiskAssignment;
  207. TWorkItemTypepackagesArray = Array of TPackage;
  208. TWorkItemStatusTypeerrorsArray = Array of TStatus;
  209. TWorkItemStatusTypemetricUpdatesArray = Array of TMetricUpdate;
  210. TWorkerPoolTypedataDisksArray = Array of TDisk;
  211. TWorkerPoolTypepackagesArray = Array of TPackage;
  212. { --------------------------------------------------------------------
  213. TApproximateProgress
  214. --------------------------------------------------------------------}
  215. TApproximateProgress = Class(TGoogleBaseObject)
  216. Private
  217. FpercentComplete : integer;
  218. Fposition : TPosition;
  219. FremainingTime : String;
  220. Protected
  221. //Property setters
  222. Procedure SetpercentComplete(AIndex : Integer; AValue : integer); virtual;
  223. Procedure Setposition(AIndex : Integer; AValue : TPosition); virtual;
  224. Procedure SetremainingTime(AIndex : Integer; const AValue : String); virtual;
  225. Public
  226. Published
  227. Property percentComplete : integer Index 0 Read FpercentComplete Write SetpercentComplete;
  228. Property position : TPosition Index 8 Read Fposition Write Setposition;
  229. Property remainingTime : String Index 16 Read FremainingTime Write SetremainingTime;
  230. end;
  231. TApproximateProgressClass = Class of TApproximateProgress;
  232. { --------------------------------------------------------------------
  233. TAutoscalingSettings
  234. --------------------------------------------------------------------}
  235. TAutoscalingSettings = Class(TGoogleBaseObject)
  236. Private
  237. Falgorithm : String;
  238. FmaxNumWorkers : integer;
  239. Protected
  240. //Property setters
  241. Procedure Setalgorithm(AIndex : Integer; const AValue : String); virtual;
  242. Procedure SetmaxNumWorkers(AIndex : Integer; AValue : integer); virtual;
  243. Public
  244. Published
  245. Property algorithm : String Index 0 Read Falgorithm Write Setalgorithm;
  246. Property maxNumWorkers : integer Index 8 Read FmaxNumWorkers Write SetmaxNumWorkers;
  247. end;
  248. TAutoscalingSettingsClass = Class of TAutoscalingSettings;
  249. { --------------------------------------------------------------------
  250. TComputationTopology
  251. --------------------------------------------------------------------}
  252. TComputationTopology = Class(TGoogleBaseObject)
  253. Private
  254. FcomputationId : String;
  255. Finputs : TComputationTopologyTypeinputsArray;
  256. FkeyRanges : TComputationTopologyTypekeyRangesArray;
  257. Foutputs : TComputationTopologyTypeoutputsArray;
  258. Protected
  259. //Property setters
  260. Procedure SetcomputationId(AIndex : Integer; const AValue : String); virtual;
  261. Procedure Setinputs(AIndex : Integer; AValue : TComputationTopologyTypeinputsArray); virtual;
  262. Procedure SetkeyRanges(AIndex : Integer; AValue : TComputationTopologyTypekeyRangesArray); virtual;
  263. Procedure Setoutputs(AIndex : Integer; AValue : TComputationTopologyTypeoutputsArray); virtual;
  264. //2.6.4. bug workaround
  265. {$IFDEF VER2_6}
  266. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  267. {$ENDIF VER2_6}
  268. Public
  269. Published
  270. Property computationId : String Index 0 Read FcomputationId Write SetcomputationId;
  271. Property inputs : TComputationTopologyTypeinputsArray Index 8 Read Finputs Write Setinputs;
  272. Property keyRanges : TComputationTopologyTypekeyRangesArray Index 16 Read FkeyRanges Write SetkeyRanges;
  273. Property outputs : TComputationTopologyTypeoutputsArray Index 24 Read Foutputs Write Setoutputs;
  274. end;
  275. TComputationTopologyClass = Class of TComputationTopology;
  276. { --------------------------------------------------------------------
  277. TDataDiskAssignment
  278. --------------------------------------------------------------------}
  279. TDataDiskAssignment = Class(TGoogleBaseObject)
  280. Private
  281. FdataDisks : TStringArray;
  282. FvmInstance : String;
  283. Protected
  284. //Property setters
  285. Procedure SetdataDisks(AIndex : Integer; AValue : TStringArray); virtual;
  286. Procedure SetvmInstance(AIndex : Integer; const AValue : String); virtual;
  287. //2.6.4. bug workaround
  288. {$IFDEF VER2_6}
  289. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  290. {$ENDIF VER2_6}
  291. Public
  292. Published
  293. Property dataDisks : TStringArray Index 0 Read FdataDisks Write SetdataDisks;
  294. Property vmInstance : String Index 8 Read FvmInstance Write SetvmInstance;
  295. end;
  296. TDataDiskAssignmentClass = Class of TDataDiskAssignment;
  297. { --------------------------------------------------------------------
  298. TDerivedSource
  299. --------------------------------------------------------------------}
  300. TDerivedSource = Class(TGoogleBaseObject)
  301. Private
  302. FderivationMode : String;
  303. Fsource : TSource;
  304. Protected
  305. //Property setters
  306. Procedure SetderivationMode(AIndex : Integer; const AValue : String); virtual;
  307. Procedure Setsource(AIndex : Integer; AValue : TSource); virtual;
  308. Public
  309. Published
  310. Property derivationMode : String Index 0 Read FderivationMode Write SetderivationMode;
  311. Property source : TSource Index 8 Read Fsource Write Setsource;
  312. end;
  313. TDerivedSourceClass = Class of TDerivedSource;
  314. { --------------------------------------------------------------------
  315. TDisk
  316. --------------------------------------------------------------------}
  317. TDisk = Class(TGoogleBaseObject)
  318. Private
  319. FdiskType : String;
  320. FmountPoint : String;
  321. FsizeGb : integer;
  322. Protected
  323. //Property setters
  324. Procedure SetdiskType(AIndex : Integer; const AValue : String); virtual;
  325. Procedure SetmountPoint(AIndex : Integer; const AValue : String); virtual;
  326. Procedure SetsizeGb(AIndex : Integer; AValue : integer); virtual;
  327. Public
  328. Published
  329. Property diskType : String Index 0 Read FdiskType Write SetdiskType;
  330. Property mountPoint : String Index 8 Read FmountPoint Write SetmountPoint;
  331. Property sizeGb : integer Index 16 Read FsizeGb Write SetsizeGb;
  332. end;
  333. TDiskClass = Class of TDisk;
  334. { --------------------------------------------------------------------
  335. TDynamicSourceSplit
  336. --------------------------------------------------------------------}
  337. TDynamicSourceSplit = Class(TGoogleBaseObject)
  338. Private
  339. Fprimary : TDerivedSource;
  340. Fresidual : TDerivedSource;
  341. Protected
  342. //Property setters
  343. Procedure Setprimary(AIndex : Integer; AValue : TDerivedSource); virtual;
  344. Procedure Setresidual(AIndex : Integer; AValue : TDerivedSource); virtual;
  345. Public
  346. Published
  347. Property primary : TDerivedSource Index 0 Read Fprimary Write Setprimary;
  348. Property residual : TDerivedSource Index 8 Read Fresidual Write Setresidual;
  349. end;
  350. TDynamicSourceSplitClass = Class of TDynamicSourceSplit;
  351. { --------------------------------------------------------------------
  352. TEnvironmentTypesdkPipelineOptions
  353. --------------------------------------------------------------------}
  354. TEnvironmentTypesdkPipelineOptions = Class(TGoogleBaseObject)
  355. Private
  356. Protected
  357. //Property setters
  358. Public
  359. Class Function AllowAdditionalProperties : Boolean; override;
  360. Published
  361. end;
  362. TEnvironmentTypesdkPipelineOptionsClass = Class of TEnvironmentTypesdkPipelineOptions;
  363. { --------------------------------------------------------------------
  364. TEnvironmentTypeuserAgent
  365. --------------------------------------------------------------------}
  366. TEnvironmentTypeuserAgent = Class(TGoogleBaseObject)
  367. Private
  368. Protected
  369. //Property setters
  370. Public
  371. Class Function AllowAdditionalProperties : Boolean; override;
  372. Published
  373. end;
  374. TEnvironmentTypeuserAgentClass = Class of TEnvironmentTypeuserAgent;
  375. { --------------------------------------------------------------------
  376. TEnvironmentTypeversion
  377. --------------------------------------------------------------------}
  378. TEnvironmentTypeversion = Class(TGoogleBaseObject)
  379. Private
  380. Protected
  381. //Property setters
  382. Public
  383. Class Function AllowAdditionalProperties : Boolean; override;
  384. Published
  385. end;
  386. TEnvironmentTypeversionClass = Class of TEnvironmentTypeversion;
  387. { --------------------------------------------------------------------
  388. TEnvironment
  389. --------------------------------------------------------------------}
  390. TEnvironment = Class(TGoogleBaseObject)
  391. Private
  392. FclusterManagerApiService : String;
  393. Fdataset : String;
  394. Fexperiments : TStringArray;
  395. FsdkPipelineOptions : TEnvironmentTypesdkPipelineOptions;
  396. FtempStoragePrefix : String;
  397. FuserAgent : TEnvironmentTypeuserAgent;
  398. Fversion : TEnvironmentTypeversion;
  399. FworkerPools : TEnvironmentTypeworkerPoolsArray;
  400. Protected
  401. //Property setters
  402. Procedure SetclusterManagerApiService(AIndex : Integer; const AValue : String); virtual;
  403. Procedure Setdataset(AIndex : Integer; const AValue : String); virtual;
  404. Procedure Setexperiments(AIndex : Integer; AValue : TStringArray); virtual;
  405. Procedure SetsdkPipelineOptions(AIndex : Integer; AValue : TEnvironmentTypesdkPipelineOptions); virtual;
  406. Procedure SettempStoragePrefix(AIndex : Integer; const AValue : String); virtual;
  407. Procedure SetuserAgent(AIndex : Integer; AValue : TEnvironmentTypeuserAgent); virtual;
  408. Procedure Setversion(AIndex : Integer; AValue : TEnvironmentTypeversion); virtual;
  409. Procedure SetworkerPools(AIndex : Integer; AValue : TEnvironmentTypeworkerPoolsArray); virtual;
  410. //2.6.4. bug workaround
  411. {$IFDEF VER2_6}
  412. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  413. {$ENDIF VER2_6}
  414. Public
  415. Published
  416. Property clusterManagerApiService : String Index 0 Read FclusterManagerApiService Write SetclusterManagerApiService;
  417. Property dataset : String Index 8 Read Fdataset Write Setdataset;
  418. Property experiments : TStringArray Index 16 Read Fexperiments Write Setexperiments;
  419. Property sdkPipelineOptions : TEnvironmentTypesdkPipelineOptions Index 24 Read FsdkPipelineOptions Write SetsdkPipelineOptions;
  420. Property tempStoragePrefix : String Index 32 Read FtempStoragePrefix Write SettempStoragePrefix;
  421. Property userAgent : TEnvironmentTypeuserAgent Index 40 Read FuserAgent Write SetuserAgent;
  422. Property version : TEnvironmentTypeversion Index 48 Read Fversion Write Setversion;
  423. Property workerPools : TEnvironmentTypeworkerPoolsArray Index 56 Read FworkerPools Write SetworkerPools;
  424. end;
  425. TEnvironmentClass = Class of TEnvironment;
  426. { --------------------------------------------------------------------
  427. TFlattenInstruction
  428. --------------------------------------------------------------------}
  429. TFlattenInstruction = Class(TGoogleBaseObject)
  430. Private
  431. Finputs : TFlattenInstructionTypeinputsArray;
  432. Protected
  433. //Property setters
  434. Procedure Setinputs(AIndex : Integer; AValue : TFlattenInstructionTypeinputsArray); virtual;
  435. //2.6.4. bug workaround
  436. {$IFDEF VER2_6}
  437. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  438. {$ENDIF VER2_6}
  439. Public
  440. Published
  441. Property inputs : TFlattenInstructionTypeinputsArray Index 0 Read Finputs Write Setinputs;
  442. end;
  443. TFlattenInstructionClass = Class of TFlattenInstruction;
  444. { --------------------------------------------------------------------
  445. TInstructionInput
  446. --------------------------------------------------------------------}
  447. TInstructionInput = Class(TGoogleBaseObject)
  448. Private
  449. FoutputNum : integer;
  450. FproducerInstructionIndex : integer;
  451. Protected
  452. //Property setters
  453. Procedure SetoutputNum(AIndex : Integer; AValue : integer); virtual;
  454. Procedure SetproducerInstructionIndex(AIndex : Integer; AValue : integer); virtual;
  455. Public
  456. Published
  457. Property outputNum : integer Index 0 Read FoutputNum Write SetoutputNum;
  458. Property producerInstructionIndex : integer Index 8 Read FproducerInstructionIndex Write SetproducerInstructionIndex;
  459. end;
  460. TInstructionInputClass = Class of TInstructionInput;
  461. { --------------------------------------------------------------------
  462. TInstructionOutputTypecodec
  463. --------------------------------------------------------------------}
  464. TInstructionOutputTypecodec = Class(TGoogleBaseObject)
  465. Private
  466. Protected
  467. //Property setters
  468. Public
  469. Class Function AllowAdditionalProperties : Boolean; override;
  470. Published
  471. end;
  472. TInstructionOutputTypecodecClass = Class of TInstructionOutputTypecodec;
  473. { --------------------------------------------------------------------
  474. TInstructionOutput
  475. --------------------------------------------------------------------}
  476. TInstructionOutput = Class(TGoogleBaseObject)
  477. Private
  478. Fcodec : TInstructionOutputTypecodec;
  479. Fname : String;
  480. Protected
  481. //Property setters
  482. Procedure Setcodec(AIndex : Integer; AValue : TInstructionOutputTypecodec); virtual;
  483. Procedure Setname(AIndex : Integer; const AValue : String); virtual;
  484. Public
  485. Published
  486. Property codec : TInstructionOutputTypecodec Index 0 Read Fcodec Write Setcodec;
  487. Property name : String Index 8 Read Fname Write Setname;
  488. end;
  489. TInstructionOutputClass = Class of TInstructionOutput;
  490. { --------------------------------------------------------------------
  491. TJob
  492. --------------------------------------------------------------------}
  493. TJob = Class(TGoogleBaseObject)
  494. Private
  495. FcreateTime : String;
  496. FcurrentState : String;
  497. FcurrentStateTime : String;
  498. Fenvironment : TEnvironment;
  499. FexecutionInfo : TJobExecutionInfo;
  500. Fid : String;
  501. Fname : String;
  502. FprojectId : String;
  503. FrequestedState : String;
  504. Fsteps : TJobTypestepsArray;
  505. F_type : String;
  506. Protected
  507. Class Function ExportPropertyName(Const AName : String) : string; override;
  508. //Property setters
  509. Procedure SetcreateTime(AIndex : Integer; const AValue : String); virtual;
  510. Procedure SetcurrentState(AIndex : Integer; const AValue : String); virtual;
  511. Procedure SetcurrentStateTime(AIndex : Integer; const AValue : String); virtual;
  512. Procedure Setenvironment(AIndex : Integer; AValue : TEnvironment); virtual;
  513. Procedure SetexecutionInfo(AIndex : Integer; AValue : TJobExecutionInfo); virtual;
  514. Procedure Setid(AIndex : Integer; const AValue : String); virtual;
  515. Procedure Setname(AIndex : Integer; const AValue : String); virtual;
  516. Procedure SetprojectId(AIndex : Integer; const AValue : String); virtual;
  517. Procedure SetrequestedState(AIndex : Integer; const AValue : String); virtual;
  518. Procedure Setsteps(AIndex : Integer; AValue : TJobTypestepsArray); virtual;
  519. Procedure Set_type(AIndex : Integer; const AValue : String); virtual;
  520. //2.6.4. bug workaround
  521. {$IFDEF VER2_6}
  522. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  523. {$ENDIF VER2_6}
  524. Public
  525. Published
  526. Property createTime : String Index 0 Read FcreateTime Write SetcreateTime;
  527. Property currentState : String Index 8 Read FcurrentState Write SetcurrentState;
  528. Property currentStateTime : String Index 16 Read FcurrentStateTime Write SetcurrentStateTime;
  529. Property environment : TEnvironment Index 24 Read Fenvironment Write Setenvironment;
  530. Property executionInfo : TJobExecutionInfo Index 32 Read FexecutionInfo Write SetexecutionInfo;
  531. Property id : String Index 40 Read Fid Write Setid;
  532. Property name : String Index 48 Read Fname Write Setname;
  533. Property projectId : String Index 56 Read FprojectId Write SetprojectId;
  534. Property requestedState : String Index 64 Read FrequestedState Write SetrequestedState;
  535. Property steps : TJobTypestepsArray Index 72 Read Fsteps Write Setsteps;
  536. Property _type : String Index 80 Read F_type Write Set_type;
  537. end;
  538. TJobClass = Class of TJob;
  539. { --------------------------------------------------------------------
  540. TJobExecutionInfoTypestages
  541. --------------------------------------------------------------------}
  542. TJobExecutionInfoTypestages = Class(TGoogleBaseObject)
  543. Private
  544. Protected
  545. //Property setters
  546. Public
  547. Class Function AllowAdditionalProperties : Boolean; override;
  548. Published
  549. end;
  550. TJobExecutionInfoTypestagesClass = Class of TJobExecutionInfoTypestages;
  551. { --------------------------------------------------------------------
  552. TJobExecutionInfo
  553. --------------------------------------------------------------------}
  554. TJobExecutionInfo = Class(TGoogleBaseObject)
  555. Private
  556. Fstages : TJobExecutionInfoTypestages;
  557. Protected
  558. //Property setters
  559. Procedure Setstages(AIndex : Integer; AValue : TJobExecutionInfoTypestages); virtual;
  560. Public
  561. Published
  562. Property stages : TJobExecutionInfoTypestages Index 0 Read Fstages Write Setstages;
  563. end;
  564. TJobExecutionInfoClass = Class of TJobExecutionInfo;
  565. { --------------------------------------------------------------------
  566. TJobExecutionStageInfo
  567. --------------------------------------------------------------------}
  568. TJobExecutionStageInfo = Class(TGoogleBaseObject)
  569. Private
  570. FstepName : TStringArray;
  571. Protected
  572. //Property setters
  573. Procedure SetstepName(AIndex : Integer; AValue : TStringArray); virtual;
  574. //2.6.4. bug workaround
  575. {$IFDEF VER2_6}
  576. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  577. {$ENDIF VER2_6}
  578. Public
  579. Published
  580. Property stepName : TStringArray Index 0 Read FstepName Write SetstepName;
  581. end;
  582. TJobExecutionStageInfoClass = Class of TJobExecutionStageInfo;
  583. { --------------------------------------------------------------------
  584. TJobMessage
  585. --------------------------------------------------------------------}
  586. TJobMessage = Class(TGoogleBaseObject)
  587. Private
  588. Fid : String;
  589. FmessageImportance : String;
  590. FmessageText : String;
  591. Ftime : String;
  592. Protected
  593. //Property setters
  594. Procedure Setid(AIndex : Integer; const AValue : String); virtual;
  595. Procedure SetmessageImportance(AIndex : Integer; const AValue : String); virtual;
  596. Procedure SetmessageText(AIndex : Integer; const AValue : String); virtual;
  597. Procedure Settime(AIndex : Integer; const AValue : String); virtual;
  598. Public
  599. Published
  600. Property id : String Index 0 Read Fid Write Setid;
  601. Property messageImportance : String Index 8 Read FmessageImportance Write SetmessageImportance;
  602. Property messageText : String Index 16 Read FmessageText Write SetmessageText;
  603. Property time : String Index 24 Read Ftime Write Settime;
  604. end;
  605. TJobMessageClass = Class of TJobMessage;
  606. { --------------------------------------------------------------------
  607. TJobMetrics
  608. --------------------------------------------------------------------}
  609. TJobMetrics = Class(TGoogleBaseObject)
  610. Private
  611. FmetricTime : String;
  612. Fmetrics : TJobMetricsTypemetricsArray;
  613. Protected
  614. //Property setters
  615. Procedure SetmetricTime(AIndex : Integer; const AValue : String); virtual;
  616. Procedure Setmetrics(AIndex : Integer; AValue : TJobMetricsTypemetricsArray); virtual;
  617. //2.6.4. bug workaround
  618. {$IFDEF VER2_6}
  619. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  620. {$ENDIF VER2_6}
  621. Public
  622. Published
  623. Property metricTime : String Index 0 Read FmetricTime Write SetmetricTime;
  624. Property metrics : TJobMetricsTypemetricsArray Index 8 Read Fmetrics Write Setmetrics;
  625. end;
  626. TJobMetricsClass = Class of TJobMetrics;
  627. { --------------------------------------------------------------------
  628. TKeyRangeDataDiskAssignment
  629. --------------------------------------------------------------------}
  630. TKeyRangeDataDiskAssignment = Class(TGoogleBaseObject)
  631. Private
  632. FdataDisk : String;
  633. F_end : String;
  634. Fstart : String;
  635. Protected
  636. Class Function ExportPropertyName(Const AName : String) : string; override;
  637. //Property setters
  638. Procedure SetdataDisk(AIndex : Integer; const AValue : String); virtual;
  639. Procedure Set_end(AIndex : Integer; const AValue : String); virtual;
  640. Procedure Setstart(AIndex : Integer; const AValue : String); virtual;
  641. Public
  642. Published
  643. Property dataDisk : String Index 0 Read FdataDisk Write SetdataDisk;
  644. Property _end : String Index 8 Read F_end Write Set_end;
  645. Property start : String Index 16 Read Fstart Write Setstart;
  646. end;
  647. TKeyRangeDataDiskAssignmentClass = Class of TKeyRangeDataDiskAssignment;
  648. { --------------------------------------------------------------------
  649. TKeyRangeLocation
  650. --------------------------------------------------------------------}
  651. TKeyRangeLocation = Class(TGoogleBaseObject)
  652. Private
  653. FdataDisk : String;
  654. FdeliveryEndpoint : String;
  655. F_end : String;
  656. FpersistentDirectory : String;
  657. Fstart : String;
  658. Protected
  659. Class Function ExportPropertyName(Const AName : String) : string; override;
  660. //Property setters
  661. Procedure SetdataDisk(AIndex : Integer; const AValue : String); virtual;
  662. Procedure SetdeliveryEndpoint(AIndex : Integer; const AValue : String); virtual;
  663. Procedure Set_end(AIndex : Integer; const AValue : String); virtual;
  664. Procedure SetpersistentDirectory(AIndex : Integer; const AValue : String); virtual;
  665. Procedure Setstart(AIndex : Integer; const AValue : String); virtual;
  666. Public
  667. Published
  668. Property dataDisk : String Index 0 Read FdataDisk Write SetdataDisk;
  669. Property deliveryEndpoint : String Index 8 Read FdeliveryEndpoint Write SetdeliveryEndpoint;
  670. Property _end : String Index 16 Read F_end Write Set_end;
  671. Property persistentDirectory : String Index 24 Read FpersistentDirectory Write SetpersistentDirectory;
  672. Property start : String Index 32 Read Fstart Write Setstart;
  673. end;
  674. TKeyRangeLocationClass = Class of TKeyRangeLocation;
  675. { --------------------------------------------------------------------
  676. TLeaseWorkItemRequest
  677. --------------------------------------------------------------------}
  678. TLeaseWorkItemRequest = Class(TGoogleBaseObject)
  679. Private
  680. FcurrentWorkerTime : String;
  681. FrequestedLeaseDuration : String;
  682. FworkItemTypes : TStringArray;
  683. FworkerCapabilities : TStringArray;
  684. FworkerId : String;
  685. Protected
  686. //Property setters
  687. Procedure SetcurrentWorkerTime(AIndex : Integer; const AValue : String); virtual;
  688. Procedure SetrequestedLeaseDuration(AIndex : Integer; const AValue : String); virtual;
  689. Procedure SetworkItemTypes(AIndex : Integer; AValue : TStringArray); virtual;
  690. Procedure SetworkerCapabilities(AIndex : Integer; AValue : TStringArray); virtual;
  691. Procedure SetworkerId(AIndex : Integer; const AValue : String); virtual;
  692. //2.6.4. bug workaround
  693. {$IFDEF VER2_6}
  694. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  695. {$ENDIF VER2_6}
  696. Public
  697. Published
  698. Property currentWorkerTime : String Index 0 Read FcurrentWorkerTime Write SetcurrentWorkerTime;
  699. Property requestedLeaseDuration : String Index 8 Read FrequestedLeaseDuration Write SetrequestedLeaseDuration;
  700. Property workItemTypes : TStringArray Index 16 Read FworkItemTypes Write SetworkItemTypes;
  701. Property workerCapabilities : TStringArray Index 24 Read FworkerCapabilities Write SetworkerCapabilities;
  702. Property workerId : String Index 32 Read FworkerId Write SetworkerId;
  703. end;
  704. TLeaseWorkItemRequestClass = Class of TLeaseWorkItemRequest;
  705. { --------------------------------------------------------------------
  706. TLeaseWorkItemResponse
  707. --------------------------------------------------------------------}
  708. TLeaseWorkItemResponse = Class(TGoogleBaseObject)
  709. Private
  710. FworkItems : TLeaseWorkItemResponseTypeworkItemsArray;
  711. Protected
  712. //Property setters
  713. Procedure SetworkItems(AIndex : Integer; AValue : TLeaseWorkItemResponseTypeworkItemsArray); virtual;
  714. //2.6.4. bug workaround
  715. {$IFDEF VER2_6}
  716. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  717. {$ENDIF VER2_6}
  718. Public
  719. Published
  720. Property workItems : TLeaseWorkItemResponseTypeworkItemsArray Index 0 Read FworkItems Write SetworkItems;
  721. end;
  722. TLeaseWorkItemResponseClass = Class of TLeaseWorkItemResponse;
  723. { --------------------------------------------------------------------
  724. TListJobMessagesResponse
  725. --------------------------------------------------------------------}
  726. TListJobMessagesResponse = Class(TGoogleBaseObject)
  727. Private
  728. FjobMessages : TListJobMessagesResponseTypejobMessagesArray;
  729. FnextPageToken : String;
  730. Protected
  731. //Property setters
  732. Procedure SetjobMessages(AIndex : Integer; AValue : TListJobMessagesResponseTypejobMessagesArray); virtual;
  733. Procedure SetnextPageToken(AIndex : Integer; const AValue : String); virtual;
  734. //2.6.4. bug workaround
  735. {$IFDEF VER2_6}
  736. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  737. {$ENDIF VER2_6}
  738. Public
  739. Published
  740. Property jobMessages : TListJobMessagesResponseTypejobMessagesArray Index 0 Read FjobMessages Write SetjobMessages;
  741. Property nextPageToken : String Index 8 Read FnextPageToken Write SetnextPageToken;
  742. end;
  743. TListJobMessagesResponseClass = Class of TListJobMessagesResponse;
  744. { --------------------------------------------------------------------
  745. TListJobsResponse
  746. --------------------------------------------------------------------}
  747. TListJobsResponse = Class(TGoogleBaseObject)
  748. Private
  749. Fjobs : TListJobsResponseTypejobsArray;
  750. FnextPageToken : String;
  751. Protected
  752. //Property setters
  753. Procedure Setjobs(AIndex : Integer; AValue : TListJobsResponseTypejobsArray); virtual;
  754. Procedure SetnextPageToken(AIndex : Integer; const AValue : String); virtual;
  755. //2.6.4. bug workaround
  756. {$IFDEF VER2_6}
  757. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  758. {$ENDIF VER2_6}
  759. Public
  760. Published
  761. Property jobs : TListJobsResponseTypejobsArray Index 0 Read Fjobs Write Setjobs;
  762. Property nextPageToken : String Index 8 Read FnextPageToken Write SetnextPageToken;
  763. end;
  764. TListJobsResponseClass = Class of TListJobsResponse;
  765. { --------------------------------------------------------------------
  766. TMapTask
  767. --------------------------------------------------------------------}
  768. TMapTask = Class(TGoogleBaseObject)
  769. Private
  770. Finstructions : TMapTaskTypeinstructionsArray;
  771. FstageName : String;
  772. FsystemName : String;
  773. Protected
  774. //Property setters
  775. Procedure Setinstructions(AIndex : Integer; AValue : TMapTaskTypeinstructionsArray); virtual;
  776. Procedure SetstageName(AIndex : Integer; const AValue : String); virtual;
  777. Procedure SetsystemName(AIndex : Integer; const AValue : String); virtual;
  778. //2.6.4. bug workaround
  779. {$IFDEF VER2_6}
  780. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  781. {$ENDIF VER2_6}
  782. Public
  783. Published
  784. Property instructions : TMapTaskTypeinstructionsArray Index 0 Read Finstructions Write Setinstructions;
  785. Property stageName : String Index 8 Read FstageName Write SetstageName;
  786. Property systemName : String Index 16 Read FsystemName Write SetsystemName;
  787. end;
  788. TMapTaskClass = Class of TMapTask;
  789. { --------------------------------------------------------------------
  790. TMetricStructuredNameTypecontext
  791. --------------------------------------------------------------------}
  792. TMetricStructuredNameTypecontext = Class(TGoogleBaseObject)
  793. Private
  794. Protected
  795. //Property setters
  796. Public
  797. Class Function AllowAdditionalProperties : Boolean; override;
  798. Published
  799. end;
  800. TMetricStructuredNameTypecontextClass = Class of TMetricStructuredNameTypecontext;
  801. { --------------------------------------------------------------------
  802. TMetricStructuredName
  803. --------------------------------------------------------------------}
  804. TMetricStructuredName = Class(TGoogleBaseObject)
  805. Private
  806. Fcontext : TMetricStructuredNameTypecontext;
  807. Fname : String;
  808. Forigin : String;
  809. Protected
  810. //Property setters
  811. Procedure Setcontext(AIndex : Integer; AValue : TMetricStructuredNameTypecontext); virtual;
  812. Procedure Setname(AIndex : Integer; const AValue : String); virtual;
  813. Procedure Setorigin(AIndex : Integer; const AValue : String); virtual;
  814. Public
  815. Published
  816. Property context : TMetricStructuredNameTypecontext Index 0 Read Fcontext Write Setcontext;
  817. Property name : String Index 8 Read Fname Write Setname;
  818. Property origin : String Index 16 Read Forigin Write Setorigin;
  819. end;
  820. TMetricStructuredNameClass = Class of TMetricStructuredName;
  821. { --------------------------------------------------------------------
  822. TMetricUpdate
  823. --------------------------------------------------------------------}
  824. TMetricUpdate = Class(TGoogleBaseObject)
  825. Private
  826. Fcumulative : boolean;
  827. Finternal : TGoogleprotobufValue;
  828. Fkind : String;
  829. FmeanCount : TGoogleprotobufValue;
  830. FmeanSum : TGoogleprotobufValue;
  831. Fname : TMetricStructuredName;
  832. Fscalar : TGoogleprotobufValue;
  833. F_set : TGoogleprotobufValue;
  834. FupdateTime : String;
  835. Protected
  836. Class Function ExportPropertyName(Const AName : String) : string; override;
  837. //Property setters
  838. Procedure Setcumulative(AIndex : Integer; AValue : boolean); virtual;
  839. Procedure Setinternal(AIndex : Integer; AValue : TGoogleprotobufValue); virtual;
  840. Procedure Setkind(AIndex : Integer; const AValue : String); virtual;
  841. Procedure SetmeanCount(AIndex : Integer; AValue : TGoogleprotobufValue); virtual;
  842. Procedure SetmeanSum(AIndex : Integer; AValue : TGoogleprotobufValue); virtual;
  843. Procedure Setname(AIndex : Integer; AValue : TMetricStructuredName); virtual;
  844. Procedure Setscalar(AIndex : Integer; AValue : TGoogleprotobufValue); virtual;
  845. Procedure Set_set(AIndex : Integer; AValue : TGoogleprotobufValue); virtual;
  846. Procedure SetupdateTime(AIndex : Integer; const AValue : String); virtual;
  847. Public
  848. Published
  849. Property cumulative : boolean Index 0 Read Fcumulative Write Setcumulative;
  850. Property internal : TGoogleprotobufValue Index 8 Read Finternal Write Setinternal;
  851. Property kind : String Index 16 Read Fkind Write Setkind;
  852. Property meanCount : TGoogleprotobufValue Index 24 Read FmeanCount Write SetmeanCount;
  853. Property meanSum : TGoogleprotobufValue Index 32 Read FmeanSum Write SetmeanSum;
  854. Property name : TMetricStructuredName Index 40 Read Fname Write Setname;
  855. Property scalar : TGoogleprotobufValue Index 48 Read Fscalar Write Setscalar;
  856. Property _set : TGoogleprotobufValue Index 56 Read F_set Write Set_set;
  857. Property updateTime : String Index 64 Read FupdateTime Write SetupdateTime;
  858. end;
  859. TMetricUpdateClass = Class of TMetricUpdate;
  860. { --------------------------------------------------------------------
  861. TMountedDataDisk
  862. --------------------------------------------------------------------}
  863. TMountedDataDisk = Class(TGoogleBaseObject)
  864. Private
  865. FdataDisk : String;
  866. Protected
  867. //Property setters
  868. Procedure SetdataDisk(AIndex : Integer; const AValue : String); virtual;
  869. Public
  870. Published
  871. Property dataDisk : String Index 0 Read FdataDisk Write SetdataDisk;
  872. end;
  873. TMountedDataDiskClass = Class of TMountedDataDisk;
  874. { --------------------------------------------------------------------
  875. TMultiOutputInfo
  876. --------------------------------------------------------------------}
  877. TMultiOutputInfo = Class(TGoogleBaseObject)
  878. Private
  879. Ftag : String;
  880. Protected
  881. //Property setters
  882. Procedure Settag(AIndex : Integer; const AValue : String); virtual;
  883. Public
  884. Published
  885. Property tag : String Index 0 Read Ftag Write Settag;
  886. end;
  887. TMultiOutputInfoClass = Class of TMultiOutputInfo;
  888. { --------------------------------------------------------------------
  889. TPackage
  890. --------------------------------------------------------------------}
  891. TPackage = Class(TGoogleBaseObject)
  892. Private
  893. Flocation : String;
  894. Fname : String;
  895. Protected
  896. //Property setters
  897. Procedure Setlocation(AIndex : Integer; const AValue : String); virtual;
  898. Procedure Setname(AIndex : Integer; const AValue : String); virtual;
  899. Public
  900. Published
  901. Property location : String Index 0 Read Flocation Write Setlocation;
  902. Property name : String Index 8 Read Fname Write Setname;
  903. end;
  904. TPackageClass = Class of TPackage;
  905. { --------------------------------------------------------------------
  906. TParDoInstructionTypeuserFn
  907. --------------------------------------------------------------------}
  908. TParDoInstructionTypeuserFn = Class(TGoogleBaseObject)
  909. Private
  910. Protected
  911. //Property setters
  912. Public
  913. Class Function AllowAdditionalProperties : Boolean; override;
  914. Published
  915. end;
  916. TParDoInstructionTypeuserFnClass = Class of TParDoInstructionTypeuserFn;
  917. { --------------------------------------------------------------------
  918. TParDoInstruction
  919. --------------------------------------------------------------------}
  920. TParDoInstruction = Class(TGoogleBaseObject)
  921. Private
  922. Finput : TInstructionInput;
  923. FmultiOutputInfos : TParDoInstructionTypemultiOutputInfosArray;
  924. FnumOutputs : integer;
  925. FsideInputs : TParDoInstructionTypesideInputsArray;
  926. FuserFn : TParDoInstructionTypeuserFn;
  927. Protected
  928. //Property setters
  929. Procedure Setinput(AIndex : Integer; AValue : TInstructionInput); virtual;
  930. Procedure SetmultiOutputInfos(AIndex : Integer; AValue : TParDoInstructionTypemultiOutputInfosArray); virtual;
  931. Procedure SetnumOutputs(AIndex : Integer; AValue : integer); virtual;
  932. Procedure SetsideInputs(AIndex : Integer; AValue : TParDoInstructionTypesideInputsArray); virtual;
  933. Procedure SetuserFn(AIndex : Integer; AValue : TParDoInstructionTypeuserFn); virtual;
  934. //2.6.4. bug workaround
  935. {$IFDEF VER2_6}
  936. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  937. {$ENDIF VER2_6}
  938. Public
  939. Published
  940. Property input : TInstructionInput Index 0 Read Finput Write Setinput;
  941. Property multiOutputInfos : TParDoInstructionTypemultiOutputInfosArray Index 8 Read FmultiOutputInfos Write SetmultiOutputInfos;
  942. Property numOutputs : integer Index 16 Read FnumOutputs Write SetnumOutputs;
  943. Property sideInputs : TParDoInstructionTypesideInputsArray Index 24 Read FsideInputs Write SetsideInputs;
  944. Property userFn : TParDoInstructionTypeuserFn Index 32 Read FuserFn Write SetuserFn;
  945. end;
  946. TParDoInstructionClass = Class of TParDoInstruction;
  947. { --------------------------------------------------------------------
  948. TParallelInstruction
  949. --------------------------------------------------------------------}
  950. TParallelInstruction = Class(TGoogleBaseObject)
  951. Private
  952. Fflatten : TFlattenInstruction;
  953. Fname : String;
  954. Foutputs : TParallelInstructionTypeoutputsArray;
  955. FparDo : TParDoInstruction;
  956. FpartialGroupByKey : TPartialGroupByKeyInstruction;
  957. Fread : TReadInstruction;
  958. FsystemName : String;
  959. Fwrite : TWriteInstruction;
  960. Protected
  961. //Property setters
  962. Procedure Setflatten(AIndex : Integer; AValue : TFlattenInstruction); virtual;
  963. Procedure Setname(AIndex : Integer; const AValue : String); virtual;
  964. Procedure Setoutputs(AIndex : Integer; AValue : TParallelInstructionTypeoutputsArray); virtual;
  965. Procedure SetparDo(AIndex : Integer; AValue : TParDoInstruction); virtual;
  966. Procedure SetpartialGroupByKey(AIndex : Integer; AValue : TPartialGroupByKeyInstruction); virtual;
  967. Procedure Setread(AIndex : Integer; AValue : TReadInstruction); virtual;
  968. Procedure SetsystemName(AIndex : Integer; const AValue : String); virtual;
  969. Procedure Setwrite(AIndex : Integer; AValue : TWriteInstruction); virtual;
  970. //2.6.4. bug workaround
  971. {$IFDEF VER2_6}
  972. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  973. {$ENDIF VER2_6}
  974. Public
  975. Published
  976. Property flatten : TFlattenInstruction Index 0 Read Fflatten Write Setflatten;
  977. Property name : String Index 8 Read Fname Write Setname;
  978. Property outputs : TParallelInstructionTypeoutputsArray Index 16 Read Foutputs Write Setoutputs;
  979. Property parDo : TParDoInstruction Index 24 Read FparDo Write SetparDo;
  980. Property partialGroupByKey : TPartialGroupByKeyInstruction Index 32 Read FpartialGroupByKey Write SetpartialGroupByKey;
  981. Property read : TReadInstruction Index 40 Read Fread Write Setread;
  982. Property systemName : String Index 48 Read FsystemName Write SetsystemName;
  983. Property write : TWriteInstruction Index 56 Read Fwrite Write Setwrite;
  984. end;
  985. TParallelInstructionClass = Class of TParallelInstruction;
  986. { --------------------------------------------------------------------
  987. TPartialGroupByKeyInstructionTypeinputElementCodec
  988. --------------------------------------------------------------------}
  989. TPartialGroupByKeyInstructionTypeinputElementCodec = Class(TGoogleBaseObject)
  990. Private
  991. Protected
  992. //Property setters
  993. Public
  994. Class Function AllowAdditionalProperties : Boolean; override;
  995. Published
  996. end;
  997. TPartialGroupByKeyInstructionTypeinputElementCodecClass = Class of TPartialGroupByKeyInstructionTypeinputElementCodec;
  998. { --------------------------------------------------------------------
  999. TPartialGroupByKeyInstructionTypevalueCombiningFn
  1000. --------------------------------------------------------------------}
  1001. TPartialGroupByKeyInstructionTypevalueCombiningFn = Class(TGoogleBaseObject)
  1002. Private
  1003. Protected
  1004. //Property setters
  1005. Public
  1006. Class Function AllowAdditionalProperties : Boolean; override;
  1007. Published
  1008. end;
  1009. TPartialGroupByKeyInstructionTypevalueCombiningFnClass = Class of TPartialGroupByKeyInstructionTypevalueCombiningFn;
  1010. { --------------------------------------------------------------------
  1011. TPartialGroupByKeyInstruction
  1012. --------------------------------------------------------------------}
  1013. TPartialGroupByKeyInstruction = Class(TGoogleBaseObject)
  1014. Private
  1015. Finput : TInstructionInput;
  1016. FinputElementCodec : TPartialGroupByKeyInstructionTypeinputElementCodec;
  1017. FvalueCombiningFn : TPartialGroupByKeyInstructionTypevalueCombiningFn;
  1018. Protected
  1019. //Property setters
  1020. Procedure Setinput(AIndex : Integer; AValue : TInstructionInput); virtual;
  1021. Procedure SetinputElementCodec(AIndex : Integer; AValue : TPartialGroupByKeyInstructionTypeinputElementCodec); virtual;
  1022. Procedure SetvalueCombiningFn(AIndex : Integer; AValue : TPartialGroupByKeyInstructionTypevalueCombiningFn); virtual;
  1023. Public
  1024. Published
  1025. Property input : TInstructionInput Index 0 Read Finput Write Setinput;
  1026. Property inputElementCodec : TPartialGroupByKeyInstructionTypeinputElementCodec Index 8 Read FinputElementCodec Write SetinputElementCodec;
  1027. Property valueCombiningFn : TPartialGroupByKeyInstructionTypevalueCombiningFn Index 16 Read FvalueCombiningFn Write SetvalueCombiningFn;
  1028. end;
  1029. TPartialGroupByKeyInstructionClass = Class of TPartialGroupByKeyInstruction;
  1030. { --------------------------------------------------------------------
  1031. TPosition
  1032. --------------------------------------------------------------------}
  1033. TPosition = Class(TGoogleBaseObject)
  1034. Private
  1035. FbyteOffset : String;
  1036. F_end : boolean;
  1037. Fkey : String;
  1038. FrecordIndex : String;
  1039. FshufflePosition : String;
  1040. Protected
  1041. Class Function ExportPropertyName(Const AName : String) : string; override;
  1042. //Property setters
  1043. Procedure SetbyteOffset(AIndex : Integer; const AValue : String); virtual;
  1044. Procedure Set_end(AIndex : Integer; AValue : boolean); virtual;
  1045. Procedure Setkey(AIndex : Integer; const AValue : String); virtual;
  1046. Procedure SetrecordIndex(AIndex : Integer; const AValue : String); virtual;
  1047. Procedure SetshufflePosition(AIndex : Integer; const AValue : String); virtual;
  1048. Public
  1049. Published
  1050. Property byteOffset : String Index 0 Read FbyteOffset Write SetbyteOffset;
  1051. Property _end : boolean Index 8 Read F_end Write Set_end;
  1052. Property key : String Index 16 Read Fkey Write Setkey;
  1053. Property recordIndex : String Index 24 Read FrecordIndex Write SetrecordIndex;
  1054. Property shufflePosition : String Index 32 Read FshufflePosition Write SetshufflePosition;
  1055. end;
  1056. TPositionClass = Class of TPosition;
  1057. { --------------------------------------------------------------------
  1058. TPubsubLocation
  1059. --------------------------------------------------------------------}
  1060. TPubsubLocation = Class(TGoogleBaseObject)
  1061. Private
  1062. FdropLateData : boolean;
  1063. FidLabel : String;
  1064. Fsubscription : String;
  1065. FtimestampLabel : String;
  1066. Ftopic : String;
  1067. FtrackingSubscription : String;
  1068. Protected
  1069. //Property setters
  1070. Procedure SetdropLateData(AIndex : Integer; AValue : boolean); virtual;
  1071. Procedure SetidLabel(AIndex : Integer; const AValue : String); virtual;
  1072. Procedure Setsubscription(AIndex : Integer; const AValue : String); virtual;
  1073. Procedure SettimestampLabel(AIndex : Integer; const AValue : String); virtual;
  1074. Procedure Settopic(AIndex : Integer; const AValue : String); virtual;
  1075. Procedure SettrackingSubscription(AIndex : Integer; const AValue : String); virtual;
  1076. Public
  1077. Published
  1078. Property dropLateData : boolean Index 0 Read FdropLateData Write SetdropLateData;
  1079. Property idLabel : String Index 8 Read FidLabel Write SetidLabel;
  1080. Property subscription : String Index 16 Read Fsubscription Write Setsubscription;
  1081. Property timestampLabel : String Index 24 Read FtimestampLabel Write SettimestampLabel;
  1082. Property topic : String Index 32 Read Ftopic Write Settopic;
  1083. Property trackingSubscription : String Index 40 Read FtrackingSubscription Write SettrackingSubscription;
  1084. end;
  1085. TPubsubLocationClass = Class of TPubsubLocation;
  1086. { --------------------------------------------------------------------
  1087. TReadInstruction
  1088. --------------------------------------------------------------------}
  1089. TReadInstruction = Class(TGoogleBaseObject)
  1090. Private
  1091. Fsource : TSource;
  1092. Protected
  1093. //Property setters
  1094. Procedure Setsource(AIndex : Integer; AValue : TSource); virtual;
  1095. Public
  1096. Published
  1097. Property source : TSource Index 0 Read Fsource Write Setsource;
  1098. end;
  1099. TReadInstructionClass = Class of TReadInstruction;
  1100. { --------------------------------------------------------------------
  1101. TReportWorkItemStatusRequest
  1102. --------------------------------------------------------------------}
  1103. TReportWorkItemStatusRequest = Class(TGoogleBaseObject)
  1104. Private
  1105. FcurrentWorkerTime : String;
  1106. FworkItemStatuses : TReportWorkItemStatusRequestTypeworkItemStatusesArray;
  1107. FworkerId : String;
  1108. Protected
  1109. //Property setters
  1110. Procedure SetcurrentWorkerTime(AIndex : Integer; const AValue : String); virtual;
  1111. Procedure SetworkItemStatuses(AIndex : Integer; AValue : TReportWorkItemStatusRequestTypeworkItemStatusesArray); virtual;
  1112. Procedure SetworkerId(AIndex : Integer; const AValue : String); virtual;
  1113. //2.6.4. bug workaround
  1114. {$IFDEF VER2_6}
  1115. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1116. {$ENDIF VER2_6}
  1117. Public
  1118. Published
  1119. Property currentWorkerTime : String Index 0 Read FcurrentWorkerTime Write SetcurrentWorkerTime;
  1120. Property workItemStatuses : TReportWorkItemStatusRequestTypeworkItemStatusesArray Index 8 Read FworkItemStatuses Write SetworkItemStatuses;
  1121. Property workerId : String Index 16 Read FworkerId Write SetworkerId;
  1122. end;
  1123. TReportWorkItemStatusRequestClass = Class of TReportWorkItemStatusRequest;
  1124. { --------------------------------------------------------------------
  1125. TReportWorkItemStatusResponse
  1126. --------------------------------------------------------------------}
  1127. TReportWorkItemStatusResponse = Class(TGoogleBaseObject)
  1128. Private
  1129. FworkItemServiceStates : TReportWorkItemStatusResponseTypeworkItemServiceStatesArray;
  1130. Protected
  1131. //Property setters
  1132. Procedure SetworkItemServiceStates(AIndex : Integer; AValue : TReportWorkItemStatusResponseTypeworkItemServiceStatesArray); virtual;
  1133. //2.6.4. bug workaround
  1134. {$IFDEF VER2_6}
  1135. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1136. {$ENDIF VER2_6}
  1137. Public
  1138. Published
  1139. Property workItemServiceStates : TReportWorkItemStatusResponseTypeworkItemServiceStatesArray Index 0 Read FworkItemServiceStates Write SetworkItemServiceStates;
  1140. end;
  1141. TReportWorkItemStatusResponseClass = Class of TReportWorkItemStatusResponse;
  1142. { --------------------------------------------------------------------
  1143. TSeqMapTaskTypeuserFn
  1144. --------------------------------------------------------------------}
  1145. TSeqMapTaskTypeuserFn = Class(TGoogleBaseObject)
  1146. Private
  1147. Protected
  1148. //Property setters
  1149. Public
  1150. Class Function AllowAdditionalProperties : Boolean; override;
  1151. Published
  1152. end;
  1153. TSeqMapTaskTypeuserFnClass = Class of TSeqMapTaskTypeuserFn;
  1154. { --------------------------------------------------------------------
  1155. TSeqMapTask
  1156. --------------------------------------------------------------------}
  1157. TSeqMapTask = Class(TGoogleBaseObject)
  1158. Private
  1159. Finputs : TSeqMapTaskTypeinputsArray;
  1160. Fname : String;
  1161. FoutputInfos : TSeqMapTaskTypeoutputInfosArray;
  1162. FstageName : String;
  1163. FsystemName : String;
  1164. FuserFn : TSeqMapTaskTypeuserFn;
  1165. Protected
  1166. //Property setters
  1167. Procedure Setinputs(AIndex : Integer; AValue : TSeqMapTaskTypeinputsArray); virtual;
  1168. Procedure Setname(AIndex : Integer; const AValue : String); virtual;
  1169. Procedure SetoutputInfos(AIndex : Integer; AValue : TSeqMapTaskTypeoutputInfosArray); virtual;
  1170. Procedure SetstageName(AIndex : Integer; const AValue : String); virtual;
  1171. Procedure SetsystemName(AIndex : Integer; const AValue : String); virtual;
  1172. Procedure SetuserFn(AIndex : Integer; AValue : TSeqMapTaskTypeuserFn); virtual;
  1173. //2.6.4. bug workaround
  1174. {$IFDEF VER2_6}
  1175. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1176. {$ENDIF VER2_6}
  1177. Public
  1178. Published
  1179. Property inputs : TSeqMapTaskTypeinputsArray Index 0 Read Finputs Write Setinputs;
  1180. Property name : String Index 8 Read Fname Write Setname;
  1181. Property outputInfos : TSeqMapTaskTypeoutputInfosArray Index 16 Read FoutputInfos Write SetoutputInfos;
  1182. Property stageName : String Index 24 Read FstageName Write SetstageName;
  1183. Property systemName : String Index 32 Read FsystemName Write SetsystemName;
  1184. Property userFn : TSeqMapTaskTypeuserFn Index 40 Read FuserFn Write SetuserFn;
  1185. end;
  1186. TSeqMapTaskClass = Class of TSeqMapTask;
  1187. { --------------------------------------------------------------------
  1188. TSeqMapTaskOutputInfo
  1189. --------------------------------------------------------------------}
  1190. TSeqMapTaskOutputInfo = Class(TGoogleBaseObject)
  1191. Private
  1192. Fsink : TSink;
  1193. Ftag : String;
  1194. Protected
  1195. //Property setters
  1196. Procedure Setsink(AIndex : Integer; AValue : TSink); virtual;
  1197. Procedure Settag(AIndex : Integer; const AValue : String); virtual;
  1198. Public
  1199. Published
  1200. Property sink : TSink Index 0 Read Fsink Write Setsink;
  1201. Property tag : String Index 8 Read Ftag Write Settag;
  1202. end;
  1203. TSeqMapTaskOutputInfoClass = Class of TSeqMapTaskOutputInfo;
  1204. { --------------------------------------------------------------------
  1205. TShellTask
  1206. --------------------------------------------------------------------}
  1207. TShellTask = Class(TGoogleBaseObject)
  1208. Private
  1209. Fcommand : String;
  1210. FexitCode : integer;
  1211. Protected
  1212. //Property setters
  1213. Procedure Setcommand(AIndex : Integer; const AValue : String); virtual;
  1214. Procedure SetexitCode(AIndex : Integer; AValue : integer); virtual;
  1215. Public
  1216. Published
  1217. Property command : String Index 0 Read Fcommand Write Setcommand;
  1218. Property exitCode : integer Index 8 Read FexitCode Write SetexitCode;
  1219. end;
  1220. TShellTaskClass = Class of TShellTask;
  1221. { --------------------------------------------------------------------
  1222. TSideInputInfoTypekind
  1223. --------------------------------------------------------------------}
  1224. TSideInputInfoTypekind = Class(TGoogleBaseObject)
  1225. Private
  1226. Protected
  1227. //Property setters
  1228. Public
  1229. Class Function AllowAdditionalProperties : Boolean; override;
  1230. Published
  1231. end;
  1232. TSideInputInfoTypekindClass = Class of TSideInputInfoTypekind;
  1233. { --------------------------------------------------------------------
  1234. TSideInputInfo
  1235. --------------------------------------------------------------------}
  1236. TSideInputInfo = Class(TGoogleBaseObject)
  1237. Private
  1238. Fkind : TSideInputInfoTypekind;
  1239. Fsources : TSideInputInfoTypesourcesArray;
  1240. Ftag : String;
  1241. Protected
  1242. //Property setters
  1243. Procedure Setkind(AIndex : Integer; AValue : TSideInputInfoTypekind); virtual;
  1244. Procedure Setsources(AIndex : Integer; AValue : TSideInputInfoTypesourcesArray); virtual;
  1245. Procedure Settag(AIndex : Integer; const AValue : String); virtual;
  1246. //2.6.4. bug workaround
  1247. {$IFDEF VER2_6}
  1248. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1249. {$ENDIF VER2_6}
  1250. Public
  1251. Published
  1252. Property kind : TSideInputInfoTypekind Index 0 Read Fkind Write Setkind;
  1253. Property sources : TSideInputInfoTypesourcesArray Index 8 Read Fsources Write Setsources;
  1254. Property tag : String Index 16 Read Ftag Write Settag;
  1255. end;
  1256. TSideInputInfoClass = Class of TSideInputInfo;
  1257. { --------------------------------------------------------------------
  1258. TSinkTypecodec
  1259. --------------------------------------------------------------------}
  1260. TSinkTypecodec = Class(TGoogleBaseObject)
  1261. Private
  1262. Protected
  1263. //Property setters
  1264. Public
  1265. Class Function AllowAdditionalProperties : Boolean; override;
  1266. Published
  1267. end;
  1268. TSinkTypecodecClass = Class of TSinkTypecodec;
  1269. { --------------------------------------------------------------------
  1270. TSinkTypespec
  1271. --------------------------------------------------------------------}
  1272. TSinkTypespec = Class(TGoogleBaseObject)
  1273. Private
  1274. Protected
  1275. //Property setters
  1276. Public
  1277. Class Function AllowAdditionalProperties : Boolean; override;
  1278. Published
  1279. end;
  1280. TSinkTypespecClass = Class of TSinkTypespec;
  1281. { --------------------------------------------------------------------
  1282. TSink
  1283. --------------------------------------------------------------------}
  1284. TSink = Class(TGoogleBaseObject)
  1285. Private
  1286. Fcodec : TSinkTypecodec;
  1287. Fspec : TSinkTypespec;
  1288. Protected
  1289. //Property setters
  1290. Procedure Setcodec(AIndex : Integer; AValue : TSinkTypecodec); virtual;
  1291. Procedure Setspec(AIndex : Integer; AValue : TSinkTypespec); virtual;
  1292. Public
  1293. Published
  1294. Property codec : TSinkTypecodec Index 0 Read Fcodec Write Setcodec;
  1295. Property spec : TSinkTypespec Index 8 Read Fspec Write Setspec;
  1296. end;
  1297. TSinkClass = Class of TSink;
  1298. { --------------------------------------------------------------------
  1299. TSourceTypebaseSpecsItem
  1300. --------------------------------------------------------------------}
  1301. TSourceTypebaseSpecsItem = Class(TGoogleBaseObject)
  1302. Private
  1303. Protected
  1304. //Property setters
  1305. Public
  1306. Class Function AllowAdditionalProperties : Boolean; override;
  1307. Published
  1308. end;
  1309. TSourceTypebaseSpecsItemClass = Class of TSourceTypebaseSpecsItem;
  1310. { --------------------------------------------------------------------
  1311. TSourceTypecodec
  1312. --------------------------------------------------------------------}
  1313. TSourceTypecodec = Class(TGoogleBaseObject)
  1314. Private
  1315. Protected
  1316. //Property setters
  1317. Public
  1318. Class Function AllowAdditionalProperties : Boolean; override;
  1319. Published
  1320. end;
  1321. TSourceTypecodecClass = Class of TSourceTypecodec;
  1322. { --------------------------------------------------------------------
  1323. TSourceTypespec
  1324. --------------------------------------------------------------------}
  1325. TSourceTypespec = Class(TGoogleBaseObject)
  1326. Private
  1327. Protected
  1328. //Property setters
  1329. Public
  1330. Class Function AllowAdditionalProperties : Boolean; override;
  1331. Published
  1332. end;
  1333. TSourceTypespecClass = Class of TSourceTypespec;
  1334. { --------------------------------------------------------------------
  1335. TSource
  1336. --------------------------------------------------------------------}
  1337. TSource = Class(TGoogleBaseObject)
  1338. Private
  1339. FbaseSpecs : TSourceTypebaseSpecsArray;
  1340. Fcodec : TSourceTypecodec;
  1341. FdoesNotNeedSplitting : boolean;
  1342. Fmetadata : TSourceMetadata;
  1343. Fspec : TSourceTypespec;
  1344. Protected
  1345. //Property setters
  1346. Procedure SetbaseSpecs(AIndex : Integer; AValue : TSourceTypebaseSpecsArray); virtual;
  1347. Procedure Setcodec(AIndex : Integer; AValue : TSourceTypecodec); virtual;
  1348. Procedure SetdoesNotNeedSplitting(AIndex : Integer; AValue : boolean); virtual;
  1349. Procedure Setmetadata(AIndex : Integer; AValue : TSourceMetadata); virtual;
  1350. Procedure Setspec(AIndex : Integer; AValue : TSourceTypespec); virtual;
  1351. //2.6.4. bug workaround
  1352. {$IFDEF VER2_6}
  1353. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1354. {$ENDIF VER2_6}
  1355. Public
  1356. Published
  1357. Property baseSpecs : TSourceTypebaseSpecsArray Index 0 Read FbaseSpecs Write SetbaseSpecs;
  1358. Property codec : TSourceTypecodec Index 8 Read Fcodec Write Setcodec;
  1359. Property doesNotNeedSplitting : boolean Index 16 Read FdoesNotNeedSplitting Write SetdoesNotNeedSplitting;
  1360. Property metadata : TSourceMetadata Index 24 Read Fmetadata Write Setmetadata;
  1361. Property spec : TSourceTypespec Index 32 Read Fspec Write Setspec;
  1362. end;
  1363. TSourceClass = Class of TSource;
  1364. { --------------------------------------------------------------------
  1365. TSourceFork
  1366. --------------------------------------------------------------------}
  1367. TSourceFork = Class(TGoogleBaseObject)
  1368. Private
  1369. Fprimary : TSourceSplitShard;
  1370. FprimarySource : TDerivedSource;
  1371. Fresidual : TSourceSplitShard;
  1372. FresidualSource : TDerivedSource;
  1373. Protected
  1374. //Property setters
  1375. Procedure Setprimary(AIndex : Integer; AValue : TSourceSplitShard); virtual;
  1376. Procedure SetprimarySource(AIndex : Integer; AValue : TDerivedSource); virtual;
  1377. Procedure Setresidual(AIndex : Integer; AValue : TSourceSplitShard); virtual;
  1378. Procedure SetresidualSource(AIndex : Integer; AValue : TDerivedSource); virtual;
  1379. Public
  1380. Published
  1381. Property primary : TSourceSplitShard Index 0 Read Fprimary Write Setprimary;
  1382. Property primarySource : TDerivedSource Index 8 Read FprimarySource Write SetprimarySource;
  1383. Property residual : TSourceSplitShard Index 16 Read Fresidual Write Setresidual;
  1384. Property residualSource : TDerivedSource Index 24 Read FresidualSource Write SetresidualSource;
  1385. end;
  1386. TSourceForkClass = Class of TSourceFork;
  1387. { --------------------------------------------------------------------
  1388. TSourceGetMetadataRequest
  1389. --------------------------------------------------------------------}
  1390. TSourceGetMetadataRequest = Class(TGoogleBaseObject)
  1391. Private
  1392. Fsource : TSource;
  1393. Protected
  1394. //Property setters
  1395. Procedure Setsource(AIndex : Integer; AValue : TSource); virtual;
  1396. Public
  1397. Published
  1398. Property source : TSource Index 0 Read Fsource Write Setsource;
  1399. end;
  1400. TSourceGetMetadataRequestClass = Class of TSourceGetMetadataRequest;
  1401. { --------------------------------------------------------------------
  1402. TSourceGetMetadataResponse
  1403. --------------------------------------------------------------------}
  1404. TSourceGetMetadataResponse = Class(TGoogleBaseObject)
  1405. Private
  1406. Fmetadata : TSourceMetadata;
  1407. Protected
  1408. //Property setters
  1409. Procedure Setmetadata(AIndex : Integer; AValue : TSourceMetadata); virtual;
  1410. Public
  1411. Published
  1412. Property metadata : TSourceMetadata Index 0 Read Fmetadata Write Setmetadata;
  1413. end;
  1414. TSourceGetMetadataResponseClass = Class of TSourceGetMetadataResponse;
  1415. { --------------------------------------------------------------------
  1416. TSourceMetadata
  1417. --------------------------------------------------------------------}
  1418. TSourceMetadata = Class(TGoogleBaseObject)
  1419. Private
  1420. FestimatedSizeBytes : String;
  1421. Finfinite : boolean;
  1422. FproducesSortedKeys : boolean;
  1423. Protected
  1424. //Property setters
  1425. Procedure SetestimatedSizeBytes(AIndex : Integer; const AValue : String); virtual;
  1426. Procedure Setinfinite(AIndex : Integer; AValue : boolean); virtual;
  1427. Procedure SetproducesSortedKeys(AIndex : Integer; AValue : boolean); virtual;
  1428. Public
  1429. Published
  1430. Property estimatedSizeBytes : String Index 0 Read FestimatedSizeBytes Write SetestimatedSizeBytes;
  1431. Property infinite : boolean Index 8 Read Finfinite Write Setinfinite;
  1432. Property producesSortedKeys : boolean Index 16 Read FproducesSortedKeys Write SetproducesSortedKeys;
  1433. end;
  1434. TSourceMetadataClass = Class of TSourceMetadata;
  1435. { --------------------------------------------------------------------
  1436. TSourceOperationRequest
  1437. --------------------------------------------------------------------}
  1438. TSourceOperationRequest = Class(TGoogleBaseObject)
  1439. Private
  1440. FgetMetadata : TSourceGetMetadataRequest;
  1441. Fsplit : TSourceSplitRequest;
  1442. Protected
  1443. //Property setters
  1444. Procedure SetgetMetadata(AIndex : Integer; AValue : TSourceGetMetadataRequest); virtual;
  1445. Procedure Setsplit(AIndex : Integer; AValue : TSourceSplitRequest); virtual;
  1446. Public
  1447. Published
  1448. Property getMetadata : TSourceGetMetadataRequest Index 0 Read FgetMetadata Write SetgetMetadata;
  1449. Property split : TSourceSplitRequest Index 8 Read Fsplit Write Setsplit;
  1450. end;
  1451. TSourceOperationRequestClass = Class of TSourceOperationRequest;
  1452. { --------------------------------------------------------------------
  1453. TSourceOperationResponse
  1454. --------------------------------------------------------------------}
  1455. TSourceOperationResponse = Class(TGoogleBaseObject)
  1456. Private
  1457. FgetMetadata : TSourceGetMetadataResponse;
  1458. Fsplit : TSourceSplitResponse;
  1459. Protected
  1460. //Property setters
  1461. Procedure SetgetMetadata(AIndex : Integer; AValue : TSourceGetMetadataResponse); virtual;
  1462. Procedure Setsplit(AIndex : Integer; AValue : TSourceSplitResponse); virtual;
  1463. Public
  1464. Published
  1465. Property getMetadata : TSourceGetMetadataResponse Index 0 Read FgetMetadata Write SetgetMetadata;
  1466. Property split : TSourceSplitResponse Index 8 Read Fsplit Write Setsplit;
  1467. end;
  1468. TSourceOperationResponseClass = Class of TSourceOperationResponse;
  1469. { --------------------------------------------------------------------
  1470. TSourceSplitOptions
  1471. --------------------------------------------------------------------}
  1472. TSourceSplitOptions = Class(TGoogleBaseObject)
  1473. Private
  1474. FdesiredBundleSizeBytes : String;
  1475. FdesiredShardSizeBytes : String;
  1476. Protected
  1477. //Property setters
  1478. Procedure SetdesiredBundleSizeBytes(AIndex : Integer; const AValue : String); virtual;
  1479. Procedure SetdesiredShardSizeBytes(AIndex : Integer; const AValue : String); virtual;
  1480. Public
  1481. Published
  1482. Property desiredBundleSizeBytes : String Index 0 Read FdesiredBundleSizeBytes Write SetdesiredBundleSizeBytes;
  1483. Property desiredShardSizeBytes : String Index 8 Read FdesiredShardSizeBytes Write SetdesiredShardSizeBytes;
  1484. end;
  1485. TSourceSplitOptionsClass = Class of TSourceSplitOptions;
  1486. { --------------------------------------------------------------------
  1487. TSourceSplitRequest
  1488. --------------------------------------------------------------------}
  1489. TSourceSplitRequest = Class(TGoogleBaseObject)
  1490. Private
  1491. Foptions : TSourceSplitOptions;
  1492. Fsource : TSource;
  1493. Protected
  1494. //Property setters
  1495. Procedure Setoptions(AIndex : Integer; AValue : TSourceSplitOptions); virtual;
  1496. Procedure Setsource(AIndex : Integer; AValue : TSource); virtual;
  1497. Public
  1498. Published
  1499. Property options : TSourceSplitOptions Index 0 Read Foptions Write Setoptions;
  1500. Property source : TSource Index 8 Read Fsource Write Setsource;
  1501. end;
  1502. TSourceSplitRequestClass = Class of TSourceSplitRequest;
  1503. { --------------------------------------------------------------------
  1504. TSourceSplitResponse
  1505. --------------------------------------------------------------------}
  1506. TSourceSplitResponse = Class(TGoogleBaseObject)
  1507. Private
  1508. Fbundles : TSourceSplitResponseTypebundlesArray;
  1509. Foutcome : String;
  1510. Fshards : TSourceSplitResponseTypeshardsArray;
  1511. Protected
  1512. //Property setters
  1513. Procedure Setbundles(AIndex : Integer; AValue : TSourceSplitResponseTypebundlesArray); virtual;
  1514. Procedure Setoutcome(AIndex : Integer; const AValue : String); virtual;
  1515. Procedure Setshards(AIndex : Integer; AValue : TSourceSplitResponseTypeshardsArray); virtual;
  1516. //2.6.4. bug workaround
  1517. {$IFDEF VER2_6}
  1518. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1519. {$ENDIF VER2_6}
  1520. Public
  1521. Published
  1522. Property bundles : TSourceSplitResponseTypebundlesArray Index 0 Read Fbundles Write Setbundles;
  1523. Property outcome : String Index 8 Read Foutcome Write Setoutcome;
  1524. Property shards : TSourceSplitResponseTypeshardsArray Index 16 Read Fshards Write Setshards;
  1525. end;
  1526. TSourceSplitResponseClass = Class of TSourceSplitResponse;
  1527. { --------------------------------------------------------------------
  1528. TSourceSplitShard
  1529. --------------------------------------------------------------------}
  1530. TSourceSplitShard = Class(TGoogleBaseObject)
  1531. Private
  1532. FderivationMode : String;
  1533. Fsource : TSource;
  1534. Protected
  1535. //Property setters
  1536. Procedure SetderivationMode(AIndex : Integer; const AValue : String); virtual;
  1537. Procedure Setsource(AIndex : Integer; AValue : TSource); virtual;
  1538. Public
  1539. Published
  1540. Property derivationMode : String Index 0 Read FderivationMode Write SetderivationMode;
  1541. Property source : TSource Index 8 Read Fsource Write Setsource;
  1542. end;
  1543. TSourceSplitShardClass = Class of TSourceSplitShard;
  1544. { --------------------------------------------------------------------
  1545. TStatusTypedetailsItem
  1546. --------------------------------------------------------------------}
  1547. TStatusTypedetailsItem = Class(TGoogleBaseObject)
  1548. Private
  1549. Protected
  1550. //Property setters
  1551. Public
  1552. Class Function AllowAdditionalProperties : Boolean; override;
  1553. Published
  1554. end;
  1555. TStatusTypedetailsItemClass = Class of TStatusTypedetailsItem;
  1556. { --------------------------------------------------------------------
  1557. TStatus
  1558. --------------------------------------------------------------------}
  1559. TStatus = Class(TGoogleBaseObject)
  1560. Private
  1561. Fcode : integer;
  1562. Fdetails : TStatusTypedetailsArray;
  1563. Fmessage : String;
  1564. Protected
  1565. //Property setters
  1566. Procedure Setcode(AIndex : Integer; AValue : integer); virtual;
  1567. Procedure Setdetails(AIndex : Integer; AValue : TStatusTypedetailsArray); virtual;
  1568. Procedure Setmessage(AIndex : Integer; const AValue : String); virtual;
  1569. //2.6.4. bug workaround
  1570. {$IFDEF VER2_6}
  1571. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1572. {$ENDIF VER2_6}
  1573. Public
  1574. Published
  1575. Property code : integer Index 0 Read Fcode Write Setcode;
  1576. Property details : TStatusTypedetailsArray Index 8 Read Fdetails Write Setdetails;
  1577. Property message : String Index 16 Read Fmessage Write Setmessage;
  1578. end;
  1579. TStatusClass = Class of TStatus;
  1580. { --------------------------------------------------------------------
  1581. TStepTypeproperties
  1582. --------------------------------------------------------------------}
  1583. TStepTypeproperties = Class(TGoogleBaseObject)
  1584. Private
  1585. Protected
  1586. //Property setters
  1587. Public
  1588. Class Function AllowAdditionalProperties : Boolean; override;
  1589. Published
  1590. end;
  1591. TStepTypepropertiesClass = Class of TStepTypeproperties;
  1592. { --------------------------------------------------------------------
  1593. TStep
  1594. --------------------------------------------------------------------}
  1595. TStep = Class(TGoogleBaseObject)
  1596. Private
  1597. Fkind : String;
  1598. Fname : String;
  1599. Fproperties : TStepTypeproperties;
  1600. Protected
  1601. //Property setters
  1602. Procedure Setkind(AIndex : Integer; const AValue : String); virtual;
  1603. Procedure Setname(AIndex : Integer; const AValue : String); virtual;
  1604. Procedure Setproperties(AIndex : Integer; AValue : TStepTypeproperties); virtual;
  1605. Public
  1606. Published
  1607. Property kind : String Index 0 Read Fkind Write Setkind;
  1608. Property name : String Index 8 Read Fname Write Setname;
  1609. Property properties : TStepTypeproperties Index 16 Read Fproperties Write Setproperties;
  1610. end;
  1611. TStepClass = Class of TStep;
  1612. { --------------------------------------------------------------------
  1613. TStreamLocation
  1614. --------------------------------------------------------------------}
  1615. TStreamLocation = Class(TGoogleBaseObject)
  1616. Private
  1617. FpubsubLocation : TPubsubLocation;
  1618. FsideInputLocation : TStreamingSideInputLocation;
  1619. FstreamingStageLocation : TStreamingStageLocation;
  1620. Protected
  1621. //Property setters
  1622. Procedure SetpubsubLocation(AIndex : Integer; AValue : TPubsubLocation); virtual;
  1623. Procedure SetsideInputLocation(AIndex : Integer; AValue : TStreamingSideInputLocation); virtual;
  1624. Procedure SetstreamingStageLocation(AIndex : Integer; AValue : TStreamingStageLocation); virtual;
  1625. Public
  1626. Published
  1627. Property pubsubLocation : TPubsubLocation Index 0 Read FpubsubLocation Write SetpubsubLocation;
  1628. Property sideInputLocation : TStreamingSideInputLocation Index 8 Read FsideInputLocation Write SetsideInputLocation;
  1629. Property streamingStageLocation : TStreamingStageLocation Index 16 Read FstreamingStageLocation Write SetstreamingStageLocation;
  1630. end;
  1631. TStreamLocationClass = Class of TStreamLocation;
  1632. { --------------------------------------------------------------------
  1633. TStreamingComputationRanges
  1634. --------------------------------------------------------------------}
  1635. TStreamingComputationRanges = Class(TGoogleBaseObject)
  1636. Private
  1637. FcomputationId : String;
  1638. FrangeAssignments : TStreamingComputationRangesTyperangeAssignmentsArray;
  1639. Protected
  1640. //Property setters
  1641. Procedure SetcomputationId(AIndex : Integer; const AValue : String); virtual;
  1642. Procedure SetrangeAssignments(AIndex : Integer; AValue : TStreamingComputationRangesTyperangeAssignmentsArray); virtual;
  1643. //2.6.4. bug workaround
  1644. {$IFDEF VER2_6}
  1645. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1646. {$ENDIF VER2_6}
  1647. Public
  1648. Published
  1649. Property computationId : String Index 0 Read FcomputationId Write SetcomputationId;
  1650. Property rangeAssignments : TStreamingComputationRangesTyperangeAssignmentsArray Index 8 Read FrangeAssignments Write SetrangeAssignments;
  1651. end;
  1652. TStreamingComputationRangesClass = Class of TStreamingComputationRanges;
  1653. { --------------------------------------------------------------------
  1654. TStreamingComputationTask
  1655. --------------------------------------------------------------------}
  1656. TStreamingComputationTask = Class(TGoogleBaseObject)
  1657. Private
  1658. FcomputationRanges : TStreamingComputationTaskTypecomputationRangesArray;
  1659. FdataDisks : TStreamingComputationTaskTypedataDisksArray;
  1660. FtaskType : String;
  1661. Protected
  1662. //Property setters
  1663. Procedure SetcomputationRanges(AIndex : Integer; AValue : TStreamingComputationTaskTypecomputationRangesArray); virtual;
  1664. Procedure SetdataDisks(AIndex : Integer; AValue : TStreamingComputationTaskTypedataDisksArray); virtual;
  1665. Procedure SettaskType(AIndex : Integer; const AValue : String); virtual;
  1666. //2.6.4. bug workaround
  1667. {$IFDEF VER2_6}
  1668. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1669. {$ENDIF VER2_6}
  1670. Public
  1671. Published
  1672. Property computationRanges : TStreamingComputationTaskTypecomputationRangesArray Index 0 Read FcomputationRanges Write SetcomputationRanges;
  1673. Property dataDisks : TStreamingComputationTaskTypedataDisksArray Index 8 Read FdataDisks Write SetdataDisks;
  1674. Property taskType : String Index 16 Read FtaskType Write SettaskType;
  1675. end;
  1676. TStreamingComputationTaskClass = Class of TStreamingComputationTask;
  1677. { --------------------------------------------------------------------
  1678. TStreamingSetupTask
  1679. --------------------------------------------------------------------}
  1680. TStreamingSetupTask = Class(TGoogleBaseObject)
  1681. Private
  1682. FreceiveWorkPort : integer;
  1683. FstreamingComputationTopology : TTopologyConfig;
  1684. FworkerHarnessPort : integer;
  1685. Protected
  1686. //Property setters
  1687. Procedure SetreceiveWorkPort(AIndex : Integer; AValue : integer); virtual;
  1688. Procedure SetstreamingComputationTopology(AIndex : Integer; AValue : TTopologyConfig); virtual;
  1689. Procedure SetworkerHarnessPort(AIndex : Integer; AValue : integer); virtual;
  1690. Public
  1691. Published
  1692. Property receiveWorkPort : integer Index 0 Read FreceiveWorkPort Write SetreceiveWorkPort;
  1693. Property streamingComputationTopology : TTopologyConfig Index 8 Read FstreamingComputationTopology Write SetstreamingComputationTopology;
  1694. Property workerHarnessPort : integer Index 16 Read FworkerHarnessPort Write SetworkerHarnessPort;
  1695. end;
  1696. TStreamingSetupTaskClass = Class of TStreamingSetupTask;
  1697. { --------------------------------------------------------------------
  1698. TStreamingSideInputLocation
  1699. --------------------------------------------------------------------}
  1700. TStreamingSideInputLocation = Class(TGoogleBaseObject)
  1701. Private
  1702. Ftag : String;
  1703. Protected
  1704. //Property setters
  1705. Procedure Settag(AIndex : Integer; const AValue : String); virtual;
  1706. Public
  1707. Published
  1708. Property tag : String Index 0 Read Ftag Write Settag;
  1709. end;
  1710. TStreamingSideInputLocationClass = Class of TStreamingSideInputLocation;
  1711. { --------------------------------------------------------------------
  1712. TStreamingStageLocation
  1713. --------------------------------------------------------------------}
  1714. TStreamingStageLocation = Class(TGoogleBaseObject)
  1715. Private
  1716. FstreamId : String;
  1717. Protected
  1718. //Property setters
  1719. Procedure SetstreamId(AIndex : Integer; const AValue : String); virtual;
  1720. Public
  1721. Published
  1722. Property streamId : String Index 0 Read FstreamId Write SetstreamId;
  1723. end;
  1724. TStreamingStageLocationClass = Class of TStreamingStageLocation;
  1725. { --------------------------------------------------------------------
  1726. TTaskRunnerSettings
  1727. --------------------------------------------------------------------}
  1728. TTaskRunnerSettings = Class(TGoogleBaseObject)
  1729. Private
  1730. Falsologtostderr : boolean;
  1731. FbaseTaskDir : String;
  1732. FbaseUrl : String;
  1733. FcommandlinesFileName : String;
  1734. FcontinueOnException : boolean;
  1735. FdataflowApiVersion : String;
  1736. FharnessCommand : String;
  1737. FlanguageHint : String;
  1738. FlogDir : String;
  1739. FlogToSerialconsole : boolean;
  1740. FlogUploadLocation : String;
  1741. FoauthScopes : TStringArray;
  1742. FparallelWorkerSettings : TWorkerSettings;
  1743. FstreamingWorkerMainClass : String;
  1744. FtaskGroup : String;
  1745. FtaskUser : String;
  1746. FtempStoragePrefix : String;
  1747. FvmId : String;
  1748. FworkflowFileName : String;
  1749. Protected
  1750. //Property setters
  1751. Procedure Setalsologtostderr(AIndex : Integer; AValue : boolean); virtual;
  1752. Procedure SetbaseTaskDir(AIndex : Integer; const AValue : String); virtual;
  1753. Procedure SetbaseUrl(AIndex : Integer; const AValue : String); virtual;
  1754. Procedure SetcommandlinesFileName(AIndex : Integer; const AValue : String); virtual;
  1755. Procedure SetcontinueOnException(AIndex : Integer; AValue : boolean); virtual;
  1756. Procedure SetdataflowApiVersion(AIndex : Integer; const AValue : String); virtual;
  1757. Procedure SetharnessCommand(AIndex : Integer; const AValue : String); virtual;
  1758. Procedure SetlanguageHint(AIndex : Integer; const AValue : String); virtual;
  1759. Procedure SetlogDir(AIndex : Integer; const AValue : String); virtual;
  1760. Procedure SetlogToSerialconsole(AIndex : Integer; AValue : boolean); virtual;
  1761. Procedure SetlogUploadLocation(AIndex : Integer; const AValue : String); virtual;
  1762. Procedure SetoauthScopes(AIndex : Integer; AValue : TStringArray); virtual;
  1763. Procedure SetparallelWorkerSettings(AIndex : Integer; AValue : TWorkerSettings); virtual;
  1764. Procedure SetstreamingWorkerMainClass(AIndex : Integer; const AValue : String); virtual;
  1765. Procedure SettaskGroup(AIndex : Integer; const AValue : String); virtual;
  1766. Procedure SettaskUser(AIndex : Integer; const AValue : String); virtual;
  1767. Procedure SettempStoragePrefix(AIndex : Integer; const AValue : String); virtual;
  1768. Procedure SetvmId(AIndex : Integer; const AValue : String); virtual;
  1769. Procedure SetworkflowFileName(AIndex : Integer; const AValue : String); virtual;
  1770. //2.6.4. bug workaround
  1771. {$IFDEF VER2_6}
  1772. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1773. {$ENDIF VER2_6}
  1774. Public
  1775. Published
  1776. Property alsologtostderr : boolean Index 0 Read Falsologtostderr Write Setalsologtostderr;
  1777. Property baseTaskDir : String Index 8 Read FbaseTaskDir Write SetbaseTaskDir;
  1778. Property baseUrl : String Index 16 Read FbaseUrl Write SetbaseUrl;
  1779. Property commandlinesFileName : String Index 24 Read FcommandlinesFileName Write SetcommandlinesFileName;
  1780. Property continueOnException : boolean Index 32 Read FcontinueOnException Write SetcontinueOnException;
  1781. Property dataflowApiVersion : String Index 40 Read FdataflowApiVersion Write SetdataflowApiVersion;
  1782. Property harnessCommand : String Index 48 Read FharnessCommand Write SetharnessCommand;
  1783. Property languageHint : String Index 56 Read FlanguageHint Write SetlanguageHint;
  1784. Property logDir : String Index 64 Read FlogDir Write SetlogDir;
  1785. Property logToSerialconsole : boolean Index 72 Read FlogToSerialconsole Write SetlogToSerialconsole;
  1786. Property logUploadLocation : String Index 80 Read FlogUploadLocation Write SetlogUploadLocation;
  1787. Property oauthScopes : TStringArray Index 88 Read FoauthScopes Write SetoauthScopes;
  1788. Property parallelWorkerSettings : TWorkerSettings Index 96 Read FparallelWorkerSettings Write SetparallelWorkerSettings;
  1789. Property streamingWorkerMainClass : String Index 104 Read FstreamingWorkerMainClass Write SetstreamingWorkerMainClass;
  1790. Property taskGroup : String Index 112 Read FtaskGroup Write SettaskGroup;
  1791. Property taskUser : String Index 120 Read FtaskUser Write SettaskUser;
  1792. Property tempStoragePrefix : String Index 128 Read FtempStoragePrefix Write SettempStoragePrefix;
  1793. Property vmId : String Index 136 Read FvmId Write SetvmId;
  1794. Property workflowFileName : String Index 144 Read FworkflowFileName Write SetworkflowFileName;
  1795. end;
  1796. TTaskRunnerSettingsClass = Class of TTaskRunnerSettings;
  1797. { --------------------------------------------------------------------
  1798. TTopologyConfig
  1799. --------------------------------------------------------------------}
  1800. TTopologyConfig = Class(TGoogleBaseObject)
  1801. Private
  1802. Fcomputations : TTopologyConfigTypecomputationsArray;
  1803. FdataDiskAssignments : TTopologyConfigTypedataDiskAssignmentsArray;
  1804. Protected
  1805. //Property setters
  1806. Procedure Setcomputations(AIndex : Integer; AValue : TTopologyConfigTypecomputationsArray); virtual;
  1807. Procedure SetdataDiskAssignments(AIndex : Integer; AValue : TTopologyConfigTypedataDiskAssignmentsArray); virtual;
  1808. //2.6.4. bug workaround
  1809. {$IFDEF VER2_6}
  1810. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1811. {$ENDIF VER2_6}
  1812. Public
  1813. Published
  1814. Property computations : TTopologyConfigTypecomputationsArray Index 0 Read Fcomputations Write Setcomputations;
  1815. Property dataDiskAssignments : TTopologyConfigTypedataDiskAssignmentsArray Index 8 Read FdataDiskAssignments Write SetdataDiskAssignments;
  1816. end;
  1817. TTopologyConfigClass = Class of TTopologyConfig;
  1818. { --------------------------------------------------------------------
  1819. TWorkItem
  1820. --------------------------------------------------------------------}
  1821. TWorkItem = Class(TGoogleBaseObject)
  1822. Private
  1823. Fconfiguration : String;
  1824. Fid : String;
  1825. FinitialReportIndex : String;
  1826. FjobId : String;
  1827. FleaseExpireTime : String;
  1828. FmapTask : TMapTask;
  1829. Fpackages : TWorkItemTypepackagesArray;
  1830. FprojectId : String;
  1831. FreportStatusInterval : String;
  1832. FseqMapTask : TSeqMapTask;
  1833. FshellTask : TShellTask;
  1834. FsourceOperationTask : TSourceOperationRequest;
  1835. FstreamingComputationTask : TStreamingComputationTask;
  1836. FstreamingSetupTask : TStreamingSetupTask;
  1837. Protected
  1838. //Property setters
  1839. Procedure Setconfiguration(AIndex : Integer; const AValue : String); virtual;
  1840. Procedure Setid(AIndex : Integer; const AValue : String); virtual;
  1841. Procedure SetinitialReportIndex(AIndex : Integer; const AValue : String); virtual;
  1842. Procedure SetjobId(AIndex : Integer; const AValue : String); virtual;
  1843. Procedure SetleaseExpireTime(AIndex : Integer; const AValue : String); virtual;
  1844. Procedure SetmapTask(AIndex : Integer; AValue : TMapTask); virtual;
  1845. Procedure Setpackages(AIndex : Integer; AValue : TWorkItemTypepackagesArray); virtual;
  1846. Procedure SetprojectId(AIndex : Integer; const AValue : String); virtual;
  1847. Procedure SetreportStatusInterval(AIndex : Integer; const AValue : String); virtual;
  1848. Procedure SetseqMapTask(AIndex : Integer; AValue : TSeqMapTask); virtual;
  1849. Procedure SetshellTask(AIndex : Integer; AValue : TShellTask); virtual;
  1850. Procedure SetsourceOperationTask(AIndex : Integer; AValue : TSourceOperationRequest); virtual;
  1851. Procedure SetstreamingComputationTask(AIndex : Integer; AValue : TStreamingComputationTask); virtual;
  1852. Procedure SetstreamingSetupTask(AIndex : Integer; AValue : TStreamingSetupTask); virtual;
  1853. //2.6.4. bug workaround
  1854. {$IFDEF VER2_6}
  1855. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1856. {$ENDIF VER2_6}
  1857. Public
  1858. Published
  1859. Property configuration : String Index 0 Read Fconfiguration Write Setconfiguration;
  1860. Property id : String Index 8 Read Fid Write Setid;
  1861. Property initialReportIndex : String Index 16 Read FinitialReportIndex Write SetinitialReportIndex;
  1862. Property jobId : String Index 24 Read FjobId Write SetjobId;
  1863. Property leaseExpireTime : String Index 32 Read FleaseExpireTime Write SetleaseExpireTime;
  1864. Property mapTask : TMapTask Index 40 Read FmapTask Write SetmapTask;
  1865. Property packages : TWorkItemTypepackagesArray Index 48 Read Fpackages Write Setpackages;
  1866. Property projectId : String Index 56 Read FprojectId Write SetprojectId;
  1867. Property reportStatusInterval : String Index 64 Read FreportStatusInterval Write SetreportStatusInterval;
  1868. Property seqMapTask : TSeqMapTask Index 72 Read FseqMapTask Write SetseqMapTask;
  1869. Property shellTask : TShellTask Index 80 Read FshellTask Write SetshellTask;
  1870. Property sourceOperationTask : TSourceOperationRequest Index 88 Read FsourceOperationTask Write SetsourceOperationTask;
  1871. Property streamingComputationTask : TStreamingComputationTask Index 96 Read FstreamingComputationTask Write SetstreamingComputationTask;
  1872. Property streamingSetupTask : TStreamingSetupTask Index 104 Read FstreamingSetupTask Write SetstreamingSetupTask;
  1873. end;
  1874. TWorkItemClass = Class of TWorkItem;
  1875. { --------------------------------------------------------------------
  1876. TWorkItemServiceStateTypeharnessData
  1877. --------------------------------------------------------------------}
  1878. TWorkItemServiceStateTypeharnessData = Class(TGoogleBaseObject)
  1879. Private
  1880. Protected
  1881. //Property setters
  1882. Public
  1883. Class Function AllowAdditionalProperties : Boolean; override;
  1884. Published
  1885. end;
  1886. TWorkItemServiceStateTypeharnessDataClass = Class of TWorkItemServiceStateTypeharnessData;
  1887. { --------------------------------------------------------------------
  1888. TWorkItemServiceState
  1889. --------------------------------------------------------------------}
  1890. TWorkItemServiceState = Class(TGoogleBaseObject)
  1891. Private
  1892. FharnessData : TWorkItemServiceStateTypeharnessData;
  1893. FleaseExpireTime : String;
  1894. FnextReportIndex : String;
  1895. FreportStatusInterval : String;
  1896. FsuggestedStopPoint : TApproximateProgress;
  1897. FsuggestedStopPosition : TPosition;
  1898. Protected
  1899. //Property setters
  1900. Procedure SetharnessData(AIndex : Integer; AValue : TWorkItemServiceStateTypeharnessData); virtual;
  1901. Procedure SetleaseExpireTime(AIndex : Integer; const AValue : String); virtual;
  1902. Procedure SetnextReportIndex(AIndex : Integer; const AValue : String); virtual;
  1903. Procedure SetreportStatusInterval(AIndex : Integer; const AValue : String); virtual;
  1904. Procedure SetsuggestedStopPoint(AIndex : Integer; AValue : TApproximateProgress); virtual;
  1905. Procedure SetsuggestedStopPosition(AIndex : Integer; AValue : TPosition); virtual;
  1906. Public
  1907. Published
  1908. Property harnessData : TWorkItemServiceStateTypeharnessData Index 0 Read FharnessData Write SetharnessData;
  1909. Property leaseExpireTime : String Index 8 Read FleaseExpireTime Write SetleaseExpireTime;
  1910. Property nextReportIndex : String Index 16 Read FnextReportIndex Write SetnextReportIndex;
  1911. Property reportStatusInterval : String Index 24 Read FreportStatusInterval Write SetreportStatusInterval;
  1912. Property suggestedStopPoint : TApproximateProgress Index 32 Read FsuggestedStopPoint Write SetsuggestedStopPoint;
  1913. Property suggestedStopPosition : TPosition Index 40 Read FsuggestedStopPosition Write SetsuggestedStopPosition;
  1914. end;
  1915. TWorkItemServiceStateClass = Class of TWorkItemServiceState;
  1916. { --------------------------------------------------------------------
  1917. TWorkItemStatus
  1918. --------------------------------------------------------------------}
  1919. TWorkItemStatus = Class(TGoogleBaseObject)
  1920. Private
  1921. Fcompleted : boolean;
  1922. FdynamicSourceSplit : TDynamicSourceSplit;
  1923. Ferrors : TWorkItemStatusTypeerrorsArray;
  1924. FmetricUpdates : TWorkItemStatusTypemetricUpdatesArray;
  1925. Fprogress : TApproximateProgress;
  1926. FreportIndex : String;
  1927. FrequestedLeaseDuration : String;
  1928. FsourceFork : TSourceFork;
  1929. FsourceOperationResponse : TSourceOperationResponse;
  1930. FstopPosition : TPosition;
  1931. FworkItemId : String;
  1932. Protected
  1933. //Property setters
  1934. Procedure Setcompleted(AIndex : Integer; AValue : boolean); virtual;
  1935. Procedure SetdynamicSourceSplit(AIndex : Integer; AValue : TDynamicSourceSplit); virtual;
  1936. Procedure Seterrors(AIndex : Integer; AValue : TWorkItemStatusTypeerrorsArray); virtual;
  1937. Procedure SetmetricUpdates(AIndex : Integer; AValue : TWorkItemStatusTypemetricUpdatesArray); virtual;
  1938. Procedure Setprogress(AIndex : Integer; AValue : TApproximateProgress); virtual;
  1939. Procedure SetreportIndex(AIndex : Integer; const AValue : String); virtual;
  1940. Procedure SetrequestedLeaseDuration(AIndex : Integer; const AValue : String); virtual;
  1941. Procedure SetsourceFork(AIndex : Integer; AValue : TSourceFork); virtual;
  1942. Procedure SetsourceOperationResponse(AIndex : Integer; AValue : TSourceOperationResponse); virtual;
  1943. Procedure SetstopPosition(AIndex : Integer; AValue : TPosition); virtual;
  1944. Procedure SetworkItemId(AIndex : Integer; const AValue : String); virtual;
  1945. //2.6.4. bug workaround
  1946. {$IFDEF VER2_6}
  1947. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  1948. {$ENDIF VER2_6}
  1949. Public
  1950. Published
  1951. Property completed : boolean Index 0 Read Fcompleted Write Setcompleted;
  1952. Property dynamicSourceSplit : TDynamicSourceSplit Index 8 Read FdynamicSourceSplit Write SetdynamicSourceSplit;
  1953. Property errors : TWorkItemStatusTypeerrorsArray Index 16 Read Ferrors Write Seterrors;
  1954. Property metricUpdates : TWorkItemStatusTypemetricUpdatesArray Index 24 Read FmetricUpdates Write SetmetricUpdates;
  1955. Property progress : TApproximateProgress Index 32 Read Fprogress Write Setprogress;
  1956. Property reportIndex : String Index 40 Read FreportIndex Write SetreportIndex;
  1957. Property requestedLeaseDuration : String Index 48 Read FrequestedLeaseDuration Write SetrequestedLeaseDuration;
  1958. Property sourceFork : TSourceFork Index 56 Read FsourceFork Write SetsourceFork;
  1959. Property sourceOperationResponse : TSourceOperationResponse Index 64 Read FsourceOperationResponse Write SetsourceOperationResponse;
  1960. Property stopPosition : TPosition Index 72 Read FstopPosition Write SetstopPosition;
  1961. Property workItemId : String Index 80 Read FworkItemId Write SetworkItemId;
  1962. end;
  1963. TWorkItemStatusClass = Class of TWorkItemStatus;
  1964. { --------------------------------------------------------------------
  1965. TWorkerPoolTypemetadata
  1966. --------------------------------------------------------------------}
  1967. TWorkerPoolTypemetadata = Class(TGoogleBaseObject)
  1968. Private
  1969. Protected
  1970. //Property setters
  1971. Public
  1972. Class Function AllowAdditionalProperties : Boolean; override;
  1973. Published
  1974. end;
  1975. TWorkerPoolTypemetadataClass = Class of TWorkerPoolTypemetadata;
  1976. { --------------------------------------------------------------------
  1977. TWorkerPoolTypepoolArgs
  1978. --------------------------------------------------------------------}
  1979. TWorkerPoolTypepoolArgs = Class(TGoogleBaseObject)
  1980. Private
  1981. Protected
  1982. //Property setters
  1983. Public
  1984. Class Function AllowAdditionalProperties : Boolean; override;
  1985. Published
  1986. end;
  1987. TWorkerPoolTypepoolArgsClass = Class of TWorkerPoolTypepoolArgs;
  1988. { --------------------------------------------------------------------
  1989. TWorkerPool
  1990. --------------------------------------------------------------------}
  1991. TWorkerPool = Class(TGoogleBaseObject)
  1992. Private
  1993. FautoscalingSettings : TAutoscalingSettings;
  1994. FdataDisks : TWorkerPoolTypedataDisksArray;
  1995. FdefaultPackageSet : String;
  1996. FdiskSizeGb : integer;
  1997. FdiskSourceImage : String;
  1998. FdiskType : String;
  1999. Fkind : String;
  2000. FmachineType : String;
  2001. Fmetadata : TWorkerPoolTypemetadata;
  2002. FnumWorkers : integer;
  2003. FonHostMaintenance : String;
  2004. Fpackages : TWorkerPoolTypepackagesArray;
  2005. FpoolArgs : TWorkerPoolTypepoolArgs;
  2006. FtaskrunnerSettings : TTaskRunnerSettings;
  2007. FteardownPolicy : String;
  2008. Fzone : String;
  2009. Protected
  2010. //Property setters
  2011. Procedure SetautoscalingSettings(AIndex : Integer; AValue : TAutoscalingSettings); virtual;
  2012. Procedure SetdataDisks(AIndex : Integer; AValue : TWorkerPoolTypedataDisksArray); virtual;
  2013. Procedure SetdefaultPackageSet(AIndex : Integer; const AValue : String); virtual;
  2014. Procedure SetdiskSizeGb(AIndex : Integer; AValue : integer); virtual;
  2015. Procedure SetdiskSourceImage(AIndex : Integer; const AValue : String); virtual;
  2016. Procedure SetdiskType(AIndex : Integer; const AValue : String); virtual;
  2017. Procedure Setkind(AIndex : Integer; const AValue : String); virtual;
  2018. Procedure SetmachineType(AIndex : Integer; const AValue : String); virtual;
  2019. Procedure Setmetadata(AIndex : Integer; AValue : TWorkerPoolTypemetadata); virtual;
  2020. Procedure SetnumWorkers(AIndex : Integer; AValue : integer); virtual;
  2021. Procedure SetonHostMaintenance(AIndex : Integer; const AValue : String); virtual;
  2022. Procedure Setpackages(AIndex : Integer; AValue : TWorkerPoolTypepackagesArray); virtual;
  2023. Procedure SetpoolArgs(AIndex : Integer; AValue : TWorkerPoolTypepoolArgs); virtual;
  2024. Procedure SettaskrunnerSettings(AIndex : Integer; AValue : TTaskRunnerSettings); virtual;
  2025. Procedure SetteardownPolicy(AIndex : Integer; const AValue : String); virtual;
  2026. Procedure Setzone(AIndex : Integer; const AValue : String); virtual;
  2027. //2.6.4. bug workaround
  2028. {$IFDEF VER2_6}
  2029. Procedure SetArrayLength(Const AName : String; ALength : Longint); override;
  2030. {$ENDIF VER2_6}
  2031. Public
  2032. Published
  2033. Property autoscalingSettings : TAutoscalingSettings Index 0 Read FautoscalingSettings Write SetautoscalingSettings;
  2034. Property dataDisks : TWorkerPoolTypedataDisksArray Index 8 Read FdataDisks Write SetdataDisks;
  2035. Property defaultPackageSet : String Index 16 Read FdefaultPackageSet Write SetdefaultPackageSet;
  2036. Property diskSizeGb : integer Index 24 Read FdiskSizeGb Write SetdiskSizeGb;
  2037. Property diskSourceImage : String Index 32 Read FdiskSourceImage Write SetdiskSourceImage;
  2038. Property diskType : String Index 40 Read FdiskType Write SetdiskType;
  2039. Property kind : String Index 48 Read Fkind Write Setkind;
  2040. Property machineType : String Index 56 Read FmachineType Write SetmachineType;
  2041. Property metadata : TWorkerPoolTypemetadata Index 64 Read Fmetadata Write Setmetadata;
  2042. Property numWorkers : integer Index 72 Read FnumWorkers Write SetnumWorkers;
  2043. Property onHostMaintenance : String Index 80 Read FonHostMaintenance Write SetonHostMaintenance;
  2044. Property packages : TWorkerPoolTypepackagesArray Index 88 Read Fpackages Write Setpackages;
  2045. Property poolArgs : TWorkerPoolTypepoolArgs Index 96 Read FpoolArgs Write SetpoolArgs;
  2046. Property taskrunnerSettings : TTaskRunnerSettings Index 104 Read FtaskrunnerSettings Write SettaskrunnerSettings;
  2047. Property teardownPolicy : String Index 112 Read FteardownPolicy Write SetteardownPolicy;
  2048. Property zone : String Index 120 Read Fzone Write Setzone;
  2049. end;
  2050. TWorkerPoolClass = Class of TWorkerPool;
  2051. { --------------------------------------------------------------------
  2052. TWorkerSettings
  2053. --------------------------------------------------------------------}
  2054. TWorkerSettings = Class(TGoogleBaseObject)
  2055. Private
  2056. FbaseUrl : String;
  2057. FreportingEnabled : boolean;
  2058. FservicePath : String;
  2059. FshuffleServicePath : String;
  2060. FtempStoragePrefix : String;
  2061. FworkerId : String;
  2062. Protected
  2063. //Property setters
  2064. Procedure SetbaseUrl(AIndex : Integer; const AValue : String); virtual;
  2065. Procedure SetreportingEnabled(AIndex : Integer; AValue : boolean); virtual;
  2066. Procedure SetservicePath(AIndex : Integer; const AValue : String); virtual;
  2067. Procedure SetshuffleServicePath(AIndex : Integer; const AValue : String); virtual;
  2068. Procedure SettempStoragePrefix(AIndex : Integer; const AValue : String); virtual;
  2069. Procedure SetworkerId(AIndex : Integer; const AValue : String); virtual;
  2070. Public
  2071. Published
  2072. Property baseUrl : String Index 0 Read FbaseUrl Write SetbaseUrl;
  2073. Property reportingEnabled : boolean Index 8 Read FreportingEnabled Write SetreportingEnabled;
  2074. Property servicePath : String Index 16 Read FservicePath Write SetservicePath;
  2075. Property shuffleServicePath : String Index 24 Read FshuffleServicePath Write SetshuffleServicePath;
  2076. Property tempStoragePrefix : String Index 32 Read FtempStoragePrefix Write SettempStoragePrefix;
  2077. Property workerId : String Index 40 Read FworkerId Write SetworkerId;
  2078. end;
  2079. TWorkerSettingsClass = Class of TWorkerSettings;
  2080. { --------------------------------------------------------------------
  2081. TWriteInstruction
  2082. --------------------------------------------------------------------}
  2083. TWriteInstruction = Class(TGoogleBaseObject)
  2084. Private
  2085. Finput : TInstructionInput;
  2086. Fsink : TSink;
  2087. Protected
  2088. //Property setters
  2089. Procedure Setinput(AIndex : Integer; AValue : TInstructionInput); virtual;
  2090. Procedure Setsink(AIndex : Integer; AValue : TSink); virtual;
  2091. Public
  2092. Published
  2093. Property input : TInstructionInput Index 0 Read Finput Write Setinput;
  2094. Property sink : TSink Index 8 Read Fsink Write Setsink;
  2095. end;
  2096. TWriteInstructionClass = Class of TWriteInstruction;
  2097. { --------------------------------------------------------------------
  2098. TProjectsJobsMessagesResource
  2099. --------------------------------------------------------------------}
  2100. //Optional query Options for TProjectsJobsMessagesResource, method List
  2101. TProjectsJobsMessagesListOptions = Record
  2102. endTime : String;
  2103. minimumImportance : String;
  2104. pageSize : integer;
  2105. pageToken : String;
  2106. startTime : String;
  2107. end;
  2108. TProjectsJobsMessagesResource = Class(TGoogleResource)
  2109. Public
  2110. Class Function ResourceName : String; override;
  2111. Class Function DefaultAPI : TGoogleAPIClass; override;
  2112. Function List(jobId: string; projectId: string; AQuery : string = '') : TListJobMessagesResponse;
  2113. Function List(jobId: string; projectId: string; AQuery : TProjectsJobsMessageslistOptions) : TListJobMessagesResponse;
  2114. end;
  2115. { --------------------------------------------------------------------
  2116. TProjectsJobsWorkItemsResource
  2117. --------------------------------------------------------------------}
  2118. TProjectsJobsWorkItemsResource = Class(TGoogleResource)
  2119. Public
  2120. Class Function ResourceName : String; override;
  2121. Class Function DefaultAPI : TGoogleAPIClass; override;
  2122. Function Lease(jobId: string; projectId: string; aLeaseWorkItemRequest : TLeaseWorkItemRequest) : TLeaseWorkItemResponse;
  2123. Function ReportStatus(jobId: string; projectId: string; aReportWorkItemStatusRequest : TReportWorkItemStatusRequest) : TReportWorkItemStatusResponse;
  2124. end;
  2125. { --------------------------------------------------------------------
  2126. TProjectsJobsResource
  2127. --------------------------------------------------------------------}
  2128. //Optional query Options for TProjectsJobsResource, method Create
  2129. TProjectsJobsCreateOptions = Record
  2130. replaceJobId : String;
  2131. view : String;
  2132. end;
  2133. //Optional query Options for TProjectsJobsResource, method Get
  2134. TProjectsJobsGetOptions = Record
  2135. view : String;
  2136. end;
  2137. //Optional query Options for TProjectsJobsResource, method GetMetrics
  2138. TProjectsJobsGetMetricsOptions = Record
  2139. startTime : String;
  2140. end;
  2141. //Optional query Options for TProjectsJobsResource, method List
  2142. TProjectsJobsListOptions = Record
  2143. pageSize : integer;
  2144. pageToken : String;
  2145. view : String;
  2146. end;
  2147. TProjectsJobsResource = Class(TGoogleResource)
  2148. Private
  2149. FMessagesInstance : TProjectsJobsMessagesResource;
  2150. FWorkItemsInstance : TProjectsJobsWorkItemsResource;
  2151. Function GetMessagesInstance : TProjectsJobsMessagesResource;virtual;
  2152. Function GetWorkItemsInstance : TProjectsJobsWorkItemsResource;virtual;
  2153. Public
  2154. Class Function ResourceName : String; override;
  2155. Class Function DefaultAPI : TGoogleAPIClass; override;
  2156. Function Create(projectId: string; aJob : TJob; AQuery : string = '') : TJob;overload;
  2157. Function Create(projectId: string; aJob : TJob; AQuery : TProjectsJobscreateOptions) : TJob;overload;
  2158. Function Get(jobId: string; projectId: string; AQuery : string = '') : TJob;
  2159. Function Get(jobId: string; projectId: string; AQuery : TProjectsJobsgetOptions) : TJob;
  2160. Function GetMetrics(jobId: string; projectId: string; AQuery : string = '') : TJobMetrics;
  2161. Function GetMetrics(jobId: string; projectId: string; AQuery : TProjectsJobsgetMetricsOptions) : TJobMetrics;
  2162. Function List(projectId: string; AQuery : string = '') : TListJobsResponse;
  2163. Function List(projectId: string; AQuery : TProjectsJobslistOptions) : TListJobsResponse;
  2164. Function Patch(jobId: string; projectId: string; aJob : TJob) : TJob;
  2165. Function Update(jobId: string; projectId: string; aJob : TJob) : TJob;
  2166. Function CreateMessagesResource(AOwner : TComponent) : TProjectsJobsMessagesResource;virtual;overload;
  2167. Function CreateMessagesResource : TProjectsJobsMessagesResource;virtual;overload;
  2168. Function CreateWorkItemsResource(AOwner : TComponent) : TProjectsJobsWorkItemsResource;virtual;overload;
  2169. Function CreateWorkItemsResource : TProjectsJobsWorkItemsResource;virtual;overload;
  2170. Property MessagesResource : TProjectsJobsMessagesResource Read GetMessagesInstance;
  2171. Property WorkItemsResource : TProjectsJobsWorkItemsResource Read GetWorkItemsInstance;
  2172. end;
  2173. { --------------------------------------------------------------------
  2174. TProjectsResource
  2175. --------------------------------------------------------------------}
  2176. TProjectsResource = Class(TGoogleResource)
  2177. Private
  2178. FJobsMessagesInstance : TProjectsJobsMessagesResource;
  2179. FJobsWorkItemsInstance : TProjectsJobsWorkItemsResource;
  2180. FJobsInstance : TProjectsJobsResource;
  2181. Function GetJobsMessagesInstance : TProjectsJobsMessagesResource;virtual;
  2182. Function GetJobsWorkItemsInstance : TProjectsJobsWorkItemsResource;virtual;
  2183. Function GetJobsInstance : TProjectsJobsResource;virtual;
  2184. Public
  2185. Class Function ResourceName : String; override;
  2186. Class Function DefaultAPI : TGoogleAPIClass; override;
  2187. Function CreateJobsMessagesResource(AOwner : TComponent) : TProjectsJobsMessagesResource;virtual;overload;
  2188. Function CreateJobsMessagesResource : TProjectsJobsMessagesResource;virtual;overload;
  2189. Function CreateJobsWorkItemsResource(AOwner : TComponent) : TProjectsJobsWorkItemsResource;virtual;overload;
  2190. Function CreateJobsWorkItemsResource : TProjectsJobsWorkItemsResource;virtual;overload;
  2191. Function CreateJobsResource(AOwner : TComponent) : TProjectsJobsResource;virtual;overload;
  2192. Function CreateJobsResource : TProjectsJobsResource;virtual;overload;
  2193. Property JobsMessagesResource : TProjectsJobsMessagesResource Read GetJobsMessagesInstance;
  2194. Property JobsWorkItemsResource : TProjectsJobsWorkItemsResource Read GetJobsWorkItemsInstance;
  2195. Property JobsResource : TProjectsJobsResource Read GetJobsInstance;
  2196. end;
  2197. { --------------------------------------------------------------------
  2198. TDataflowAPI
  2199. --------------------------------------------------------------------}
  2200. TDataflowAPI = Class(TGoogleAPI)
  2201. Private
  2202. FProjectsJobsMessagesInstance : TProjectsJobsMessagesResource;
  2203. FProjectsJobsWorkItemsInstance : TProjectsJobsWorkItemsResource;
  2204. FProjectsJobsInstance : TProjectsJobsResource;
  2205. FProjectsInstance : TProjectsResource;
  2206. Function GetProjectsJobsMessagesInstance : TProjectsJobsMessagesResource;virtual;
  2207. Function GetProjectsJobsWorkItemsInstance : TProjectsJobsWorkItemsResource;virtual;
  2208. Function GetProjectsJobsInstance : TProjectsJobsResource;virtual;
  2209. Function GetProjectsInstance : TProjectsResource;virtual;
  2210. Public
  2211. //Override class functions with API info
  2212. Class Function APIName : String; override;
  2213. Class Function APIVersion : String; override;
  2214. Class Function APIRevision : String; override;
  2215. Class Function APIID : String; override;
  2216. Class Function APITitle : String; override;
  2217. Class Function APIDescription : String; override;
  2218. Class Function APIOwnerDomain : String; override;
  2219. Class Function APIOwnerName : String; override;
  2220. Class Function APIIcon16 : String; override;
  2221. Class Function APIIcon32 : String; override;
  2222. Class Function APIdocumentationLink : String; override;
  2223. Class Function APIrootUrl : string; override;
  2224. Class Function APIbasePath : string;override;
  2225. Class Function APIbaseURL : String;override;
  2226. Class Function APIProtocol : string;override;
  2227. Class Function APIservicePath : string;override;
  2228. Class Function APIbatchPath : String;override;
  2229. Class Function APIAuthScopes : TScopeInfoArray;override;
  2230. Class Function APINeedsAuth : Boolean;override;
  2231. Class Procedure RegisterAPIResources; override;
  2232. //Add create function for resources
  2233. Function CreateProjectsJobsMessagesResource(AOwner : TComponent) : TProjectsJobsMessagesResource;virtual;overload;
  2234. Function CreateProjectsJobsMessagesResource : TProjectsJobsMessagesResource;virtual;overload;
  2235. Function CreateProjectsJobsWorkItemsResource(AOwner : TComponent) : TProjectsJobsWorkItemsResource;virtual;overload;
  2236. Function CreateProjectsJobsWorkItemsResource : TProjectsJobsWorkItemsResource;virtual;overload;
  2237. Function CreateProjectsJobsResource(AOwner : TComponent) : TProjectsJobsResource;virtual;overload;
  2238. Function CreateProjectsJobsResource : TProjectsJobsResource;virtual;overload;
  2239. Function CreateProjectsResource(AOwner : TComponent) : TProjectsResource;virtual;overload;
  2240. Function CreateProjectsResource : TProjectsResource;virtual;overload;
  2241. //Add default on-demand instances for resources
  2242. Property ProjectsJobsMessagesResource : TProjectsJobsMessagesResource Read GetProjectsJobsMessagesInstance;
  2243. Property ProjectsJobsWorkItemsResource : TProjectsJobsWorkItemsResource Read GetProjectsJobsWorkItemsInstance;
  2244. Property ProjectsJobsResource : TProjectsJobsResource Read GetProjectsJobsInstance;
  2245. Property ProjectsResource : TProjectsResource Read GetProjectsInstance;
  2246. end;
  2247. implementation
  2248. { --------------------------------------------------------------------
  2249. TApproximateProgress
  2250. --------------------------------------------------------------------}
  2251. Procedure TApproximateProgress.SetpercentComplete(AIndex : Integer; AValue : integer);
  2252. begin
  2253. If (FpercentComplete=AValue) then exit;
  2254. FpercentComplete:=AValue;
  2255. MarkPropertyChanged(AIndex);
  2256. end;
  2257. Procedure TApproximateProgress.Setposition(AIndex : Integer; AValue : TPosition);
  2258. begin
  2259. If (Fposition=AValue) then exit;
  2260. Fposition:=AValue;
  2261. MarkPropertyChanged(AIndex);
  2262. end;
  2263. Procedure TApproximateProgress.SetremainingTime(AIndex : Integer; const AValue : String);
  2264. begin
  2265. If (FremainingTime=AValue) then exit;
  2266. FremainingTime:=AValue;
  2267. MarkPropertyChanged(AIndex);
  2268. end;
  2269. { --------------------------------------------------------------------
  2270. TAutoscalingSettings
  2271. --------------------------------------------------------------------}
  2272. Procedure TAutoscalingSettings.Setalgorithm(AIndex : Integer; const AValue : String);
  2273. begin
  2274. If (Falgorithm=AValue) then exit;
  2275. Falgorithm:=AValue;
  2276. MarkPropertyChanged(AIndex);
  2277. end;
  2278. Procedure TAutoscalingSettings.SetmaxNumWorkers(AIndex : Integer; AValue : integer);
  2279. begin
  2280. If (FmaxNumWorkers=AValue) then exit;
  2281. FmaxNumWorkers:=AValue;
  2282. MarkPropertyChanged(AIndex);
  2283. end;
  2284. { --------------------------------------------------------------------
  2285. TComputationTopology
  2286. --------------------------------------------------------------------}
  2287. Procedure TComputationTopology.SetcomputationId(AIndex : Integer; const AValue : String);
  2288. begin
  2289. If (FcomputationId=AValue) then exit;
  2290. FcomputationId:=AValue;
  2291. MarkPropertyChanged(AIndex);
  2292. end;
  2293. Procedure TComputationTopology.Setinputs(AIndex : Integer; AValue : TComputationTopologyTypeinputsArray);
  2294. begin
  2295. If (Finputs=AValue) then exit;
  2296. Finputs:=AValue;
  2297. MarkPropertyChanged(AIndex);
  2298. end;
  2299. Procedure TComputationTopology.SetkeyRanges(AIndex : Integer; AValue : TComputationTopologyTypekeyRangesArray);
  2300. begin
  2301. If (FkeyRanges=AValue) then exit;
  2302. FkeyRanges:=AValue;
  2303. MarkPropertyChanged(AIndex);
  2304. end;
  2305. Procedure TComputationTopology.Setoutputs(AIndex : Integer; AValue : TComputationTopologyTypeoutputsArray);
  2306. begin
  2307. If (Foutputs=AValue) then exit;
  2308. Foutputs:=AValue;
  2309. MarkPropertyChanged(AIndex);
  2310. end;
  2311. //2.6.4. bug workaround
  2312. {$IFDEF VER2_6}
  2313. Procedure TComputationTopology.SetArrayLength(Const AName : String; ALength : Longint);
  2314. begin
  2315. Case AName of
  2316. 'inputs' : SetLength(Finputs,ALength);
  2317. 'keyranges' : SetLength(FkeyRanges,ALength);
  2318. 'outputs' : SetLength(Foutputs,ALength);
  2319. else
  2320. Inherited SetArrayLength(AName,ALength);
  2321. end;
  2322. end;
  2323. {$ENDIF VER2_6}
  2324. { --------------------------------------------------------------------
  2325. TDataDiskAssignment
  2326. --------------------------------------------------------------------}
  2327. Procedure TDataDiskAssignment.SetdataDisks(AIndex : Integer; AValue : TStringArray);
  2328. begin
  2329. If (FdataDisks=AValue) then exit;
  2330. FdataDisks:=AValue;
  2331. MarkPropertyChanged(AIndex);
  2332. end;
  2333. Procedure TDataDiskAssignment.SetvmInstance(AIndex : Integer; const AValue : String);
  2334. begin
  2335. If (FvmInstance=AValue) then exit;
  2336. FvmInstance:=AValue;
  2337. MarkPropertyChanged(AIndex);
  2338. end;
  2339. //2.6.4. bug workaround
  2340. {$IFDEF VER2_6}
  2341. Procedure TDataDiskAssignment.SetArrayLength(Const AName : String; ALength : Longint);
  2342. begin
  2343. Case AName of
  2344. 'datadisks' : SetLength(FdataDisks,ALength);
  2345. else
  2346. Inherited SetArrayLength(AName,ALength);
  2347. end;
  2348. end;
  2349. {$ENDIF VER2_6}
  2350. { --------------------------------------------------------------------
  2351. TDerivedSource
  2352. --------------------------------------------------------------------}
  2353. Procedure TDerivedSource.SetderivationMode(AIndex : Integer; const AValue : String);
  2354. begin
  2355. If (FderivationMode=AValue) then exit;
  2356. FderivationMode:=AValue;
  2357. MarkPropertyChanged(AIndex);
  2358. end;
  2359. Procedure TDerivedSource.Setsource(AIndex : Integer; AValue : TSource);
  2360. begin
  2361. If (Fsource=AValue) then exit;
  2362. Fsource:=AValue;
  2363. MarkPropertyChanged(AIndex);
  2364. end;
  2365. { --------------------------------------------------------------------
  2366. TDisk
  2367. --------------------------------------------------------------------}
  2368. Procedure TDisk.SetdiskType(AIndex : Integer; const AValue : String);
  2369. begin
  2370. If (FdiskType=AValue) then exit;
  2371. FdiskType:=AValue;
  2372. MarkPropertyChanged(AIndex);
  2373. end;
  2374. Procedure TDisk.SetmountPoint(AIndex : Integer; const AValue : String);
  2375. begin
  2376. If (FmountPoint=AValue) then exit;
  2377. FmountPoint:=AValue;
  2378. MarkPropertyChanged(AIndex);
  2379. end;
  2380. Procedure TDisk.SetsizeGb(AIndex : Integer; AValue : integer);
  2381. begin
  2382. If (FsizeGb=AValue) then exit;
  2383. FsizeGb:=AValue;
  2384. MarkPropertyChanged(AIndex);
  2385. end;
  2386. { --------------------------------------------------------------------
  2387. TDynamicSourceSplit
  2388. --------------------------------------------------------------------}
  2389. Procedure TDynamicSourceSplit.Setprimary(AIndex : Integer; AValue : TDerivedSource);
  2390. begin
  2391. If (Fprimary=AValue) then exit;
  2392. Fprimary:=AValue;
  2393. MarkPropertyChanged(AIndex);
  2394. end;
  2395. Procedure TDynamicSourceSplit.Setresidual(AIndex : Integer; AValue : TDerivedSource);
  2396. begin
  2397. If (Fresidual=AValue) then exit;
  2398. Fresidual:=AValue;
  2399. MarkPropertyChanged(AIndex);
  2400. end;
  2401. { --------------------------------------------------------------------
  2402. TEnvironmentTypesdkPipelineOptions
  2403. --------------------------------------------------------------------}
  2404. Class Function TEnvironmentTypesdkPipelineOptions.AllowAdditionalProperties : Boolean;
  2405. begin
  2406. Result:=True;
  2407. end;
  2408. { --------------------------------------------------------------------
  2409. TEnvironmentTypeuserAgent
  2410. --------------------------------------------------------------------}
  2411. Class Function TEnvironmentTypeuserAgent.AllowAdditionalProperties : Boolean;
  2412. begin
  2413. Result:=True;
  2414. end;
  2415. { --------------------------------------------------------------------
  2416. TEnvironmentTypeversion
  2417. --------------------------------------------------------------------}
  2418. Class Function TEnvironmentTypeversion.AllowAdditionalProperties : Boolean;
  2419. begin
  2420. Result:=True;
  2421. end;
  2422. { --------------------------------------------------------------------
  2423. TEnvironment
  2424. --------------------------------------------------------------------}
  2425. Procedure TEnvironment.SetclusterManagerApiService(AIndex : Integer; const AValue : String);
  2426. begin
  2427. If (FclusterManagerApiService=AValue) then exit;
  2428. FclusterManagerApiService:=AValue;
  2429. MarkPropertyChanged(AIndex);
  2430. end;
  2431. Procedure TEnvironment.Setdataset(AIndex : Integer; const AValue : String);
  2432. begin
  2433. If (Fdataset=AValue) then exit;
  2434. Fdataset:=AValue;
  2435. MarkPropertyChanged(AIndex);
  2436. end;
  2437. Procedure TEnvironment.Setexperiments(AIndex : Integer; AValue : TStringArray);
  2438. begin
  2439. If (Fexperiments=AValue) then exit;
  2440. Fexperiments:=AValue;
  2441. MarkPropertyChanged(AIndex);
  2442. end;
  2443. Procedure TEnvironment.SetsdkPipelineOptions(AIndex : Integer; AValue : TEnvironmentTypesdkPipelineOptions);
  2444. begin
  2445. If (FsdkPipelineOptions=AValue) then exit;
  2446. FsdkPipelineOptions:=AValue;
  2447. MarkPropertyChanged(AIndex);
  2448. end;
  2449. Procedure TEnvironment.SettempStoragePrefix(AIndex : Integer; const AValue : String);
  2450. begin
  2451. If (FtempStoragePrefix=AValue) then exit;
  2452. FtempStoragePrefix:=AValue;
  2453. MarkPropertyChanged(AIndex);
  2454. end;
  2455. Procedure TEnvironment.SetuserAgent(AIndex : Integer; AValue : TEnvironmentTypeuserAgent);
  2456. begin
  2457. If (FuserAgent=AValue) then exit;
  2458. FuserAgent:=AValue;
  2459. MarkPropertyChanged(AIndex);
  2460. end;
  2461. Procedure TEnvironment.Setversion(AIndex : Integer; AValue : TEnvironmentTypeversion);
  2462. begin
  2463. If (Fversion=AValue) then exit;
  2464. Fversion:=AValue;
  2465. MarkPropertyChanged(AIndex);
  2466. end;
  2467. Procedure TEnvironment.SetworkerPools(AIndex : Integer; AValue : TEnvironmentTypeworkerPoolsArray);
  2468. begin
  2469. If (FworkerPools=AValue) then exit;
  2470. FworkerPools:=AValue;
  2471. MarkPropertyChanged(AIndex);
  2472. end;
  2473. //2.6.4. bug workaround
  2474. {$IFDEF VER2_6}
  2475. Procedure TEnvironment.SetArrayLength(Const AName : String; ALength : Longint);
  2476. begin
  2477. Case AName of
  2478. 'experiments' : SetLength(Fexperiments,ALength);
  2479. 'workerpools' : SetLength(FworkerPools,ALength);
  2480. else
  2481. Inherited SetArrayLength(AName,ALength);
  2482. end;
  2483. end;
  2484. {$ENDIF VER2_6}
  2485. { --------------------------------------------------------------------
  2486. TFlattenInstruction
  2487. --------------------------------------------------------------------}
  2488. Procedure TFlattenInstruction.Setinputs(AIndex : Integer; AValue : TFlattenInstructionTypeinputsArray);
  2489. begin
  2490. If (Finputs=AValue) then exit;
  2491. Finputs:=AValue;
  2492. MarkPropertyChanged(AIndex);
  2493. end;
  2494. //2.6.4. bug workaround
  2495. {$IFDEF VER2_6}
  2496. Procedure TFlattenInstruction.SetArrayLength(Const AName : String; ALength : Longint);
  2497. begin
  2498. Case AName of
  2499. 'inputs' : SetLength(Finputs,ALength);
  2500. else
  2501. Inherited SetArrayLength(AName,ALength);
  2502. end;
  2503. end;
  2504. {$ENDIF VER2_6}
  2505. { --------------------------------------------------------------------
  2506. TInstructionInput
  2507. --------------------------------------------------------------------}
  2508. Procedure TInstructionInput.SetoutputNum(AIndex : Integer; AValue : integer);
  2509. begin
  2510. If (FoutputNum=AValue) then exit;
  2511. FoutputNum:=AValue;
  2512. MarkPropertyChanged(AIndex);
  2513. end;
  2514. Procedure TInstructionInput.SetproducerInstructionIndex(AIndex : Integer; AValue : integer);
  2515. begin
  2516. If (FproducerInstructionIndex=AValue) then exit;
  2517. FproducerInstructionIndex:=AValue;
  2518. MarkPropertyChanged(AIndex);
  2519. end;
  2520. { --------------------------------------------------------------------
  2521. TInstructionOutputTypecodec
  2522. --------------------------------------------------------------------}
  2523. Class Function TInstructionOutputTypecodec.AllowAdditionalProperties : Boolean;
  2524. begin
  2525. Result:=True;
  2526. end;
  2527. { --------------------------------------------------------------------
  2528. TInstructionOutput
  2529. --------------------------------------------------------------------}
  2530. Procedure TInstructionOutput.Setcodec(AIndex : Integer; AValue : TInstructionOutputTypecodec);
  2531. begin
  2532. If (Fcodec=AValue) then exit;
  2533. Fcodec:=AValue;
  2534. MarkPropertyChanged(AIndex);
  2535. end;
  2536. Procedure TInstructionOutput.Setname(AIndex : Integer; const AValue : String);
  2537. begin
  2538. If (Fname=AValue) then exit;
  2539. Fname:=AValue;
  2540. MarkPropertyChanged(AIndex);
  2541. end;
  2542. { --------------------------------------------------------------------
  2543. TJob
  2544. --------------------------------------------------------------------}
  2545. Procedure TJob.SetcreateTime(AIndex : Integer; const AValue : String);
  2546. begin
  2547. If (FcreateTime=AValue) then exit;
  2548. FcreateTime:=AValue;
  2549. MarkPropertyChanged(AIndex);
  2550. end;
  2551. Procedure TJob.SetcurrentState(AIndex : Integer; const AValue : String);
  2552. begin
  2553. If (FcurrentState=AValue) then exit;
  2554. FcurrentState:=AValue;
  2555. MarkPropertyChanged(AIndex);
  2556. end;
  2557. Procedure TJob.SetcurrentStateTime(AIndex : Integer; const AValue : String);
  2558. begin
  2559. If (FcurrentStateTime=AValue) then exit;
  2560. FcurrentStateTime:=AValue;
  2561. MarkPropertyChanged(AIndex);
  2562. end;
  2563. Procedure TJob.Setenvironment(AIndex : Integer; AValue : TEnvironment);
  2564. begin
  2565. If (Fenvironment=AValue) then exit;
  2566. Fenvironment:=AValue;
  2567. MarkPropertyChanged(AIndex);
  2568. end;
  2569. Procedure TJob.SetexecutionInfo(AIndex : Integer; AValue : TJobExecutionInfo);
  2570. begin
  2571. If (FexecutionInfo=AValue) then exit;
  2572. FexecutionInfo:=AValue;
  2573. MarkPropertyChanged(AIndex);
  2574. end;
  2575. Procedure TJob.Setid(AIndex : Integer; const AValue : String);
  2576. begin
  2577. If (Fid=AValue) then exit;
  2578. Fid:=AValue;
  2579. MarkPropertyChanged(AIndex);
  2580. end;
  2581. Procedure TJob.Setname(AIndex : Integer; const AValue : String);
  2582. begin
  2583. If (Fname=AValue) then exit;
  2584. Fname:=AValue;
  2585. MarkPropertyChanged(AIndex);
  2586. end;
  2587. Procedure TJob.SetprojectId(AIndex : Integer; const AValue : String);
  2588. begin
  2589. If (FprojectId=AValue) then exit;
  2590. FprojectId:=AValue;
  2591. MarkPropertyChanged(AIndex);
  2592. end;
  2593. Procedure TJob.SetrequestedState(AIndex : Integer; const AValue : String);
  2594. begin
  2595. If (FrequestedState=AValue) then exit;
  2596. FrequestedState:=AValue;
  2597. MarkPropertyChanged(AIndex);
  2598. end;
  2599. Procedure TJob.Setsteps(AIndex : Integer; AValue : TJobTypestepsArray);
  2600. begin
  2601. If (Fsteps=AValue) then exit;
  2602. Fsteps:=AValue;
  2603. MarkPropertyChanged(AIndex);
  2604. end;
  2605. Procedure TJob.Set_type(AIndex : Integer; const AValue : String);
  2606. begin
  2607. If (F_type=AValue) then exit;
  2608. F_type:=AValue;
  2609. MarkPropertyChanged(AIndex);
  2610. end;
  2611. Class Function TJob.ExportPropertyName(Const AName : String) :String;
  2612. begin
  2613. Case AName of
  2614. '_type' : Result:='type';
  2615. else
  2616. Result:=Inherited ExportPropertyName(AName);
  2617. end;
  2618. end;
  2619. //2.6.4. bug workaround
  2620. {$IFDEF VER2_6}
  2621. Procedure TJob.SetArrayLength(Const AName : String; ALength : Longint);
  2622. begin
  2623. Case AName of
  2624. 'steps' : SetLength(Fsteps,ALength);
  2625. else
  2626. Inherited SetArrayLength(AName,ALength);
  2627. end;
  2628. end;
  2629. {$ENDIF VER2_6}
  2630. { --------------------------------------------------------------------
  2631. TJobExecutionInfoTypestages
  2632. --------------------------------------------------------------------}
  2633. Class Function TJobExecutionInfoTypestages.AllowAdditionalProperties : Boolean;
  2634. begin
  2635. Result:=True;
  2636. end;
  2637. { --------------------------------------------------------------------
  2638. TJobExecutionInfo
  2639. --------------------------------------------------------------------}
  2640. Procedure TJobExecutionInfo.Setstages(AIndex : Integer; AValue : TJobExecutionInfoTypestages);
  2641. begin
  2642. If (Fstages=AValue) then exit;
  2643. Fstages:=AValue;
  2644. MarkPropertyChanged(AIndex);
  2645. end;
  2646. { --------------------------------------------------------------------
  2647. TJobExecutionStageInfo
  2648. --------------------------------------------------------------------}
  2649. Procedure TJobExecutionStageInfo.SetstepName(AIndex : Integer; AValue : TStringArray);
  2650. begin
  2651. If (FstepName=AValue) then exit;
  2652. FstepName:=AValue;
  2653. MarkPropertyChanged(AIndex);
  2654. end;
  2655. //2.6.4. bug workaround
  2656. {$IFDEF VER2_6}
  2657. Procedure TJobExecutionStageInfo.SetArrayLength(Const AName : String; ALength : Longint);
  2658. begin
  2659. Case AName of
  2660. 'stepname' : SetLength(FstepName,ALength);
  2661. else
  2662. Inherited SetArrayLength(AName,ALength);
  2663. end;
  2664. end;
  2665. {$ENDIF VER2_6}
  2666. { --------------------------------------------------------------------
  2667. TJobMessage
  2668. --------------------------------------------------------------------}
  2669. Procedure TJobMessage.Setid(AIndex : Integer; const AValue : String);
  2670. begin
  2671. If (Fid=AValue) then exit;
  2672. Fid:=AValue;
  2673. MarkPropertyChanged(AIndex);
  2674. end;
  2675. Procedure TJobMessage.SetmessageImportance(AIndex : Integer; const AValue : String);
  2676. begin
  2677. If (FmessageImportance=AValue) then exit;
  2678. FmessageImportance:=AValue;
  2679. MarkPropertyChanged(AIndex);
  2680. end;
  2681. Procedure TJobMessage.SetmessageText(AIndex : Integer; const AValue : String);
  2682. begin
  2683. If (FmessageText=AValue) then exit;
  2684. FmessageText:=AValue;
  2685. MarkPropertyChanged(AIndex);
  2686. end;
  2687. Procedure TJobMessage.Settime(AIndex : Integer; const AValue : String);
  2688. begin
  2689. If (Ftime=AValue) then exit;
  2690. Ftime:=AValue;
  2691. MarkPropertyChanged(AIndex);
  2692. end;
  2693. { --------------------------------------------------------------------
  2694. TJobMetrics
  2695. --------------------------------------------------------------------}
  2696. Procedure TJobMetrics.SetmetricTime(AIndex : Integer; const AValue : String);
  2697. begin
  2698. If (FmetricTime=AValue) then exit;
  2699. FmetricTime:=AValue;
  2700. MarkPropertyChanged(AIndex);
  2701. end;
  2702. Procedure TJobMetrics.Setmetrics(AIndex : Integer; AValue : TJobMetricsTypemetricsArray);
  2703. begin
  2704. If (Fmetrics=AValue) then exit;
  2705. Fmetrics:=AValue;
  2706. MarkPropertyChanged(AIndex);
  2707. end;
  2708. //2.6.4. bug workaround
  2709. {$IFDEF VER2_6}
  2710. Procedure TJobMetrics.SetArrayLength(Const AName : String; ALength : Longint);
  2711. begin
  2712. Case AName of
  2713. 'metrics' : SetLength(Fmetrics,ALength);
  2714. else
  2715. Inherited SetArrayLength(AName,ALength);
  2716. end;
  2717. end;
  2718. {$ENDIF VER2_6}
  2719. { --------------------------------------------------------------------
  2720. TKeyRangeDataDiskAssignment
  2721. --------------------------------------------------------------------}
  2722. Procedure TKeyRangeDataDiskAssignment.SetdataDisk(AIndex : Integer; const AValue : String);
  2723. begin
  2724. If (FdataDisk=AValue) then exit;
  2725. FdataDisk:=AValue;
  2726. MarkPropertyChanged(AIndex);
  2727. end;
  2728. Procedure TKeyRangeDataDiskAssignment.Set_end(AIndex : Integer; const AValue : String);
  2729. begin
  2730. If (F_end=AValue) then exit;
  2731. F_end:=AValue;
  2732. MarkPropertyChanged(AIndex);
  2733. end;
  2734. Procedure TKeyRangeDataDiskAssignment.Setstart(AIndex : Integer; const AValue : String);
  2735. begin
  2736. If (Fstart=AValue) then exit;
  2737. Fstart:=AValue;
  2738. MarkPropertyChanged(AIndex);
  2739. end;
  2740. Class Function TKeyRangeDataDiskAssignment.ExportPropertyName(Const AName : String) :String;
  2741. begin
  2742. Case AName of
  2743. '_end' : Result:='end';
  2744. else
  2745. Result:=Inherited ExportPropertyName(AName);
  2746. end;
  2747. end;
  2748. { --------------------------------------------------------------------
  2749. TKeyRangeLocation
  2750. --------------------------------------------------------------------}
  2751. Procedure TKeyRangeLocation.SetdataDisk(AIndex : Integer; const AValue : String);
  2752. begin
  2753. If (FdataDisk=AValue) then exit;
  2754. FdataDisk:=AValue;
  2755. MarkPropertyChanged(AIndex);
  2756. end;
  2757. Procedure TKeyRangeLocation.SetdeliveryEndpoint(AIndex : Integer; const AValue : String);
  2758. begin
  2759. If (FdeliveryEndpoint=AValue) then exit;
  2760. FdeliveryEndpoint:=AValue;
  2761. MarkPropertyChanged(AIndex);
  2762. end;
  2763. Procedure TKeyRangeLocation.Set_end(AIndex : Integer; const AValue : String);
  2764. begin
  2765. If (F_end=AValue) then exit;
  2766. F_end:=AValue;
  2767. MarkPropertyChanged(AIndex);
  2768. end;
  2769. Procedure TKeyRangeLocation.SetpersistentDirectory(AIndex : Integer; const AValue : String);
  2770. begin
  2771. If (FpersistentDirectory=AValue) then exit;
  2772. FpersistentDirectory:=AValue;
  2773. MarkPropertyChanged(AIndex);
  2774. end;
  2775. Procedure TKeyRangeLocation.Setstart(AIndex : Integer; const AValue : String);
  2776. begin
  2777. If (Fstart=AValue) then exit;
  2778. Fstart:=AValue;
  2779. MarkPropertyChanged(AIndex);
  2780. end;
  2781. Class Function TKeyRangeLocation.ExportPropertyName(Const AName : String) :String;
  2782. begin
  2783. Case AName of
  2784. '_end' : Result:='end';
  2785. else
  2786. Result:=Inherited ExportPropertyName(AName);
  2787. end;
  2788. end;
  2789. { --------------------------------------------------------------------
  2790. TLeaseWorkItemRequest
  2791. --------------------------------------------------------------------}
  2792. Procedure TLeaseWorkItemRequest.SetcurrentWorkerTime(AIndex : Integer; const AValue : String);
  2793. begin
  2794. If (FcurrentWorkerTime=AValue) then exit;
  2795. FcurrentWorkerTime:=AValue;
  2796. MarkPropertyChanged(AIndex);
  2797. end;
  2798. Procedure TLeaseWorkItemRequest.SetrequestedLeaseDuration(AIndex : Integer; const AValue : String);
  2799. begin
  2800. If (FrequestedLeaseDuration=AValue) then exit;
  2801. FrequestedLeaseDuration:=AValue;
  2802. MarkPropertyChanged(AIndex);
  2803. end;
  2804. Procedure TLeaseWorkItemRequest.SetworkItemTypes(AIndex : Integer; AValue : TStringArray);
  2805. begin
  2806. If (FworkItemTypes=AValue) then exit;
  2807. FworkItemTypes:=AValue;
  2808. MarkPropertyChanged(AIndex);
  2809. end;
  2810. Procedure TLeaseWorkItemRequest.SetworkerCapabilities(AIndex : Integer; AValue : TStringArray);
  2811. begin
  2812. If (FworkerCapabilities=AValue) then exit;
  2813. FworkerCapabilities:=AValue;
  2814. MarkPropertyChanged(AIndex);
  2815. end;
  2816. Procedure TLeaseWorkItemRequest.SetworkerId(AIndex : Integer; const AValue : String);
  2817. begin
  2818. If (FworkerId=AValue) then exit;
  2819. FworkerId:=AValue;
  2820. MarkPropertyChanged(AIndex);
  2821. end;
  2822. //2.6.4. bug workaround
  2823. {$IFDEF VER2_6}
  2824. Procedure TLeaseWorkItemRequest.SetArrayLength(Const AName : String; ALength : Longint);
  2825. begin
  2826. Case AName of
  2827. 'workitemtypes' : SetLength(FworkItemTypes,ALength);
  2828. 'workercapabilities' : SetLength(FworkerCapabilities,ALength);
  2829. else
  2830. Inherited SetArrayLength(AName,ALength);
  2831. end;
  2832. end;
  2833. {$ENDIF VER2_6}
  2834. { --------------------------------------------------------------------
  2835. TLeaseWorkItemResponse
  2836. --------------------------------------------------------------------}
  2837. Procedure TLeaseWorkItemResponse.SetworkItems(AIndex : Integer; AValue : TLeaseWorkItemResponseTypeworkItemsArray);
  2838. begin
  2839. If (FworkItems=AValue) then exit;
  2840. FworkItems:=AValue;
  2841. MarkPropertyChanged(AIndex);
  2842. end;
  2843. //2.6.4. bug workaround
  2844. {$IFDEF VER2_6}
  2845. Procedure TLeaseWorkItemResponse.SetArrayLength(Const AName : String; ALength : Longint);
  2846. begin
  2847. Case AName of
  2848. 'workitems' : SetLength(FworkItems,ALength);
  2849. else
  2850. Inherited SetArrayLength(AName,ALength);
  2851. end;
  2852. end;
  2853. {$ENDIF VER2_6}
  2854. { --------------------------------------------------------------------
  2855. TListJobMessagesResponse
  2856. --------------------------------------------------------------------}
  2857. Procedure TListJobMessagesResponse.SetjobMessages(AIndex : Integer; AValue : TListJobMessagesResponseTypejobMessagesArray);
  2858. begin
  2859. If (FjobMessages=AValue) then exit;
  2860. FjobMessages:=AValue;
  2861. MarkPropertyChanged(AIndex);
  2862. end;
  2863. Procedure TListJobMessagesResponse.SetnextPageToken(AIndex : Integer; const AValue : String);
  2864. begin
  2865. If (FnextPageToken=AValue) then exit;
  2866. FnextPageToken:=AValue;
  2867. MarkPropertyChanged(AIndex);
  2868. end;
  2869. //2.6.4. bug workaround
  2870. {$IFDEF VER2_6}
  2871. Procedure TListJobMessagesResponse.SetArrayLength(Const AName : String; ALength : Longint);
  2872. begin
  2873. Case AName of
  2874. 'jobmessages' : SetLength(FjobMessages,ALength);
  2875. else
  2876. Inherited SetArrayLength(AName,ALength);
  2877. end;
  2878. end;
  2879. {$ENDIF VER2_6}
  2880. { --------------------------------------------------------------------
  2881. TListJobsResponse
  2882. --------------------------------------------------------------------}
  2883. Procedure TListJobsResponse.Setjobs(AIndex : Integer; AValue : TListJobsResponseTypejobsArray);
  2884. begin
  2885. If (Fjobs=AValue) then exit;
  2886. Fjobs:=AValue;
  2887. MarkPropertyChanged(AIndex);
  2888. end;
  2889. Procedure TListJobsResponse.SetnextPageToken(AIndex : Integer; const AValue : String);
  2890. begin
  2891. If (FnextPageToken=AValue) then exit;
  2892. FnextPageToken:=AValue;
  2893. MarkPropertyChanged(AIndex);
  2894. end;
  2895. //2.6.4. bug workaround
  2896. {$IFDEF VER2_6}
  2897. Procedure TListJobsResponse.SetArrayLength(Const AName : String; ALength : Longint);
  2898. begin
  2899. Case AName of
  2900. 'jobs' : SetLength(Fjobs,ALength);
  2901. else
  2902. Inherited SetArrayLength(AName,ALength);
  2903. end;
  2904. end;
  2905. {$ENDIF VER2_6}
  2906. { --------------------------------------------------------------------
  2907. TMapTask
  2908. --------------------------------------------------------------------}
  2909. Procedure TMapTask.Setinstructions(AIndex : Integer; AValue : TMapTaskTypeinstructionsArray);
  2910. begin
  2911. If (Finstructions=AValue) then exit;
  2912. Finstructions:=AValue;
  2913. MarkPropertyChanged(AIndex);
  2914. end;
  2915. Procedure TMapTask.SetstageName(AIndex : Integer; const AValue : String);
  2916. begin
  2917. If (FstageName=AValue) then exit;
  2918. FstageName:=AValue;
  2919. MarkPropertyChanged(AIndex);
  2920. end;
  2921. Procedure TMapTask.SetsystemName(AIndex : Integer; const AValue : String);
  2922. begin
  2923. If (FsystemName=AValue) then exit;
  2924. FsystemName:=AValue;
  2925. MarkPropertyChanged(AIndex);
  2926. end;
  2927. //2.6.4. bug workaround
  2928. {$IFDEF VER2_6}
  2929. Procedure TMapTask.SetArrayLength(Const AName : String; ALength : Longint);
  2930. begin
  2931. Case AName of
  2932. 'instructions' : SetLength(Finstructions,ALength);
  2933. else
  2934. Inherited SetArrayLength(AName,ALength);
  2935. end;
  2936. end;
  2937. {$ENDIF VER2_6}
  2938. { --------------------------------------------------------------------
  2939. TMetricStructuredNameTypecontext
  2940. --------------------------------------------------------------------}
  2941. Class Function TMetricStructuredNameTypecontext.AllowAdditionalProperties : Boolean;
  2942. begin
  2943. Result:=True;
  2944. end;
  2945. { --------------------------------------------------------------------
  2946. TMetricStructuredName
  2947. --------------------------------------------------------------------}
  2948. Procedure TMetricStructuredName.Setcontext(AIndex : Integer; AValue : TMetricStructuredNameTypecontext);
  2949. begin
  2950. If (Fcontext=AValue) then exit;
  2951. Fcontext:=AValue;
  2952. MarkPropertyChanged(AIndex);
  2953. end;
  2954. Procedure TMetricStructuredName.Setname(AIndex : Integer; const AValue : String);
  2955. begin
  2956. If (Fname=AValue) then exit;
  2957. Fname:=AValue;
  2958. MarkPropertyChanged(AIndex);
  2959. end;
  2960. Procedure TMetricStructuredName.Setorigin(AIndex : Integer; const AValue : String);
  2961. begin
  2962. If (Forigin=AValue) then exit;
  2963. Forigin:=AValue;
  2964. MarkPropertyChanged(AIndex);
  2965. end;
  2966. { --------------------------------------------------------------------
  2967. TMetricUpdate
  2968. --------------------------------------------------------------------}
  2969. Procedure TMetricUpdate.Setcumulative(AIndex : Integer; AValue : boolean);
  2970. begin
  2971. If (Fcumulative=AValue) then exit;
  2972. Fcumulative:=AValue;
  2973. MarkPropertyChanged(AIndex);
  2974. end;
  2975. Procedure TMetricUpdate.Setinternal(AIndex : Integer; AValue : TGoogleprotobufValue);
  2976. begin
  2977. If (Finternal=AValue) then exit;
  2978. Finternal:=AValue;
  2979. MarkPropertyChanged(AIndex);
  2980. end;
  2981. Procedure TMetricUpdate.Setkind(AIndex : Integer; const AValue : String);
  2982. begin
  2983. If (Fkind=AValue) then exit;
  2984. Fkind:=AValue;
  2985. MarkPropertyChanged(AIndex);
  2986. end;
  2987. Procedure TMetricUpdate.SetmeanCount(AIndex : Integer; AValue : TGoogleprotobufValue);
  2988. begin
  2989. If (FmeanCount=AValue) then exit;
  2990. FmeanCount:=AValue;
  2991. MarkPropertyChanged(AIndex);
  2992. end;
  2993. Procedure TMetricUpdate.SetmeanSum(AIndex : Integer; AValue : TGoogleprotobufValue);
  2994. begin
  2995. If (FmeanSum=AValue) then exit;
  2996. FmeanSum:=AValue;
  2997. MarkPropertyChanged(AIndex);
  2998. end;
  2999. Procedure TMetricUpdate.Setname(AIndex : Integer; AValue : TMetricStructuredName);
  3000. begin
  3001. If (Fname=AValue) then exit;
  3002. Fname:=AValue;
  3003. MarkPropertyChanged(AIndex);
  3004. end;
  3005. Procedure TMetricUpdate.Setscalar(AIndex : Integer; AValue : TGoogleprotobufValue);
  3006. begin
  3007. If (Fscalar=AValue) then exit;
  3008. Fscalar:=AValue;
  3009. MarkPropertyChanged(AIndex);
  3010. end;
  3011. Procedure TMetricUpdate.Set_set(AIndex : Integer; AValue : TGoogleprotobufValue);
  3012. begin
  3013. If (F_set=AValue) then exit;
  3014. F_set:=AValue;
  3015. MarkPropertyChanged(AIndex);
  3016. end;
  3017. Procedure TMetricUpdate.SetupdateTime(AIndex : Integer; const AValue : String);
  3018. begin
  3019. If (FupdateTime=AValue) then exit;
  3020. FupdateTime:=AValue;
  3021. MarkPropertyChanged(AIndex);
  3022. end;
  3023. Class Function TMetricUpdate.ExportPropertyName(Const AName : String) :String;
  3024. begin
  3025. Case AName of
  3026. '_set' : Result:='set';
  3027. else
  3028. Result:=Inherited ExportPropertyName(AName);
  3029. end;
  3030. end;
  3031. { --------------------------------------------------------------------
  3032. TMountedDataDisk
  3033. --------------------------------------------------------------------}
  3034. Procedure TMountedDataDisk.SetdataDisk(AIndex : Integer; const AValue : String);
  3035. begin
  3036. If (FdataDisk=AValue) then exit;
  3037. FdataDisk:=AValue;
  3038. MarkPropertyChanged(AIndex);
  3039. end;
  3040. { --------------------------------------------------------------------
  3041. TMultiOutputInfo
  3042. --------------------------------------------------------------------}
  3043. Procedure TMultiOutputInfo.Settag(AIndex : Integer; const AValue : String);
  3044. begin
  3045. If (Ftag=AValue) then exit;
  3046. Ftag:=AValue;
  3047. MarkPropertyChanged(AIndex);
  3048. end;
  3049. { --------------------------------------------------------------------
  3050. TPackage
  3051. --------------------------------------------------------------------}
  3052. Procedure TPackage.Setlocation(AIndex : Integer; const AValue : String);
  3053. begin
  3054. If (Flocation=AValue) then exit;
  3055. Flocation:=AValue;
  3056. MarkPropertyChanged(AIndex);
  3057. end;
  3058. Procedure TPackage.Setname(AIndex : Integer; const AValue : String);
  3059. begin
  3060. If (Fname=AValue) then exit;
  3061. Fname:=AValue;
  3062. MarkPropertyChanged(AIndex);
  3063. end;
  3064. { --------------------------------------------------------------------
  3065. TParDoInstructionTypeuserFn
  3066. --------------------------------------------------------------------}
  3067. Class Function TParDoInstructionTypeuserFn.AllowAdditionalProperties : Boolean;
  3068. begin
  3069. Result:=True;
  3070. end;
  3071. { --------------------------------------------------------------------
  3072. TParDoInstruction
  3073. --------------------------------------------------------------------}
  3074. Procedure TParDoInstruction.Setinput(AIndex : Integer; AValue : TInstructionInput);
  3075. begin
  3076. If (Finput=AValue) then exit;
  3077. Finput:=AValue;
  3078. MarkPropertyChanged(AIndex);
  3079. end;
  3080. Procedure TParDoInstruction.SetmultiOutputInfos(AIndex : Integer; AValue : TParDoInstructionTypemultiOutputInfosArray);
  3081. begin
  3082. If (FmultiOutputInfos=AValue) then exit;
  3083. FmultiOutputInfos:=AValue;
  3084. MarkPropertyChanged(AIndex);
  3085. end;
  3086. Procedure TParDoInstruction.SetnumOutputs(AIndex : Integer; AValue : integer);
  3087. begin
  3088. If (FnumOutputs=AValue) then exit;
  3089. FnumOutputs:=AValue;
  3090. MarkPropertyChanged(AIndex);
  3091. end;
  3092. Procedure TParDoInstruction.SetsideInputs(AIndex : Integer; AValue : TParDoInstructionTypesideInputsArray);
  3093. begin
  3094. If (FsideInputs=AValue) then exit;
  3095. FsideInputs:=AValue;
  3096. MarkPropertyChanged(AIndex);
  3097. end;
  3098. Procedure TParDoInstruction.SetuserFn(AIndex : Integer; AValue : TParDoInstructionTypeuserFn);
  3099. begin
  3100. If (FuserFn=AValue) then exit;
  3101. FuserFn:=AValue;
  3102. MarkPropertyChanged(AIndex);
  3103. end;
  3104. //2.6.4. bug workaround
  3105. {$IFDEF VER2_6}
  3106. Procedure TParDoInstruction.SetArrayLength(Const AName : String; ALength : Longint);
  3107. begin
  3108. Case AName of
  3109. 'multioutputinfos' : SetLength(FmultiOutputInfos,ALength);
  3110. 'sideinputs' : SetLength(FsideInputs,ALength);
  3111. else
  3112. Inherited SetArrayLength(AName,ALength);
  3113. end;
  3114. end;
  3115. {$ENDIF VER2_6}
  3116. { --------------------------------------------------------------------
  3117. TParallelInstruction
  3118. --------------------------------------------------------------------}
  3119. Procedure TParallelInstruction.Setflatten(AIndex : Integer; AValue : TFlattenInstruction);
  3120. begin
  3121. If (Fflatten=AValue) then exit;
  3122. Fflatten:=AValue;
  3123. MarkPropertyChanged(AIndex);
  3124. end;
  3125. Procedure TParallelInstruction.Setname(AIndex : Integer; const AValue : String);
  3126. begin
  3127. If (Fname=AValue) then exit;
  3128. Fname:=AValue;
  3129. MarkPropertyChanged(AIndex);
  3130. end;
  3131. Procedure TParallelInstruction.Setoutputs(AIndex : Integer; AValue : TParallelInstructionTypeoutputsArray);
  3132. begin
  3133. If (Foutputs=AValue) then exit;
  3134. Foutputs:=AValue;
  3135. MarkPropertyChanged(AIndex);
  3136. end;
  3137. Procedure TParallelInstruction.SetparDo(AIndex : Integer; AValue : TParDoInstruction);
  3138. begin
  3139. If (FparDo=AValue) then exit;
  3140. FparDo:=AValue;
  3141. MarkPropertyChanged(AIndex);
  3142. end;
  3143. Procedure TParallelInstruction.SetpartialGroupByKey(AIndex : Integer; AValue : TPartialGroupByKeyInstruction);
  3144. begin
  3145. If (FpartialGroupByKey=AValue) then exit;
  3146. FpartialGroupByKey:=AValue;
  3147. MarkPropertyChanged(AIndex);
  3148. end;
  3149. Procedure TParallelInstruction.Setread(AIndex : Integer; AValue : TReadInstruction);
  3150. begin
  3151. If (Fread=AValue) then exit;
  3152. Fread:=AValue;
  3153. MarkPropertyChanged(AIndex);
  3154. end;
  3155. Procedure TParallelInstruction.SetsystemName(AIndex : Integer; const AValue : String);
  3156. begin
  3157. If (FsystemName=AValue) then exit;
  3158. FsystemName:=AValue;
  3159. MarkPropertyChanged(AIndex);
  3160. end;
  3161. Procedure TParallelInstruction.Setwrite(AIndex : Integer; AValue : TWriteInstruction);
  3162. begin
  3163. If (Fwrite=AValue) then exit;
  3164. Fwrite:=AValue;
  3165. MarkPropertyChanged(AIndex);
  3166. end;
  3167. //2.6.4. bug workaround
  3168. {$IFDEF VER2_6}
  3169. Procedure TParallelInstruction.SetArrayLength(Const AName : String; ALength : Longint);
  3170. begin
  3171. Case AName of
  3172. 'outputs' : SetLength(Foutputs,ALength);
  3173. else
  3174. Inherited SetArrayLength(AName,ALength);
  3175. end;
  3176. end;
  3177. {$ENDIF VER2_6}
  3178. { --------------------------------------------------------------------
  3179. TPartialGroupByKeyInstructionTypeinputElementCodec
  3180. --------------------------------------------------------------------}
  3181. Class Function TPartialGroupByKeyInstructionTypeinputElementCodec.AllowAdditionalProperties : Boolean;
  3182. begin
  3183. Result:=True;
  3184. end;
  3185. { --------------------------------------------------------------------
  3186. TPartialGroupByKeyInstructionTypevalueCombiningFn
  3187. --------------------------------------------------------------------}
  3188. Class Function TPartialGroupByKeyInstructionTypevalueCombiningFn.AllowAdditionalProperties : Boolean;
  3189. begin
  3190. Result:=True;
  3191. end;
  3192. { --------------------------------------------------------------------
  3193. TPartialGroupByKeyInstruction
  3194. --------------------------------------------------------------------}
  3195. Procedure TPartialGroupByKeyInstruction.Setinput(AIndex : Integer; AValue : TInstructionInput);
  3196. begin
  3197. If (Finput=AValue) then exit;
  3198. Finput:=AValue;
  3199. MarkPropertyChanged(AIndex);
  3200. end;
  3201. Procedure TPartialGroupByKeyInstruction.SetinputElementCodec(AIndex : Integer; AValue : TPartialGroupByKeyInstructionTypeinputElementCodec);
  3202. begin
  3203. If (FinputElementCodec=AValue) then exit;
  3204. FinputElementCodec:=AValue;
  3205. MarkPropertyChanged(AIndex);
  3206. end;
  3207. Procedure TPartialGroupByKeyInstruction.SetvalueCombiningFn(AIndex : Integer; AValue : TPartialGroupByKeyInstructionTypevalueCombiningFn);
  3208. begin
  3209. If (FvalueCombiningFn=AValue) then exit;
  3210. FvalueCombiningFn:=AValue;
  3211. MarkPropertyChanged(AIndex);
  3212. end;
  3213. { --------------------------------------------------------------------
  3214. TPosition
  3215. --------------------------------------------------------------------}
  3216. Procedure TPosition.SetbyteOffset(AIndex : Integer; const AValue : String);
  3217. begin
  3218. If (FbyteOffset=AValue) then exit;
  3219. FbyteOffset:=AValue;
  3220. MarkPropertyChanged(AIndex);
  3221. end;
  3222. Procedure TPosition.Set_end(AIndex : Integer; AValue : boolean);
  3223. begin
  3224. If (F_end=AValue) then exit;
  3225. F_end:=AValue;
  3226. MarkPropertyChanged(AIndex);
  3227. end;
  3228. Procedure TPosition.Setkey(AIndex : Integer; const AValue : String);
  3229. begin
  3230. If (Fkey=AValue) then exit;
  3231. Fkey:=AValue;
  3232. MarkPropertyChanged(AIndex);
  3233. end;
  3234. Procedure TPosition.SetrecordIndex(AIndex : Integer; const AValue : String);
  3235. begin
  3236. If (FrecordIndex=AValue) then exit;
  3237. FrecordIndex:=AValue;
  3238. MarkPropertyChanged(AIndex);
  3239. end;
  3240. Procedure TPosition.SetshufflePosition(AIndex : Integer; const AValue : String);
  3241. begin
  3242. If (FshufflePosition=AValue) then exit;
  3243. FshufflePosition:=AValue;
  3244. MarkPropertyChanged(AIndex);
  3245. end;
  3246. Class Function TPosition.ExportPropertyName(Const AName : String) :String;
  3247. begin
  3248. Case AName of
  3249. '_end' : Result:='end';
  3250. else
  3251. Result:=Inherited ExportPropertyName(AName);
  3252. end;
  3253. end;
  3254. { --------------------------------------------------------------------
  3255. TPubsubLocation
  3256. --------------------------------------------------------------------}
  3257. Procedure TPubsubLocation.SetdropLateData(AIndex : Integer; AValue : boolean);
  3258. begin
  3259. If (FdropLateData=AValue) then exit;
  3260. FdropLateData:=AValue;
  3261. MarkPropertyChanged(AIndex);
  3262. end;
  3263. Procedure TPubsubLocation.SetidLabel(AIndex : Integer; const AValue : String);
  3264. begin
  3265. If (FidLabel=AValue) then exit;
  3266. FidLabel:=AValue;
  3267. MarkPropertyChanged(AIndex);
  3268. end;
  3269. Procedure TPubsubLocation.Setsubscription(AIndex : Integer; const AValue : String);
  3270. begin
  3271. If (Fsubscription=AValue) then exit;
  3272. Fsubscription:=AValue;
  3273. MarkPropertyChanged(AIndex);
  3274. end;
  3275. Procedure TPubsubLocation.SettimestampLabel(AIndex : Integer; const AValue : String);
  3276. begin
  3277. If (FtimestampLabel=AValue) then exit;
  3278. FtimestampLabel:=AValue;
  3279. MarkPropertyChanged(AIndex);
  3280. end;
  3281. Procedure TPubsubLocation.Settopic(AIndex : Integer; const AValue : String);
  3282. begin
  3283. If (Ftopic=AValue) then exit;
  3284. Ftopic:=AValue;
  3285. MarkPropertyChanged(AIndex);
  3286. end;
  3287. Procedure TPubsubLocation.SettrackingSubscription(AIndex : Integer; const AValue : String);
  3288. begin
  3289. If (FtrackingSubscription=AValue) then exit;
  3290. FtrackingSubscription:=AValue;
  3291. MarkPropertyChanged(AIndex);
  3292. end;
  3293. { --------------------------------------------------------------------
  3294. TReadInstruction
  3295. --------------------------------------------------------------------}
  3296. Procedure TReadInstruction.Setsource(AIndex : Integer; AValue : TSource);
  3297. begin
  3298. If (Fsource=AValue) then exit;
  3299. Fsource:=AValue;
  3300. MarkPropertyChanged(AIndex);
  3301. end;
  3302. { --------------------------------------------------------------------
  3303. TReportWorkItemStatusRequest
  3304. --------------------------------------------------------------------}
  3305. Procedure TReportWorkItemStatusRequest.SetcurrentWorkerTime(AIndex : Integer; const AValue : String);
  3306. begin
  3307. If (FcurrentWorkerTime=AValue) then exit;
  3308. FcurrentWorkerTime:=AValue;
  3309. MarkPropertyChanged(AIndex);
  3310. end;
  3311. Procedure TReportWorkItemStatusRequest.SetworkItemStatuses(AIndex : Integer; AValue : TReportWorkItemStatusRequestTypeworkItemStatusesArray);
  3312. begin
  3313. If (FworkItemStatuses=AValue) then exit;
  3314. FworkItemStatuses:=AValue;
  3315. MarkPropertyChanged(AIndex);
  3316. end;
  3317. Procedure TReportWorkItemStatusRequest.SetworkerId(AIndex : Integer; const AValue : String);
  3318. begin
  3319. If (FworkerId=AValue) then exit;
  3320. FworkerId:=AValue;
  3321. MarkPropertyChanged(AIndex);
  3322. end;
  3323. //2.6.4. bug workaround
  3324. {$IFDEF VER2_6}
  3325. Procedure TReportWorkItemStatusRequest.SetArrayLength(Const AName : String; ALength : Longint);
  3326. begin
  3327. Case AName of
  3328. 'workitemstatuses' : SetLength(FworkItemStatuses,ALength);
  3329. else
  3330. Inherited SetArrayLength(AName,ALength);
  3331. end;
  3332. end;
  3333. {$ENDIF VER2_6}
  3334. { --------------------------------------------------------------------
  3335. TReportWorkItemStatusResponse
  3336. --------------------------------------------------------------------}
  3337. Procedure TReportWorkItemStatusResponse.SetworkItemServiceStates(AIndex : Integer; AValue : TReportWorkItemStatusResponseTypeworkItemServiceStatesArray);
  3338. begin
  3339. If (FworkItemServiceStates=AValue) then exit;
  3340. FworkItemServiceStates:=AValue;
  3341. MarkPropertyChanged(AIndex);
  3342. end;
  3343. //2.6.4. bug workaround
  3344. {$IFDEF VER2_6}
  3345. Procedure TReportWorkItemStatusResponse.SetArrayLength(Const AName : String; ALength : Longint);
  3346. begin
  3347. Case AName of
  3348. 'workitemservicestates' : SetLength(FworkItemServiceStates,ALength);
  3349. else
  3350. Inherited SetArrayLength(AName,ALength);
  3351. end;
  3352. end;
  3353. {$ENDIF VER2_6}
  3354. { --------------------------------------------------------------------
  3355. TSeqMapTaskTypeuserFn
  3356. --------------------------------------------------------------------}
  3357. Class Function TSeqMapTaskTypeuserFn.AllowAdditionalProperties : Boolean;
  3358. begin
  3359. Result:=True;
  3360. end;
  3361. { --------------------------------------------------------------------
  3362. TSeqMapTask
  3363. --------------------------------------------------------------------}
  3364. Procedure TSeqMapTask.Setinputs(AIndex : Integer; AValue : TSeqMapTaskTypeinputsArray);
  3365. begin
  3366. If (Finputs=AValue) then exit;
  3367. Finputs:=AValue;
  3368. MarkPropertyChanged(AIndex);
  3369. end;
  3370. Procedure TSeqMapTask.Setname(AIndex : Integer; const AValue : String);
  3371. begin
  3372. If (Fname=AValue) then exit;
  3373. Fname:=AValue;
  3374. MarkPropertyChanged(AIndex);
  3375. end;
  3376. Procedure TSeqMapTask.SetoutputInfos(AIndex : Integer; AValue : TSeqMapTaskTypeoutputInfosArray);
  3377. begin
  3378. If (FoutputInfos=AValue) then exit;
  3379. FoutputInfos:=AValue;
  3380. MarkPropertyChanged(AIndex);
  3381. end;
  3382. Procedure TSeqMapTask.SetstageName(AIndex : Integer; const AValue : String);
  3383. begin
  3384. If (FstageName=AValue) then exit;
  3385. FstageName:=AValue;
  3386. MarkPropertyChanged(AIndex);
  3387. end;
  3388. Procedure TSeqMapTask.SetsystemName(AIndex : Integer; const AValue : String);
  3389. begin
  3390. If (FsystemName=AValue) then exit;
  3391. FsystemName:=AValue;
  3392. MarkPropertyChanged(AIndex);
  3393. end;
  3394. Procedure TSeqMapTask.SetuserFn(AIndex : Integer; AValue : TSeqMapTaskTypeuserFn);
  3395. begin
  3396. If (FuserFn=AValue) then exit;
  3397. FuserFn:=AValue;
  3398. MarkPropertyChanged(AIndex);
  3399. end;
  3400. //2.6.4. bug workaround
  3401. {$IFDEF VER2_6}
  3402. Procedure TSeqMapTask.SetArrayLength(Const AName : String; ALength : Longint);
  3403. begin
  3404. Case AName of
  3405. 'inputs' : SetLength(Finputs,ALength);
  3406. 'outputinfos' : SetLength(FoutputInfos,ALength);
  3407. else
  3408. Inherited SetArrayLength(AName,ALength);
  3409. end;
  3410. end;
  3411. {$ENDIF VER2_6}
  3412. { --------------------------------------------------------------------
  3413. TSeqMapTaskOutputInfo
  3414. --------------------------------------------------------------------}
  3415. Procedure TSeqMapTaskOutputInfo.Setsink(AIndex : Integer; AValue : TSink);
  3416. begin
  3417. If (Fsink=AValue) then exit;
  3418. Fsink:=AValue;
  3419. MarkPropertyChanged(AIndex);
  3420. end;
  3421. Procedure TSeqMapTaskOutputInfo.Settag(AIndex : Integer; const AValue : String);
  3422. begin
  3423. If (Ftag=AValue) then exit;
  3424. Ftag:=AValue;
  3425. MarkPropertyChanged(AIndex);
  3426. end;
  3427. { --------------------------------------------------------------------
  3428. TShellTask
  3429. --------------------------------------------------------------------}
  3430. Procedure TShellTask.Setcommand(AIndex : Integer; const AValue : String);
  3431. begin
  3432. If (Fcommand=AValue) then exit;
  3433. Fcommand:=AValue;
  3434. MarkPropertyChanged(AIndex);
  3435. end;
  3436. Procedure TShellTask.SetexitCode(AIndex : Integer; AValue : integer);
  3437. begin
  3438. If (FexitCode=AValue) then exit;
  3439. FexitCode:=AValue;
  3440. MarkPropertyChanged(AIndex);
  3441. end;
  3442. { --------------------------------------------------------------------
  3443. TSideInputInfoTypekind
  3444. --------------------------------------------------------------------}
  3445. Class Function TSideInputInfoTypekind.AllowAdditionalProperties : Boolean;
  3446. begin
  3447. Result:=True;
  3448. end;
  3449. { --------------------------------------------------------------------
  3450. TSideInputInfo
  3451. --------------------------------------------------------------------}
  3452. Procedure TSideInputInfo.Setkind(AIndex : Integer; AValue : TSideInputInfoTypekind);
  3453. begin
  3454. If (Fkind=AValue) then exit;
  3455. Fkind:=AValue;
  3456. MarkPropertyChanged(AIndex);
  3457. end;
  3458. Procedure TSideInputInfo.Setsources(AIndex : Integer; AValue : TSideInputInfoTypesourcesArray);
  3459. begin
  3460. If (Fsources=AValue) then exit;
  3461. Fsources:=AValue;
  3462. MarkPropertyChanged(AIndex);
  3463. end;
  3464. Procedure TSideInputInfo.Settag(AIndex : Integer; const AValue : String);
  3465. begin
  3466. If (Ftag=AValue) then exit;
  3467. Ftag:=AValue;
  3468. MarkPropertyChanged(AIndex);
  3469. end;
  3470. //2.6.4. bug workaround
  3471. {$IFDEF VER2_6}
  3472. Procedure TSideInputInfo.SetArrayLength(Const AName : String; ALength : Longint);
  3473. begin
  3474. Case AName of
  3475. 'sources' : SetLength(Fsources,ALength);
  3476. else
  3477. Inherited SetArrayLength(AName,ALength);
  3478. end;
  3479. end;
  3480. {$ENDIF VER2_6}
  3481. { --------------------------------------------------------------------
  3482. TSinkTypecodec
  3483. --------------------------------------------------------------------}
  3484. Class Function TSinkTypecodec.AllowAdditionalProperties : Boolean;
  3485. begin
  3486. Result:=True;
  3487. end;
  3488. { --------------------------------------------------------------------
  3489. TSinkTypespec
  3490. --------------------------------------------------------------------}
  3491. Class Function TSinkTypespec.AllowAdditionalProperties : Boolean;
  3492. begin
  3493. Result:=True;
  3494. end;
  3495. { --------------------------------------------------------------------
  3496. TSink
  3497. --------------------------------------------------------------------}
  3498. Procedure TSink.Setcodec(AIndex : Integer; AValue : TSinkTypecodec);
  3499. begin
  3500. If (Fcodec=AValue) then exit;
  3501. Fcodec:=AValue;
  3502. MarkPropertyChanged(AIndex);
  3503. end;
  3504. Procedure TSink.Setspec(AIndex : Integer; AValue : TSinkTypespec);
  3505. begin
  3506. If (Fspec=AValue) then exit;
  3507. Fspec:=AValue;
  3508. MarkPropertyChanged(AIndex);
  3509. end;
  3510. { --------------------------------------------------------------------
  3511. TSourceTypebaseSpecsItem
  3512. --------------------------------------------------------------------}
  3513. Class Function TSourceTypebaseSpecsItem.AllowAdditionalProperties : Boolean;
  3514. begin
  3515. Result:=True;
  3516. end;
  3517. { --------------------------------------------------------------------
  3518. TSourceTypecodec
  3519. --------------------------------------------------------------------}
  3520. Class Function TSourceTypecodec.AllowAdditionalProperties : Boolean;
  3521. begin
  3522. Result:=True;
  3523. end;
  3524. { --------------------------------------------------------------------
  3525. TSourceTypespec
  3526. --------------------------------------------------------------------}
  3527. Class Function TSourceTypespec.AllowAdditionalProperties : Boolean;
  3528. begin
  3529. Result:=True;
  3530. end;
  3531. { --------------------------------------------------------------------
  3532. TSource
  3533. --------------------------------------------------------------------}
  3534. Procedure TSource.SetbaseSpecs(AIndex : Integer; AValue : TSourceTypebaseSpecsArray);
  3535. begin
  3536. If (FbaseSpecs=AValue) then exit;
  3537. FbaseSpecs:=AValue;
  3538. MarkPropertyChanged(AIndex);
  3539. end;
  3540. Procedure TSource.Setcodec(AIndex : Integer; AValue : TSourceTypecodec);
  3541. begin
  3542. If (Fcodec=AValue) then exit;
  3543. Fcodec:=AValue;
  3544. MarkPropertyChanged(AIndex);
  3545. end;
  3546. Procedure TSource.SetdoesNotNeedSplitting(AIndex : Integer; AValue : boolean);
  3547. begin
  3548. If (FdoesNotNeedSplitting=AValue) then exit;
  3549. FdoesNotNeedSplitting:=AValue;
  3550. MarkPropertyChanged(AIndex);
  3551. end;
  3552. Procedure TSource.Setmetadata(AIndex : Integer; AValue : TSourceMetadata);
  3553. begin
  3554. If (Fmetadata=AValue) then exit;
  3555. Fmetadata:=AValue;
  3556. MarkPropertyChanged(AIndex);
  3557. end;
  3558. Procedure TSource.Setspec(AIndex : Integer; AValue : TSourceTypespec);
  3559. begin
  3560. If (Fspec=AValue) then exit;
  3561. Fspec:=AValue;
  3562. MarkPropertyChanged(AIndex);
  3563. end;
  3564. //2.6.4. bug workaround
  3565. {$IFDEF VER2_6}
  3566. Procedure TSource.SetArrayLength(Const AName : String; ALength : Longint);
  3567. begin
  3568. Case AName of
  3569. 'basespecs' : SetLength(FbaseSpecs,ALength);
  3570. else
  3571. Inherited SetArrayLength(AName,ALength);
  3572. end;
  3573. end;
  3574. {$ENDIF VER2_6}
  3575. { --------------------------------------------------------------------
  3576. TSourceFork
  3577. --------------------------------------------------------------------}
  3578. Procedure TSourceFork.Setprimary(AIndex : Integer; AValue : TSourceSplitShard);
  3579. begin
  3580. If (Fprimary=AValue) then exit;
  3581. Fprimary:=AValue;
  3582. MarkPropertyChanged(AIndex);
  3583. end;
  3584. Procedure TSourceFork.SetprimarySource(AIndex : Integer; AValue : TDerivedSource);
  3585. begin
  3586. If (FprimarySource=AValue) then exit;
  3587. FprimarySource:=AValue;
  3588. MarkPropertyChanged(AIndex);
  3589. end;
  3590. Procedure TSourceFork.Setresidual(AIndex : Integer; AValue : TSourceSplitShard);
  3591. begin
  3592. If (Fresidual=AValue) then exit;
  3593. Fresidual:=AValue;
  3594. MarkPropertyChanged(AIndex);
  3595. end;
  3596. Procedure TSourceFork.SetresidualSource(AIndex : Integer; AValue : TDerivedSource);
  3597. begin
  3598. If (FresidualSource=AValue) then exit;
  3599. FresidualSource:=AValue;
  3600. MarkPropertyChanged(AIndex);
  3601. end;
  3602. { --------------------------------------------------------------------
  3603. TSourceGetMetadataRequest
  3604. --------------------------------------------------------------------}
  3605. Procedure TSourceGetMetadataRequest.Setsource(AIndex : Integer; AValue : TSource);
  3606. begin
  3607. If (Fsource=AValue) then exit;
  3608. Fsource:=AValue;
  3609. MarkPropertyChanged(AIndex);
  3610. end;
  3611. { --------------------------------------------------------------------
  3612. TSourceGetMetadataResponse
  3613. --------------------------------------------------------------------}
  3614. Procedure TSourceGetMetadataResponse.Setmetadata(AIndex : Integer; AValue : TSourceMetadata);
  3615. begin
  3616. If (Fmetadata=AValue) then exit;
  3617. Fmetadata:=AValue;
  3618. MarkPropertyChanged(AIndex);
  3619. end;
  3620. { --------------------------------------------------------------------
  3621. TSourceMetadata
  3622. --------------------------------------------------------------------}
  3623. Procedure TSourceMetadata.SetestimatedSizeBytes(AIndex : Integer; const AValue : String);
  3624. begin
  3625. If (FestimatedSizeBytes=AValue) then exit;
  3626. FestimatedSizeBytes:=AValue;
  3627. MarkPropertyChanged(AIndex);
  3628. end;
  3629. Procedure TSourceMetadata.Setinfinite(AIndex : Integer; AValue : boolean);
  3630. begin
  3631. If (Finfinite=AValue) then exit;
  3632. Finfinite:=AValue;
  3633. MarkPropertyChanged(AIndex);
  3634. end;
  3635. Procedure TSourceMetadata.SetproducesSortedKeys(AIndex : Integer; AValue : boolean);
  3636. begin
  3637. If (FproducesSortedKeys=AValue) then exit;
  3638. FproducesSortedKeys:=AValue;
  3639. MarkPropertyChanged(AIndex);
  3640. end;
  3641. { --------------------------------------------------------------------
  3642. TSourceOperationRequest
  3643. --------------------------------------------------------------------}
  3644. Procedure TSourceOperationRequest.SetgetMetadata(AIndex : Integer; AValue : TSourceGetMetadataRequest);
  3645. begin
  3646. If (FgetMetadata=AValue) then exit;
  3647. FgetMetadata:=AValue;
  3648. MarkPropertyChanged(AIndex);
  3649. end;
  3650. Procedure TSourceOperationRequest.Setsplit(AIndex : Integer; AValue : TSourceSplitRequest);
  3651. begin
  3652. If (Fsplit=AValue) then exit;
  3653. Fsplit:=AValue;
  3654. MarkPropertyChanged(AIndex);
  3655. end;
  3656. { --------------------------------------------------------------------
  3657. TSourceOperationResponse
  3658. --------------------------------------------------------------------}
  3659. Procedure TSourceOperationResponse.SetgetMetadata(AIndex : Integer; AValue : TSourceGetMetadataResponse);
  3660. begin
  3661. If (FgetMetadata=AValue) then exit;
  3662. FgetMetadata:=AValue;
  3663. MarkPropertyChanged(AIndex);
  3664. end;
  3665. Procedure TSourceOperationResponse.Setsplit(AIndex : Integer; AValue : TSourceSplitResponse);
  3666. begin
  3667. If (Fsplit=AValue) then exit;
  3668. Fsplit:=AValue;
  3669. MarkPropertyChanged(AIndex);
  3670. end;
  3671. { --------------------------------------------------------------------
  3672. TSourceSplitOptions
  3673. --------------------------------------------------------------------}
  3674. Procedure TSourceSplitOptions.SetdesiredBundleSizeBytes(AIndex : Integer; const AValue : String);
  3675. begin
  3676. If (FdesiredBundleSizeBytes=AValue) then exit;
  3677. FdesiredBundleSizeBytes:=AValue;
  3678. MarkPropertyChanged(AIndex);
  3679. end;
  3680. Procedure TSourceSplitOptions.SetdesiredShardSizeBytes(AIndex : Integer; const AValue : String);
  3681. begin
  3682. If (FdesiredShardSizeBytes=AValue) then exit;
  3683. FdesiredShardSizeBytes:=AValue;
  3684. MarkPropertyChanged(AIndex);
  3685. end;
  3686. { --------------------------------------------------------------------
  3687. TSourceSplitRequest
  3688. --------------------------------------------------------------------}
  3689. Procedure TSourceSplitRequest.Setoptions(AIndex : Integer; AValue : TSourceSplitOptions);
  3690. begin
  3691. If (Foptions=AValue) then exit;
  3692. Foptions:=AValue;
  3693. MarkPropertyChanged(AIndex);
  3694. end;
  3695. Procedure TSourceSplitRequest.Setsource(AIndex : Integer; AValue : TSource);
  3696. begin
  3697. If (Fsource=AValue) then exit;
  3698. Fsource:=AValue;
  3699. MarkPropertyChanged(AIndex);
  3700. end;
  3701. { --------------------------------------------------------------------
  3702. TSourceSplitResponse
  3703. --------------------------------------------------------------------}
  3704. Procedure TSourceSplitResponse.Setbundles(AIndex : Integer; AValue : TSourceSplitResponseTypebundlesArray);
  3705. begin
  3706. If (Fbundles=AValue) then exit;
  3707. Fbundles:=AValue;
  3708. MarkPropertyChanged(AIndex);
  3709. end;
  3710. Procedure TSourceSplitResponse.Setoutcome(AIndex : Integer; const AValue : String);
  3711. begin
  3712. If (Foutcome=AValue) then exit;
  3713. Foutcome:=AValue;
  3714. MarkPropertyChanged(AIndex);
  3715. end;
  3716. Procedure TSourceSplitResponse.Setshards(AIndex : Integer; AValue : TSourceSplitResponseTypeshardsArray);
  3717. begin
  3718. If (Fshards=AValue) then exit;
  3719. Fshards:=AValue;
  3720. MarkPropertyChanged(AIndex);
  3721. end;
  3722. //2.6.4. bug workaround
  3723. {$IFDEF VER2_6}
  3724. Procedure TSourceSplitResponse.SetArrayLength(Const AName : String; ALength : Longint);
  3725. begin
  3726. Case AName of
  3727. 'bundles' : SetLength(Fbundles,ALength);
  3728. 'shards' : SetLength(Fshards,ALength);
  3729. else
  3730. Inherited SetArrayLength(AName,ALength);
  3731. end;
  3732. end;
  3733. {$ENDIF VER2_6}
  3734. { --------------------------------------------------------------------
  3735. TSourceSplitShard
  3736. --------------------------------------------------------------------}
  3737. Procedure TSourceSplitShard.SetderivationMode(AIndex : Integer; const AValue : String);
  3738. begin
  3739. If (FderivationMode=AValue) then exit;
  3740. FderivationMode:=AValue;
  3741. MarkPropertyChanged(AIndex);
  3742. end;
  3743. Procedure TSourceSplitShard.Setsource(AIndex : Integer; AValue : TSource);
  3744. begin
  3745. If (Fsource=AValue) then exit;
  3746. Fsource:=AValue;
  3747. MarkPropertyChanged(AIndex);
  3748. end;
  3749. { --------------------------------------------------------------------
  3750. TStatusTypedetailsItem
  3751. --------------------------------------------------------------------}
  3752. Class Function TStatusTypedetailsItem.AllowAdditionalProperties : Boolean;
  3753. begin
  3754. Result:=True;
  3755. end;
  3756. { --------------------------------------------------------------------
  3757. TStatus
  3758. --------------------------------------------------------------------}
  3759. Procedure TStatus.Setcode(AIndex : Integer; AValue : integer);
  3760. begin
  3761. If (Fcode=AValue) then exit;
  3762. Fcode:=AValue;
  3763. MarkPropertyChanged(AIndex);
  3764. end;
  3765. Procedure TStatus.Setdetails(AIndex : Integer; AValue : TStatusTypedetailsArray);
  3766. begin
  3767. If (Fdetails=AValue) then exit;
  3768. Fdetails:=AValue;
  3769. MarkPropertyChanged(AIndex);
  3770. end;
  3771. Procedure TStatus.Setmessage(AIndex : Integer; const AValue : String);
  3772. begin
  3773. If (Fmessage=AValue) then exit;
  3774. Fmessage:=AValue;
  3775. MarkPropertyChanged(AIndex);
  3776. end;
  3777. //2.6.4. bug workaround
  3778. {$IFDEF VER2_6}
  3779. Procedure TStatus.SetArrayLength(Const AName : String; ALength : Longint);
  3780. begin
  3781. Case AName of
  3782. 'details' : SetLength(Fdetails,ALength);
  3783. else
  3784. Inherited SetArrayLength(AName,ALength);
  3785. end;
  3786. end;
  3787. {$ENDIF VER2_6}
  3788. { --------------------------------------------------------------------
  3789. TStepTypeproperties
  3790. --------------------------------------------------------------------}
  3791. Class Function TStepTypeproperties.AllowAdditionalProperties : Boolean;
  3792. begin
  3793. Result:=True;
  3794. end;
  3795. { --------------------------------------------------------------------
  3796. TStep
  3797. --------------------------------------------------------------------}
  3798. Procedure TStep.Setkind(AIndex : Integer; const AValue : String);
  3799. begin
  3800. If (Fkind=AValue) then exit;
  3801. Fkind:=AValue;
  3802. MarkPropertyChanged(AIndex);
  3803. end;
  3804. Procedure TStep.Setname(AIndex : Integer; const AValue : String);
  3805. begin
  3806. If (Fname=AValue) then exit;
  3807. Fname:=AValue;
  3808. MarkPropertyChanged(AIndex);
  3809. end;
  3810. Procedure TStep.Setproperties(AIndex : Integer; AValue : TStepTypeproperties);
  3811. begin
  3812. If (Fproperties=AValue) then exit;
  3813. Fproperties:=AValue;
  3814. MarkPropertyChanged(AIndex);
  3815. end;
  3816. { --------------------------------------------------------------------
  3817. TStreamLocation
  3818. --------------------------------------------------------------------}
  3819. Procedure TStreamLocation.SetpubsubLocation(AIndex : Integer; AValue : TPubsubLocation);
  3820. begin
  3821. If (FpubsubLocation=AValue) then exit;
  3822. FpubsubLocation:=AValue;
  3823. MarkPropertyChanged(AIndex);
  3824. end;
  3825. Procedure TStreamLocation.SetsideInputLocation(AIndex : Integer; AValue : TStreamingSideInputLocation);
  3826. begin
  3827. If (FsideInputLocation=AValue) then exit;
  3828. FsideInputLocation:=AValue;
  3829. MarkPropertyChanged(AIndex);
  3830. end;
  3831. Procedure TStreamLocation.SetstreamingStageLocation(AIndex : Integer; AValue : TStreamingStageLocation);
  3832. begin
  3833. If (FstreamingStageLocation=AValue) then exit;
  3834. FstreamingStageLocation:=AValue;
  3835. MarkPropertyChanged(AIndex);
  3836. end;
  3837. { --------------------------------------------------------------------
  3838. TStreamingComputationRanges
  3839. --------------------------------------------------------------------}
  3840. Procedure TStreamingComputationRanges.SetcomputationId(AIndex : Integer; const AValue : String);
  3841. begin
  3842. If (FcomputationId=AValue) then exit;
  3843. FcomputationId:=AValue;
  3844. MarkPropertyChanged(AIndex);
  3845. end;
  3846. Procedure TStreamingComputationRanges.SetrangeAssignments(AIndex : Integer; AValue : TStreamingComputationRangesTyperangeAssignmentsArray);
  3847. begin
  3848. If (FrangeAssignments=AValue) then exit;
  3849. FrangeAssignments:=AValue;
  3850. MarkPropertyChanged(AIndex);
  3851. end;
  3852. //2.6.4. bug workaround
  3853. {$IFDEF VER2_6}
  3854. Procedure TStreamingComputationRanges.SetArrayLength(Const AName : String; ALength : Longint);
  3855. begin
  3856. Case AName of
  3857. 'rangeassignments' : SetLength(FrangeAssignments,ALength);
  3858. else
  3859. Inherited SetArrayLength(AName,ALength);
  3860. end;
  3861. end;
  3862. {$ENDIF VER2_6}
  3863. { --------------------------------------------------------------------
  3864. TStreamingComputationTask
  3865. --------------------------------------------------------------------}
  3866. Procedure TStreamingComputationTask.SetcomputationRanges(AIndex : Integer; AValue : TStreamingComputationTaskTypecomputationRangesArray);
  3867. begin
  3868. If (FcomputationRanges=AValue) then exit;
  3869. FcomputationRanges:=AValue;
  3870. MarkPropertyChanged(AIndex);
  3871. end;
  3872. Procedure TStreamingComputationTask.SetdataDisks(AIndex : Integer; AValue : TStreamingComputationTaskTypedataDisksArray);
  3873. begin
  3874. If (FdataDisks=AValue) then exit;
  3875. FdataDisks:=AValue;
  3876. MarkPropertyChanged(AIndex);
  3877. end;
  3878. Procedure TStreamingComputationTask.SettaskType(AIndex : Integer; const AValue : String);
  3879. begin
  3880. If (FtaskType=AValue) then exit;
  3881. FtaskType:=AValue;
  3882. MarkPropertyChanged(AIndex);
  3883. end;
  3884. //2.6.4. bug workaround
  3885. {$IFDEF VER2_6}
  3886. Procedure TStreamingComputationTask.SetArrayLength(Const AName : String; ALength : Longint);
  3887. begin
  3888. Case AName of
  3889. 'computationranges' : SetLength(FcomputationRanges,ALength);
  3890. 'datadisks' : SetLength(FdataDisks,ALength);
  3891. else
  3892. Inherited SetArrayLength(AName,ALength);
  3893. end;
  3894. end;
  3895. {$ENDIF VER2_6}
  3896. { --------------------------------------------------------------------
  3897. TStreamingSetupTask
  3898. --------------------------------------------------------------------}
  3899. Procedure TStreamingSetupTask.SetreceiveWorkPort(AIndex : Integer; AValue : integer);
  3900. begin
  3901. If (FreceiveWorkPort=AValue) then exit;
  3902. FreceiveWorkPort:=AValue;
  3903. MarkPropertyChanged(AIndex);
  3904. end;
  3905. Procedure TStreamingSetupTask.SetstreamingComputationTopology(AIndex : Integer; AValue : TTopologyConfig);
  3906. begin
  3907. If (FstreamingComputationTopology=AValue) then exit;
  3908. FstreamingComputationTopology:=AValue;
  3909. MarkPropertyChanged(AIndex);
  3910. end;
  3911. Procedure TStreamingSetupTask.SetworkerHarnessPort(AIndex : Integer; AValue : integer);
  3912. begin
  3913. If (FworkerHarnessPort=AValue) then exit;
  3914. FworkerHarnessPort:=AValue;
  3915. MarkPropertyChanged(AIndex);
  3916. end;
  3917. { --------------------------------------------------------------------
  3918. TStreamingSideInputLocation
  3919. --------------------------------------------------------------------}
  3920. Procedure TStreamingSideInputLocation.Settag(AIndex : Integer; const AValue : String);
  3921. begin
  3922. If (Ftag=AValue) then exit;
  3923. Ftag:=AValue;
  3924. MarkPropertyChanged(AIndex);
  3925. end;
  3926. { --------------------------------------------------------------------
  3927. TStreamingStageLocation
  3928. --------------------------------------------------------------------}
  3929. Procedure TStreamingStageLocation.SetstreamId(AIndex : Integer; const AValue : String);
  3930. begin
  3931. If (FstreamId=AValue) then exit;
  3932. FstreamId:=AValue;
  3933. MarkPropertyChanged(AIndex);
  3934. end;
  3935. { --------------------------------------------------------------------
  3936. TTaskRunnerSettings
  3937. --------------------------------------------------------------------}
  3938. Procedure TTaskRunnerSettings.Setalsologtostderr(AIndex : Integer; AValue : boolean);
  3939. begin
  3940. If (Falsologtostderr=AValue) then exit;
  3941. Falsologtostderr:=AValue;
  3942. MarkPropertyChanged(AIndex);
  3943. end;
  3944. Procedure TTaskRunnerSettings.SetbaseTaskDir(AIndex : Integer; const AValue : String);
  3945. begin
  3946. If (FbaseTaskDir=AValue) then exit;
  3947. FbaseTaskDir:=AValue;
  3948. MarkPropertyChanged(AIndex);
  3949. end;
  3950. Procedure TTaskRunnerSettings.SetbaseUrl(AIndex : Integer; const AValue : String);
  3951. begin
  3952. If (FbaseUrl=AValue) then exit;
  3953. FbaseUrl:=AValue;
  3954. MarkPropertyChanged(AIndex);
  3955. end;
  3956. Procedure TTaskRunnerSettings.SetcommandlinesFileName(AIndex : Integer; const AValue : String);
  3957. begin
  3958. If (FcommandlinesFileName=AValue) then exit;
  3959. FcommandlinesFileName:=AValue;
  3960. MarkPropertyChanged(AIndex);
  3961. end;
  3962. Procedure TTaskRunnerSettings.SetcontinueOnException(AIndex : Integer; AValue : boolean);
  3963. begin
  3964. If (FcontinueOnException=AValue) then exit;
  3965. FcontinueOnException:=AValue;
  3966. MarkPropertyChanged(AIndex);
  3967. end;
  3968. Procedure TTaskRunnerSettings.SetdataflowApiVersion(AIndex : Integer; const AValue : String);
  3969. begin
  3970. If (FdataflowApiVersion=AValue) then exit;
  3971. FdataflowApiVersion:=AValue;
  3972. MarkPropertyChanged(AIndex);
  3973. end;
  3974. Procedure TTaskRunnerSettings.SetharnessCommand(AIndex : Integer; const AValue : String);
  3975. begin
  3976. If (FharnessCommand=AValue) then exit;
  3977. FharnessCommand:=AValue;
  3978. MarkPropertyChanged(AIndex);
  3979. end;
  3980. Procedure TTaskRunnerSettings.SetlanguageHint(AIndex : Integer; const AValue : String);
  3981. begin
  3982. If (FlanguageHint=AValue) then exit;
  3983. FlanguageHint:=AValue;
  3984. MarkPropertyChanged(AIndex);
  3985. end;
  3986. Procedure TTaskRunnerSettings.SetlogDir(AIndex : Integer; const AValue : String);
  3987. begin
  3988. If (FlogDir=AValue) then exit;
  3989. FlogDir:=AValue;
  3990. MarkPropertyChanged(AIndex);
  3991. end;
  3992. Procedure TTaskRunnerSettings.SetlogToSerialconsole(AIndex : Integer; AValue : boolean);
  3993. begin
  3994. If (FlogToSerialconsole=AValue) then exit;
  3995. FlogToSerialconsole:=AValue;
  3996. MarkPropertyChanged(AIndex);
  3997. end;
  3998. Procedure TTaskRunnerSettings.SetlogUploadLocation(AIndex : Integer; const AValue : String);
  3999. begin
  4000. If (FlogUploadLocation=AValue) then exit;
  4001. FlogUploadLocation:=AValue;
  4002. MarkPropertyChanged(AIndex);
  4003. end;
  4004. Procedure TTaskRunnerSettings.SetoauthScopes(AIndex : Integer; AValue : TStringArray);
  4005. begin
  4006. If (FoauthScopes=AValue) then exit;
  4007. FoauthScopes:=AValue;
  4008. MarkPropertyChanged(AIndex);
  4009. end;
  4010. Procedure TTaskRunnerSettings.SetparallelWorkerSettings(AIndex : Integer; AValue : TWorkerSettings);
  4011. begin
  4012. If (FparallelWorkerSettings=AValue) then exit;
  4013. FparallelWorkerSettings:=AValue;
  4014. MarkPropertyChanged(AIndex);
  4015. end;
  4016. Procedure TTaskRunnerSettings.SetstreamingWorkerMainClass(AIndex : Integer; const AValue : String);
  4017. begin
  4018. If (FstreamingWorkerMainClass=AValue) then exit;
  4019. FstreamingWorkerMainClass:=AValue;
  4020. MarkPropertyChanged(AIndex);
  4021. end;
  4022. Procedure TTaskRunnerSettings.SettaskGroup(AIndex : Integer; const AValue : String);
  4023. begin
  4024. If (FtaskGroup=AValue) then exit;
  4025. FtaskGroup:=AValue;
  4026. MarkPropertyChanged(AIndex);
  4027. end;
  4028. Procedure TTaskRunnerSettings.SettaskUser(AIndex : Integer; const AValue : String);
  4029. begin
  4030. If (FtaskUser=AValue) then exit;
  4031. FtaskUser:=AValue;
  4032. MarkPropertyChanged(AIndex);
  4033. end;
  4034. Procedure TTaskRunnerSettings.SettempStoragePrefix(AIndex : Integer; const AValue : String);
  4035. begin
  4036. If (FtempStoragePrefix=AValue) then exit;
  4037. FtempStoragePrefix:=AValue;
  4038. MarkPropertyChanged(AIndex);
  4039. end;
  4040. Procedure TTaskRunnerSettings.SetvmId(AIndex : Integer; const AValue : String);
  4041. begin
  4042. If (FvmId=AValue) then exit;
  4043. FvmId:=AValue;
  4044. MarkPropertyChanged(AIndex);
  4045. end;
  4046. Procedure TTaskRunnerSettings.SetworkflowFileName(AIndex : Integer; const AValue : String);
  4047. begin
  4048. If (FworkflowFileName=AValue) then exit;
  4049. FworkflowFileName:=AValue;
  4050. MarkPropertyChanged(AIndex);
  4051. end;
  4052. //2.6.4. bug workaround
  4053. {$IFDEF VER2_6}
  4054. Procedure TTaskRunnerSettings.SetArrayLength(Const AName : String; ALength : Longint);
  4055. begin
  4056. Case AName of
  4057. 'oauthscopes' : SetLength(FoauthScopes,ALength);
  4058. else
  4059. Inherited SetArrayLength(AName,ALength);
  4060. end;
  4061. end;
  4062. {$ENDIF VER2_6}
  4063. { --------------------------------------------------------------------
  4064. TTopologyConfig
  4065. --------------------------------------------------------------------}
  4066. Procedure TTopologyConfig.Setcomputations(AIndex : Integer; AValue : TTopologyConfigTypecomputationsArray);
  4067. begin
  4068. If (Fcomputations=AValue) then exit;
  4069. Fcomputations:=AValue;
  4070. MarkPropertyChanged(AIndex);
  4071. end;
  4072. Procedure TTopologyConfig.SetdataDiskAssignments(AIndex : Integer; AValue : TTopologyConfigTypedataDiskAssignmentsArray);
  4073. begin
  4074. If (FdataDiskAssignments=AValue) then exit;
  4075. FdataDiskAssignments:=AValue;
  4076. MarkPropertyChanged(AIndex);
  4077. end;
  4078. //2.6.4. bug workaround
  4079. {$IFDEF VER2_6}
  4080. Procedure TTopologyConfig.SetArrayLength(Const AName : String; ALength : Longint);
  4081. begin
  4082. Case AName of
  4083. 'computations' : SetLength(Fcomputations,ALength);
  4084. 'datadiskassignments' : SetLength(FdataDiskAssignments,ALength);
  4085. else
  4086. Inherited SetArrayLength(AName,ALength);
  4087. end;
  4088. end;
  4089. {$ENDIF VER2_6}
  4090. { --------------------------------------------------------------------
  4091. TWorkItem
  4092. --------------------------------------------------------------------}
  4093. Procedure TWorkItem.Setconfiguration(AIndex : Integer; const AValue : String);
  4094. begin
  4095. If (Fconfiguration=AValue) then exit;
  4096. Fconfiguration:=AValue;
  4097. MarkPropertyChanged(AIndex);
  4098. end;
  4099. Procedure TWorkItem.Setid(AIndex : Integer; const AValue : String);
  4100. begin
  4101. If (Fid=AValue) then exit;
  4102. Fid:=AValue;
  4103. MarkPropertyChanged(AIndex);
  4104. end;
  4105. Procedure TWorkItem.SetinitialReportIndex(AIndex : Integer; const AValue : String);
  4106. begin
  4107. If (FinitialReportIndex=AValue) then exit;
  4108. FinitialReportIndex:=AValue;
  4109. MarkPropertyChanged(AIndex);
  4110. end;
  4111. Procedure TWorkItem.SetjobId(AIndex : Integer; const AValue : String);
  4112. begin
  4113. If (FjobId=AValue) then exit;
  4114. FjobId:=AValue;
  4115. MarkPropertyChanged(AIndex);
  4116. end;
  4117. Procedure TWorkItem.SetleaseExpireTime(AIndex : Integer; const AValue : String);
  4118. begin
  4119. If (FleaseExpireTime=AValue) then exit;
  4120. FleaseExpireTime:=AValue;
  4121. MarkPropertyChanged(AIndex);
  4122. end;
  4123. Procedure TWorkItem.SetmapTask(AIndex : Integer; AValue : TMapTask);
  4124. begin
  4125. If (FmapTask=AValue) then exit;
  4126. FmapTask:=AValue;
  4127. MarkPropertyChanged(AIndex);
  4128. end;
  4129. Procedure TWorkItem.Setpackages(AIndex : Integer; AValue : TWorkItemTypepackagesArray);
  4130. begin
  4131. If (Fpackages=AValue) then exit;
  4132. Fpackages:=AValue;
  4133. MarkPropertyChanged(AIndex);
  4134. end;
  4135. Procedure TWorkItem.SetprojectId(AIndex : Integer; const AValue : String);
  4136. begin
  4137. If (FprojectId=AValue) then exit;
  4138. FprojectId:=AValue;
  4139. MarkPropertyChanged(AIndex);
  4140. end;
  4141. Procedure TWorkItem.SetreportStatusInterval(AIndex : Integer; const AValue : String);
  4142. begin
  4143. If (FreportStatusInterval=AValue) then exit;
  4144. FreportStatusInterval:=AValue;
  4145. MarkPropertyChanged(AIndex);
  4146. end;
  4147. Procedure TWorkItem.SetseqMapTask(AIndex : Integer; AValue : TSeqMapTask);
  4148. begin
  4149. If (FseqMapTask=AValue) then exit;
  4150. FseqMapTask:=AValue;
  4151. MarkPropertyChanged(AIndex);
  4152. end;
  4153. Procedure TWorkItem.SetshellTask(AIndex : Integer; AValue : TShellTask);
  4154. begin
  4155. If (FshellTask=AValue) then exit;
  4156. FshellTask:=AValue;
  4157. MarkPropertyChanged(AIndex);
  4158. end;
  4159. Procedure TWorkItem.SetsourceOperationTask(AIndex : Integer; AValue : TSourceOperationRequest);
  4160. begin
  4161. If (FsourceOperationTask=AValue) then exit;
  4162. FsourceOperationTask:=AValue;
  4163. MarkPropertyChanged(AIndex);
  4164. end;
  4165. Procedure TWorkItem.SetstreamingComputationTask(AIndex : Integer; AValue : TStreamingComputationTask);
  4166. begin
  4167. If (FstreamingComputationTask=AValue) then exit;
  4168. FstreamingComputationTask:=AValue;
  4169. MarkPropertyChanged(AIndex);
  4170. end;
  4171. Procedure TWorkItem.SetstreamingSetupTask(AIndex : Integer; AValue : TStreamingSetupTask);
  4172. begin
  4173. If (FstreamingSetupTask=AValue) then exit;
  4174. FstreamingSetupTask:=AValue;
  4175. MarkPropertyChanged(AIndex);
  4176. end;
  4177. //2.6.4. bug workaround
  4178. {$IFDEF VER2_6}
  4179. Procedure TWorkItem.SetArrayLength(Const AName : String; ALength : Longint);
  4180. begin
  4181. Case AName of
  4182. 'packages' : SetLength(Fpackages,ALength);
  4183. else
  4184. Inherited SetArrayLength(AName,ALength);
  4185. end;
  4186. end;
  4187. {$ENDIF VER2_6}
  4188. { --------------------------------------------------------------------
  4189. TWorkItemServiceStateTypeharnessData
  4190. --------------------------------------------------------------------}
  4191. Class Function TWorkItemServiceStateTypeharnessData.AllowAdditionalProperties : Boolean;
  4192. begin
  4193. Result:=True;
  4194. end;
  4195. { --------------------------------------------------------------------
  4196. TWorkItemServiceState
  4197. --------------------------------------------------------------------}
  4198. Procedure TWorkItemServiceState.SetharnessData(AIndex : Integer; AValue : TWorkItemServiceStateTypeharnessData);
  4199. begin
  4200. If (FharnessData=AValue) then exit;
  4201. FharnessData:=AValue;
  4202. MarkPropertyChanged(AIndex);
  4203. end;
  4204. Procedure TWorkItemServiceState.SetleaseExpireTime(AIndex : Integer; const AValue : String);
  4205. begin
  4206. If (FleaseExpireTime=AValue) then exit;
  4207. FleaseExpireTime:=AValue;
  4208. MarkPropertyChanged(AIndex);
  4209. end;
  4210. Procedure TWorkItemServiceState.SetnextReportIndex(AIndex : Integer; const AValue : String);
  4211. begin
  4212. If (FnextReportIndex=AValue) then exit;
  4213. FnextReportIndex:=AValue;
  4214. MarkPropertyChanged(AIndex);
  4215. end;
  4216. Procedure TWorkItemServiceState.SetreportStatusInterval(AIndex : Integer; const AValue : String);
  4217. begin
  4218. If (FreportStatusInterval=AValue) then exit;
  4219. FreportStatusInterval:=AValue;
  4220. MarkPropertyChanged(AIndex);
  4221. end;
  4222. Procedure TWorkItemServiceState.SetsuggestedStopPoint(AIndex : Integer; AValue : TApproximateProgress);
  4223. begin
  4224. If (FsuggestedStopPoint=AValue) then exit;
  4225. FsuggestedStopPoint:=AValue;
  4226. MarkPropertyChanged(AIndex);
  4227. end;
  4228. Procedure TWorkItemServiceState.SetsuggestedStopPosition(AIndex : Integer; AValue : TPosition);
  4229. begin
  4230. If (FsuggestedStopPosition=AValue) then exit;
  4231. FsuggestedStopPosition:=AValue;
  4232. MarkPropertyChanged(AIndex);
  4233. end;
  4234. { --------------------------------------------------------------------
  4235. TWorkItemStatus
  4236. --------------------------------------------------------------------}
  4237. Procedure TWorkItemStatus.Setcompleted(AIndex : Integer; AValue : boolean);
  4238. begin
  4239. If (Fcompleted=AValue) then exit;
  4240. Fcompleted:=AValue;
  4241. MarkPropertyChanged(AIndex);
  4242. end;
  4243. Procedure TWorkItemStatus.SetdynamicSourceSplit(AIndex : Integer; AValue : TDynamicSourceSplit);
  4244. begin
  4245. If (FdynamicSourceSplit=AValue) then exit;
  4246. FdynamicSourceSplit:=AValue;
  4247. MarkPropertyChanged(AIndex);
  4248. end;
  4249. Procedure TWorkItemStatus.Seterrors(AIndex : Integer; AValue : TWorkItemStatusTypeerrorsArray);
  4250. begin
  4251. If (Ferrors=AValue) then exit;
  4252. Ferrors:=AValue;
  4253. MarkPropertyChanged(AIndex);
  4254. end;
  4255. Procedure TWorkItemStatus.SetmetricUpdates(AIndex : Integer; AValue : TWorkItemStatusTypemetricUpdatesArray);
  4256. begin
  4257. If (FmetricUpdates=AValue) then exit;
  4258. FmetricUpdates:=AValue;
  4259. MarkPropertyChanged(AIndex);
  4260. end;
  4261. Procedure TWorkItemStatus.Setprogress(AIndex : Integer; AValue : TApproximateProgress);
  4262. begin
  4263. If (Fprogress=AValue) then exit;
  4264. Fprogress:=AValue;
  4265. MarkPropertyChanged(AIndex);
  4266. end;
  4267. Procedure TWorkItemStatus.SetreportIndex(AIndex : Integer; const AValue : String);
  4268. begin
  4269. If (FreportIndex=AValue) then exit;
  4270. FreportIndex:=AValue;
  4271. MarkPropertyChanged(AIndex);
  4272. end;
  4273. Procedure TWorkItemStatus.SetrequestedLeaseDuration(AIndex : Integer; const AValue : String);
  4274. begin
  4275. If (FrequestedLeaseDuration=AValue) then exit;
  4276. FrequestedLeaseDuration:=AValue;
  4277. MarkPropertyChanged(AIndex);
  4278. end;
  4279. Procedure TWorkItemStatus.SetsourceFork(AIndex : Integer; AValue : TSourceFork);
  4280. begin
  4281. If (FsourceFork=AValue) then exit;
  4282. FsourceFork:=AValue;
  4283. MarkPropertyChanged(AIndex);
  4284. end;
  4285. Procedure TWorkItemStatus.SetsourceOperationResponse(AIndex : Integer; AValue : TSourceOperationResponse);
  4286. begin
  4287. If (FsourceOperationResponse=AValue) then exit;
  4288. FsourceOperationResponse:=AValue;
  4289. MarkPropertyChanged(AIndex);
  4290. end;
  4291. Procedure TWorkItemStatus.SetstopPosition(AIndex : Integer; AValue : TPosition);
  4292. begin
  4293. If (FstopPosition=AValue) then exit;
  4294. FstopPosition:=AValue;
  4295. MarkPropertyChanged(AIndex);
  4296. end;
  4297. Procedure TWorkItemStatus.SetworkItemId(AIndex : Integer; const AValue : String);
  4298. begin
  4299. If (FworkItemId=AValue) then exit;
  4300. FworkItemId:=AValue;
  4301. MarkPropertyChanged(AIndex);
  4302. end;
  4303. //2.6.4. bug workaround
  4304. {$IFDEF VER2_6}
  4305. Procedure TWorkItemStatus.SetArrayLength(Const AName : String; ALength : Longint);
  4306. begin
  4307. Case AName of
  4308. 'errors' : SetLength(Ferrors,ALength);
  4309. 'metricupdates' : SetLength(FmetricUpdates,ALength);
  4310. else
  4311. Inherited SetArrayLength(AName,ALength);
  4312. end;
  4313. end;
  4314. {$ENDIF VER2_6}
  4315. { --------------------------------------------------------------------
  4316. TWorkerPoolTypemetadata
  4317. --------------------------------------------------------------------}
  4318. Class Function TWorkerPoolTypemetadata.AllowAdditionalProperties : Boolean;
  4319. begin
  4320. Result:=True;
  4321. end;
  4322. { --------------------------------------------------------------------
  4323. TWorkerPoolTypepoolArgs
  4324. --------------------------------------------------------------------}
  4325. Class Function TWorkerPoolTypepoolArgs.AllowAdditionalProperties : Boolean;
  4326. begin
  4327. Result:=True;
  4328. end;
  4329. { --------------------------------------------------------------------
  4330. TWorkerPool
  4331. --------------------------------------------------------------------}
  4332. Procedure TWorkerPool.SetautoscalingSettings(AIndex : Integer; AValue : TAutoscalingSettings);
  4333. begin
  4334. If (FautoscalingSettings=AValue) then exit;
  4335. FautoscalingSettings:=AValue;
  4336. MarkPropertyChanged(AIndex);
  4337. end;
  4338. Procedure TWorkerPool.SetdataDisks(AIndex : Integer; AValue : TWorkerPoolTypedataDisksArray);
  4339. begin
  4340. If (FdataDisks=AValue) then exit;
  4341. FdataDisks:=AValue;
  4342. MarkPropertyChanged(AIndex);
  4343. end;
  4344. Procedure TWorkerPool.SetdefaultPackageSet(AIndex : Integer; const AValue : String);
  4345. begin
  4346. If (FdefaultPackageSet=AValue) then exit;
  4347. FdefaultPackageSet:=AValue;
  4348. MarkPropertyChanged(AIndex);
  4349. end;
  4350. Procedure TWorkerPool.SetdiskSizeGb(AIndex : Integer; AValue : integer);
  4351. begin
  4352. If (FdiskSizeGb=AValue) then exit;
  4353. FdiskSizeGb:=AValue;
  4354. MarkPropertyChanged(AIndex);
  4355. end;
  4356. Procedure TWorkerPool.SetdiskSourceImage(AIndex : Integer; const AValue : String);
  4357. begin
  4358. If (FdiskSourceImage=AValue) then exit;
  4359. FdiskSourceImage:=AValue;
  4360. MarkPropertyChanged(AIndex);
  4361. end;
  4362. Procedure TWorkerPool.SetdiskType(AIndex : Integer; const AValue : String);
  4363. begin
  4364. If (FdiskType=AValue) then exit;
  4365. FdiskType:=AValue;
  4366. MarkPropertyChanged(AIndex);
  4367. end;
  4368. Procedure TWorkerPool.Setkind(AIndex : Integer; const AValue : String);
  4369. begin
  4370. If (Fkind=AValue) then exit;
  4371. Fkind:=AValue;
  4372. MarkPropertyChanged(AIndex);
  4373. end;
  4374. Procedure TWorkerPool.SetmachineType(AIndex : Integer; const AValue : String);
  4375. begin
  4376. If (FmachineType=AValue) then exit;
  4377. FmachineType:=AValue;
  4378. MarkPropertyChanged(AIndex);
  4379. end;
  4380. Procedure TWorkerPool.Setmetadata(AIndex : Integer; AValue : TWorkerPoolTypemetadata);
  4381. begin
  4382. If (Fmetadata=AValue) then exit;
  4383. Fmetadata:=AValue;
  4384. MarkPropertyChanged(AIndex);
  4385. end;
  4386. Procedure TWorkerPool.SetnumWorkers(AIndex : Integer; AValue : integer);
  4387. begin
  4388. If (FnumWorkers=AValue) then exit;
  4389. FnumWorkers:=AValue;
  4390. MarkPropertyChanged(AIndex);
  4391. end;
  4392. Procedure TWorkerPool.SetonHostMaintenance(AIndex : Integer; const AValue : String);
  4393. begin
  4394. If (FonHostMaintenance=AValue) then exit;
  4395. FonHostMaintenance:=AValue;
  4396. MarkPropertyChanged(AIndex);
  4397. end;
  4398. Procedure TWorkerPool.Setpackages(AIndex : Integer; AValue : TWorkerPoolTypepackagesArray);
  4399. begin
  4400. If (Fpackages=AValue) then exit;
  4401. Fpackages:=AValue;
  4402. MarkPropertyChanged(AIndex);
  4403. end;
  4404. Procedure TWorkerPool.SetpoolArgs(AIndex : Integer; AValue : TWorkerPoolTypepoolArgs);
  4405. begin
  4406. If (FpoolArgs=AValue) then exit;
  4407. FpoolArgs:=AValue;
  4408. MarkPropertyChanged(AIndex);
  4409. end;
  4410. Procedure TWorkerPool.SettaskrunnerSettings(AIndex : Integer; AValue : TTaskRunnerSettings);
  4411. begin
  4412. If (FtaskrunnerSettings=AValue) then exit;
  4413. FtaskrunnerSettings:=AValue;
  4414. MarkPropertyChanged(AIndex);
  4415. end;
  4416. Procedure TWorkerPool.SetteardownPolicy(AIndex : Integer; const AValue : String);
  4417. begin
  4418. If (FteardownPolicy=AValue) then exit;
  4419. FteardownPolicy:=AValue;
  4420. MarkPropertyChanged(AIndex);
  4421. end;
  4422. Procedure TWorkerPool.Setzone(AIndex : Integer; const AValue : String);
  4423. begin
  4424. If (Fzone=AValue) then exit;
  4425. Fzone:=AValue;
  4426. MarkPropertyChanged(AIndex);
  4427. end;
  4428. //2.6.4. bug workaround
  4429. {$IFDEF VER2_6}
  4430. Procedure TWorkerPool.SetArrayLength(Const AName : String; ALength : Longint);
  4431. begin
  4432. Case AName of
  4433. 'datadisks' : SetLength(FdataDisks,ALength);
  4434. 'packages' : SetLength(Fpackages,ALength);
  4435. else
  4436. Inherited SetArrayLength(AName,ALength);
  4437. end;
  4438. end;
  4439. {$ENDIF VER2_6}
  4440. { --------------------------------------------------------------------
  4441. TWorkerSettings
  4442. --------------------------------------------------------------------}
  4443. Procedure TWorkerSettings.SetbaseUrl(AIndex : Integer; const AValue : String);
  4444. begin
  4445. If (FbaseUrl=AValue) then exit;
  4446. FbaseUrl:=AValue;
  4447. MarkPropertyChanged(AIndex);
  4448. end;
  4449. Procedure TWorkerSettings.SetreportingEnabled(AIndex : Integer; AValue : boolean);
  4450. begin
  4451. If (FreportingEnabled=AValue) then exit;
  4452. FreportingEnabled:=AValue;
  4453. MarkPropertyChanged(AIndex);
  4454. end;
  4455. Procedure TWorkerSettings.SetservicePath(AIndex : Integer; const AValue : String);
  4456. begin
  4457. If (FservicePath=AValue) then exit;
  4458. FservicePath:=AValue;
  4459. MarkPropertyChanged(AIndex);
  4460. end;
  4461. Procedure TWorkerSettings.SetshuffleServicePath(AIndex : Integer; const AValue : String);
  4462. begin
  4463. If (FshuffleServicePath=AValue) then exit;
  4464. FshuffleServicePath:=AValue;
  4465. MarkPropertyChanged(AIndex);
  4466. end;
  4467. Procedure TWorkerSettings.SettempStoragePrefix(AIndex : Integer; const AValue : String);
  4468. begin
  4469. If (FtempStoragePrefix=AValue) then exit;
  4470. FtempStoragePrefix:=AValue;
  4471. MarkPropertyChanged(AIndex);
  4472. end;
  4473. Procedure TWorkerSettings.SetworkerId(AIndex : Integer; const AValue : String);
  4474. begin
  4475. If (FworkerId=AValue) then exit;
  4476. FworkerId:=AValue;
  4477. MarkPropertyChanged(AIndex);
  4478. end;
  4479. { --------------------------------------------------------------------
  4480. TWriteInstruction
  4481. --------------------------------------------------------------------}
  4482. Procedure TWriteInstruction.Setinput(AIndex : Integer; AValue : TInstructionInput);
  4483. begin
  4484. If (Finput=AValue) then exit;
  4485. Finput:=AValue;
  4486. MarkPropertyChanged(AIndex);
  4487. end;
  4488. Procedure TWriteInstruction.Setsink(AIndex : Integer; AValue : TSink);
  4489. begin
  4490. If (Fsink=AValue) then exit;
  4491. Fsink:=AValue;
  4492. MarkPropertyChanged(AIndex);
  4493. end;
  4494. { --------------------------------------------------------------------
  4495. TProjectsJobsMessagesResource
  4496. --------------------------------------------------------------------}
  4497. Class Function TProjectsJobsMessagesResource.ResourceName : String;
  4498. begin
  4499. Result:='messages';
  4500. end;
  4501. Class Function TProjectsJobsMessagesResource.DefaultAPI : TGoogleAPIClass;
  4502. begin
  4503. Result:=TdataflowAPI;
  4504. end;
  4505. Function TProjectsJobsMessagesResource.List(jobId: string; projectId: string; AQuery : string = '') : TListJobMessagesResponse;
  4506. Const
  4507. _HTTPMethod = 'GET';
  4508. _Path = '{projectId}/jobs/{jobId}/messages';
  4509. _Methodid = 'dataflow.projects.jobs.messages.list';
  4510. Var
  4511. _P : String;
  4512. begin
  4513. _P:=SubstitutePath(_Path,['jobId',jobId,'projectId',projectId]);
  4514. Result:=ServiceCall(_HTTPMethod,_P,AQuery,Nil,TListJobMessagesResponse) as TListJobMessagesResponse;
  4515. end;
  4516. Function TProjectsJobsMessagesResource.List(jobId: string; projectId: string; AQuery : TProjectsJobsMessageslistOptions) : TListJobMessagesResponse;
  4517. Var
  4518. _Q : String;
  4519. begin
  4520. _Q:='';
  4521. AddToQuery(_Q,'endTime',AQuery.endTime);
  4522. AddToQuery(_Q,'minimumImportance',AQuery.minimumImportance);
  4523. AddToQuery(_Q,'pageSize',AQuery.pageSize);
  4524. AddToQuery(_Q,'pageToken',AQuery.pageToken);
  4525. AddToQuery(_Q,'startTime',AQuery.startTime);
  4526. Result:=List(jobId,projectId,_Q);
  4527. end;
  4528. { --------------------------------------------------------------------
  4529. TProjectsJobsWorkItemsResource
  4530. --------------------------------------------------------------------}
  4531. Class Function TProjectsJobsWorkItemsResource.ResourceName : String;
  4532. begin
  4533. Result:='workItems';
  4534. end;
  4535. Class Function TProjectsJobsWorkItemsResource.DefaultAPI : TGoogleAPIClass;
  4536. begin
  4537. Result:=TdataflowAPI;
  4538. end;
  4539. Function TProjectsJobsWorkItemsResource.Lease(jobId: string; projectId: string; aLeaseWorkItemRequest : TLeaseWorkItemRequest) : TLeaseWorkItemResponse;
  4540. Const
  4541. _HTTPMethod = 'POST';
  4542. _Path = '{projectId}/jobs/{jobId}/workItems:lease';
  4543. _Methodid = 'dataflow.projects.jobs.workItems.lease';
  4544. Var
  4545. _P : String;
  4546. begin
  4547. _P:=SubstitutePath(_Path,['jobId',jobId,'projectId',projectId]);
  4548. Result:=ServiceCall(_HTTPMethod,_P,'',aLeaseWorkItemRequest,TLeaseWorkItemResponse) as TLeaseWorkItemResponse;
  4549. end;
  4550. Function TProjectsJobsWorkItemsResource.ReportStatus(jobId: string; projectId: string; aReportWorkItemStatusRequest : TReportWorkItemStatusRequest) : TReportWorkItemStatusResponse;
  4551. Const
  4552. _HTTPMethod = 'POST';
  4553. _Path = '{projectId}/jobs/{jobId}/workItems:reportStatus';
  4554. _Methodid = 'dataflow.projects.jobs.workItems.reportStatus';
  4555. Var
  4556. _P : String;
  4557. begin
  4558. _P:=SubstitutePath(_Path,['jobId',jobId,'projectId',projectId]);
  4559. Result:=ServiceCall(_HTTPMethod,_P,'',aReportWorkItemStatusRequest,TReportWorkItemStatusResponse) as TReportWorkItemStatusResponse;
  4560. end;
  4561. { --------------------------------------------------------------------
  4562. TProjectsJobsResource
  4563. --------------------------------------------------------------------}
  4564. Class Function TProjectsJobsResource.ResourceName : String;
  4565. begin
  4566. Result:='jobs';
  4567. end;
  4568. Class Function TProjectsJobsResource.DefaultAPI : TGoogleAPIClass;
  4569. begin
  4570. Result:=TdataflowAPI;
  4571. end;
  4572. Function TProjectsJobsResource.Create(projectId: string; aJob : TJob; AQuery : string = '') : TJob;
  4573. Const
  4574. _HTTPMethod = 'POST';
  4575. _Path = '{projectId}/jobs';
  4576. _Methodid = 'dataflow.projects.jobs.create';
  4577. Var
  4578. _P : String;
  4579. begin
  4580. _P:=SubstitutePath(_Path,['projectId',projectId]);
  4581. Result:=ServiceCall(_HTTPMethod,_P,AQuery,aJob,TJob) as TJob;
  4582. end;
  4583. Function TProjectsJobsResource.Create(projectId: string; aJob : TJob; AQuery : TProjectsJobscreateOptions) : TJob;
  4584. Var
  4585. _Q : String;
  4586. begin
  4587. _Q:='';
  4588. AddToQuery(_Q,'replaceJobId',AQuery.replaceJobId);
  4589. AddToQuery(_Q,'view',AQuery.view);
  4590. Result:=Create(projectId,aJob,_Q);
  4591. end;
  4592. Function TProjectsJobsResource.Get(jobId: string; projectId: string; AQuery : string = '') : TJob;
  4593. Const
  4594. _HTTPMethod = 'GET';
  4595. _Path = '{projectId}/jobs/{jobId}';
  4596. _Methodid = 'dataflow.projects.jobs.get';
  4597. Var
  4598. _P : String;
  4599. begin
  4600. _P:=SubstitutePath(_Path,['jobId',jobId,'projectId',projectId]);
  4601. Result:=ServiceCall(_HTTPMethod,_P,AQuery,Nil,TJob) as TJob;
  4602. end;
  4603. Function TProjectsJobsResource.Get(jobId: string; projectId: string; AQuery : TProjectsJobsgetOptions) : TJob;
  4604. Var
  4605. _Q : String;
  4606. begin
  4607. _Q:='';
  4608. AddToQuery(_Q,'view',AQuery.view);
  4609. Result:=Get(jobId,projectId,_Q);
  4610. end;
  4611. Function TProjectsJobsResource.GetMetrics(jobId: string; projectId: string; AQuery : string = '') : TJobMetrics;
  4612. Const
  4613. _HTTPMethod = 'GET';
  4614. _Path = '{projectId}/jobs/{jobId}/metrics';
  4615. _Methodid = 'dataflow.projects.jobs.getMetrics';
  4616. Var
  4617. _P : String;
  4618. begin
  4619. _P:=SubstitutePath(_Path,['jobId',jobId,'projectId',projectId]);
  4620. Result:=ServiceCall(_HTTPMethod,_P,AQuery,Nil,TJobMetrics) as TJobMetrics;
  4621. end;
  4622. Function TProjectsJobsResource.GetMetrics(jobId: string; projectId: string; AQuery : TProjectsJobsgetMetricsOptions) : TJobMetrics;
  4623. Var
  4624. _Q : String;
  4625. begin
  4626. _Q:='';
  4627. AddToQuery(_Q,'startTime',AQuery.startTime);
  4628. Result:=GetMetrics(jobId,projectId,_Q);
  4629. end;
  4630. Function TProjectsJobsResource.List(projectId: string; AQuery : string = '') : TListJobsResponse;
  4631. Const
  4632. _HTTPMethod = 'GET';
  4633. _Path = '{projectId}/jobs';
  4634. _Methodid = 'dataflow.projects.jobs.list';
  4635. Var
  4636. _P : String;
  4637. begin
  4638. _P:=SubstitutePath(_Path,['projectId',projectId]);
  4639. Result:=ServiceCall(_HTTPMethod,_P,AQuery,Nil,TListJobsResponse) as TListJobsResponse;
  4640. end;
  4641. Function TProjectsJobsResource.List(projectId: string; AQuery : TProjectsJobslistOptions) : TListJobsResponse;
  4642. Var
  4643. _Q : String;
  4644. begin
  4645. _Q:='';
  4646. AddToQuery(_Q,'pageSize',AQuery.pageSize);
  4647. AddToQuery(_Q,'pageToken',AQuery.pageToken);
  4648. AddToQuery(_Q,'view',AQuery.view);
  4649. Result:=List(projectId,_Q);
  4650. end;
  4651. Function TProjectsJobsResource.Patch(jobId: string; projectId: string; aJob : TJob) : TJob;
  4652. Const
  4653. _HTTPMethod = 'PATCH';
  4654. _Path = '{projectId}/jobs/{jobId}';
  4655. _Methodid = 'dataflow.projects.jobs.patch';
  4656. Var
  4657. _P : String;
  4658. begin
  4659. _P:=SubstitutePath(_Path,['jobId',jobId,'projectId',projectId]);
  4660. Result:=ServiceCall(_HTTPMethod,_P,'',aJob,TJob) as TJob;
  4661. end;
  4662. Function TProjectsJobsResource.Update(jobId: string; projectId: string; aJob : TJob) : TJob;
  4663. Const
  4664. _HTTPMethod = 'PUT';
  4665. _Path = '{projectId}/jobs/{jobId}';
  4666. _Methodid = 'dataflow.projects.jobs.update';
  4667. Var
  4668. _P : String;
  4669. begin
  4670. _P:=SubstitutePath(_Path,['jobId',jobId,'projectId',projectId]);
  4671. Result:=ServiceCall(_HTTPMethod,_P,'',aJob,TJob) as TJob;
  4672. end;
  4673. Function TProjectsJobsResource.GetMessagesInstance : TProjectsJobsMessagesResource;
  4674. begin
  4675. if (FMessagesInstance=Nil) then
  4676. FMessagesInstance:=CreateMessagesResource;
  4677. Result:=FMessagesInstance;
  4678. end;
  4679. Function TProjectsJobsResource.CreateMessagesResource : TProjectsJobsMessagesResource;
  4680. begin
  4681. Result:=CreateMessagesResource(Self);
  4682. end;
  4683. Function TProjectsJobsResource.CreateMessagesResource(AOwner : TComponent) : TProjectsJobsMessagesResource;
  4684. begin
  4685. Result:=TProjectsJobsMessagesResource.Create(AOwner);
  4686. Result.API:=Self.API;
  4687. end;
  4688. Function TProjectsJobsResource.GetWorkItemsInstance : TProjectsJobsWorkItemsResource;
  4689. begin
  4690. if (FWorkItemsInstance=Nil) then
  4691. FWorkItemsInstance:=CreateWorkItemsResource;
  4692. Result:=FWorkItemsInstance;
  4693. end;
  4694. Function TProjectsJobsResource.CreateWorkItemsResource : TProjectsJobsWorkItemsResource;
  4695. begin
  4696. Result:=CreateWorkItemsResource(Self);
  4697. end;
  4698. Function TProjectsJobsResource.CreateWorkItemsResource(AOwner : TComponent) : TProjectsJobsWorkItemsResource;
  4699. begin
  4700. Result:=TProjectsJobsWorkItemsResource.Create(AOwner);
  4701. Result.API:=Self.API;
  4702. end;
  4703. { --------------------------------------------------------------------
  4704. TProjectsResource
  4705. --------------------------------------------------------------------}
  4706. Class Function TProjectsResource.ResourceName : String;
  4707. begin
  4708. Result:='projects';
  4709. end;
  4710. Class Function TProjectsResource.DefaultAPI : TGoogleAPIClass;
  4711. begin
  4712. Result:=TdataflowAPI;
  4713. end;
  4714. Function TProjectsResource.GetJobsMessagesInstance : TProjectsJobsMessagesResource;
  4715. begin
  4716. if (FJobsMessagesInstance=Nil) then
  4717. FJobsMessagesInstance:=CreateJobsMessagesResource;
  4718. Result:=FJobsMessagesInstance;
  4719. end;
  4720. Function TProjectsResource.CreateJobsMessagesResource : TProjectsJobsMessagesResource;
  4721. begin
  4722. Result:=CreateJobsMessagesResource(Self);
  4723. end;
  4724. Function TProjectsResource.CreateJobsMessagesResource(AOwner : TComponent) : TProjectsJobsMessagesResource;
  4725. begin
  4726. Result:=TProjectsJobsMessagesResource.Create(AOwner);
  4727. Result.API:=Self.API;
  4728. end;
  4729. Function TProjectsResource.GetJobsWorkItemsInstance : TProjectsJobsWorkItemsResource;
  4730. begin
  4731. if (FJobsWorkItemsInstance=Nil) then
  4732. FJobsWorkItemsInstance:=CreateJobsWorkItemsResource;
  4733. Result:=FJobsWorkItemsInstance;
  4734. end;
  4735. Function TProjectsResource.CreateJobsWorkItemsResource : TProjectsJobsWorkItemsResource;
  4736. begin
  4737. Result:=CreateJobsWorkItemsResource(Self);
  4738. end;
  4739. Function TProjectsResource.CreateJobsWorkItemsResource(AOwner : TComponent) : TProjectsJobsWorkItemsResource;
  4740. begin
  4741. Result:=TProjectsJobsWorkItemsResource.Create(AOwner);
  4742. Result.API:=Self.API;
  4743. end;
  4744. Function TProjectsResource.GetJobsInstance : TProjectsJobsResource;
  4745. begin
  4746. if (FJobsInstance=Nil) then
  4747. FJobsInstance:=CreateJobsResource;
  4748. Result:=FJobsInstance;
  4749. end;
  4750. Function TProjectsResource.CreateJobsResource : TProjectsJobsResource;
  4751. begin
  4752. Result:=CreateJobsResource(Self);
  4753. end;
  4754. Function TProjectsResource.CreateJobsResource(AOwner : TComponent) : TProjectsJobsResource;
  4755. begin
  4756. Result:=TProjectsJobsResource.Create(AOwner);
  4757. Result.API:=Self.API;
  4758. end;
  4759. { --------------------------------------------------------------------
  4760. TDataflowAPI
  4761. --------------------------------------------------------------------}
  4762. Class Function TDataflowAPI.APIName : String;
  4763. begin
  4764. Result:='dataflow';
  4765. end;
  4766. Class Function TDataflowAPI.APIVersion : String;
  4767. begin
  4768. Result:='v1b3';
  4769. end;
  4770. Class Function TDataflowAPI.APIRevision : String;
  4771. begin
  4772. Result:='20150417';
  4773. end;
  4774. Class Function TDataflowAPI.APIID : String;
  4775. begin
  4776. Result:='dataflow:v1b3';
  4777. end;
  4778. Class Function TDataflowAPI.APITitle : String;
  4779. begin
  4780. Result:='Google Dataflow API';
  4781. end;
  4782. Class Function TDataflowAPI.APIDescription : String;
  4783. begin
  4784. Result:='Google Dataflow API.';
  4785. end;
  4786. Class Function TDataflowAPI.APIOwnerDomain : String;
  4787. begin
  4788. Result:='google.com';
  4789. end;
  4790. Class Function TDataflowAPI.APIOwnerName : String;
  4791. begin
  4792. Result:='Google';
  4793. end;
  4794. Class Function TDataflowAPI.APIIcon16 : String;
  4795. begin
  4796. Result:='http://www.google.com/images/icons/product/search-16.gif';
  4797. end;
  4798. Class Function TDataflowAPI.APIIcon32 : String;
  4799. begin
  4800. Result:='http://www.google.com/images/icons/product/search-32.gif';
  4801. end;
  4802. Class Function TDataflowAPI.APIdocumentationLink : String;
  4803. begin
  4804. Result:='';
  4805. end;
  4806. Class Function TDataflowAPI.APIrootUrl : string;
  4807. begin
  4808. Result:='https://dataflow.googleapis.com/';
  4809. end;
  4810. Class Function TDataflowAPI.APIbasePath : string;
  4811. begin
  4812. Result:='/v1b3/projects/';
  4813. end;
  4814. Class Function TDataflowAPI.APIbaseURL : String;
  4815. begin
  4816. Result:='https://dataflow.googleapis.com/v1b3/projects/';
  4817. end;
  4818. Class Function TDataflowAPI.APIProtocol : string;
  4819. begin
  4820. Result:='rest';
  4821. end;
  4822. Class Function TDataflowAPI.APIservicePath : string;
  4823. begin
  4824. Result:='v1b3/projects/';
  4825. end;
  4826. Class Function TDataflowAPI.APIbatchPath : String;
  4827. begin
  4828. Result:='batch';
  4829. end;
  4830. Class Function TDataflowAPI.APIAuthScopes : TScopeInfoArray;
  4831. begin
  4832. SetLength(Result,2);
  4833. Result[0].Name:='https://www.googleapis.com/auth/cloud-platform';
  4834. Result[0].Description:='View and manage your data across Google Cloud Platform services';
  4835. Result[1].Name:='https://www.googleapis.com/auth/userinfo.email';
  4836. Result[1].Description:='View your email address';
  4837. end;
  4838. Class Function TDataflowAPI.APINeedsAuth : Boolean;
  4839. begin
  4840. Result:=True;
  4841. end;
  4842. Class Procedure TDataflowAPI.RegisterAPIResources;
  4843. begin
  4844. TApproximateProgress.RegisterObject;
  4845. TAutoscalingSettings.RegisterObject;
  4846. TComputationTopology.RegisterObject;
  4847. TDataDiskAssignment.RegisterObject;
  4848. TDerivedSource.RegisterObject;
  4849. TDisk.RegisterObject;
  4850. TDynamicSourceSplit.RegisterObject;
  4851. TEnvironmentTypesdkPipelineOptions.RegisterObject;
  4852. TEnvironmentTypeuserAgent.RegisterObject;
  4853. TEnvironmentTypeversion.RegisterObject;
  4854. TEnvironment.RegisterObject;
  4855. TFlattenInstruction.RegisterObject;
  4856. TInstructionInput.RegisterObject;
  4857. TInstructionOutputTypecodec.RegisterObject;
  4858. TInstructionOutput.RegisterObject;
  4859. TJob.RegisterObject;
  4860. TJobExecutionInfoTypestages.RegisterObject;
  4861. TJobExecutionInfo.RegisterObject;
  4862. TJobExecutionStageInfo.RegisterObject;
  4863. TJobMessage.RegisterObject;
  4864. TJobMetrics.RegisterObject;
  4865. TKeyRangeDataDiskAssignment.RegisterObject;
  4866. TKeyRangeLocation.RegisterObject;
  4867. TLeaseWorkItemRequest.RegisterObject;
  4868. TLeaseWorkItemResponse.RegisterObject;
  4869. TListJobMessagesResponse.RegisterObject;
  4870. TListJobsResponse.RegisterObject;
  4871. TMapTask.RegisterObject;
  4872. TMetricStructuredNameTypecontext.RegisterObject;
  4873. TMetricStructuredName.RegisterObject;
  4874. TMetricUpdate.RegisterObject;
  4875. TMountedDataDisk.RegisterObject;
  4876. TMultiOutputInfo.RegisterObject;
  4877. TPackage.RegisterObject;
  4878. TParDoInstructionTypeuserFn.RegisterObject;
  4879. TParDoInstruction.RegisterObject;
  4880. TParallelInstruction.RegisterObject;
  4881. TPartialGroupByKeyInstructionTypeinputElementCodec.RegisterObject;
  4882. TPartialGroupByKeyInstructionTypevalueCombiningFn.RegisterObject;
  4883. TPartialGroupByKeyInstruction.RegisterObject;
  4884. TPosition.RegisterObject;
  4885. TPubsubLocation.RegisterObject;
  4886. TReadInstruction.RegisterObject;
  4887. TReportWorkItemStatusRequest.RegisterObject;
  4888. TReportWorkItemStatusResponse.RegisterObject;
  4889. TSeqMapTaskTypeuserFn.RegisterObject;
  4890. TSeqMapTask.RegisterObject;
  4891. TSeqMapTaskOutputInfo.RegisterObject;
  4892. TShellTask.RegisterObject;
  4893. TSideInputInfoTypekind.RegisterObject;
  4894. TSideInputInfo.RegisterObject;
  4895. TSinkTypecodec.RegisterObject;
  4896. TSinkTypespec.RegisterObject;
  4897. TSink.RegisterObject;
  4898. TSourceTypebaseSpecsItem.RegisterObject;
  4899. TSourceTypecodec.RegisterObject;
  4900. TSourceTypespec.RegisterObject;
  4901. TSource.RegisterObject;
  4902. TSourceFork.RegisterObject;
  4903. TSourceGetMetadataRequest.RegisterObject;
  4904. TSourceGetMetadataResponse.RegisterObject;
  4905. TSourceMetadata.RegisterObject;
  4906. TSourceOperationRequest.RegisterObject;
  4907. TSourceOperationResponse.RegisterObject;
  4908. TSourceSplitOptions.RegisterObject;
  4909. TSourceSplitRequest.RegisterObject;
  4910. TSourceSplitResponse.RegisterObject;
  4911. TSourceSplitShard.RegisterObject;
  4912. TStatusTypedetailsItem.RegisterObject;
  4913. TStatus.RegisterObject;
  4914. TStepTypeproperties.RegisterObject;
  4915. TStep.RegisterObject;
  4916. TStreamLocation.RegisterObject;
  4917. TStreamingComputationRanges.RegisterObject;
  4918. TStreamingComputationTask.RegisterObject;
  4919. TStreamingSetupTask.RegisterObject;
  4920. TStreamingSideInputLocation.RegisterObject;
  4921. TStreamingStageLocation.RegisterObject;
  4922. TTaskRunnerSettings.RegisterObject;
  4923. TTopologyConfig.RegisterObject;
  4924. TWorkItem.RegisterObject;
  4925. TWorkItemServiceStateTypeharnessData.RegisterObject;
  4926. TWorkItemServiceState.RegisterObject;
  4927. TWorkItemStatus.RegisterObject;
  4928. TWorkerPoolTypemetadata.RegisterObject;
  4929. TWorkerPoolTypepoolArgs.RegisterObject;
  4930. TWorkerPool.RegisterObject;
  4931. TWorkerSettings.RegisterObject;
  4932. TWriteInstruction.RegisterObject;
  4933. end;
  4934. Function TDataflowAPI.GetProjectsJobsMessagesInstance : TProjectsJobsMessagesResource;
  4935. begin
  4936. if (FProjectsJobsMessagesInstance=Nil) then
  4937. FProjectsJobsMessagesInstance:=CreateProjectsJobsMessagesResource;
  4938. Result:=FProjectsJobsMessagesInstance;
  4939. end;
  4940. Function TDataflowAPI.CreateProjectsJobsMessagesResource : TProjectsJobsMessagesResource;
  4941. begin
  4942. Result:=CreateProjectsJobsMessagesResource(Self);
  4943. end;
  4944. Function TDataflowAPI.CreateProjectsJobsMessagesResource(AOwner : TComponent) : TProjectsJobsMessagesResource;
  4945. begin
  4946. Result:=TProjectsJobsMessagesResource.Create(AOwner);
  4947. Result.API:=Self.API;
  4948. end;
  4949. Function TDataflowAPI.GetProjectsJobsWorkItemsInstance : TProjectsJobsWorkItemsResource;
  4950. begin
  4951. if (FProjectsJobsWorkItemsInstance=Nil) then
  4952. FProjectsJobsWorkItemsInstance:=CreateProjectsJobsWorkItemsResource;
  4953. Result:=FProjectsJobsWorkItemsInstance;
  4954. end;
  4955. Function TDataflowAPI.CreateProjectsJobsWorkItemsResource : TProjectsJobsWorkItemsResource;
  4956. begin
  4957. Result:=CreateProjectsJobsWorkItemsResource(Self);
  4958. end;
  4959. Function TDataflowAPI.CreateProjectsJobsWorkItemsResource(AOwner : TComponent) : TProjectsJobsWorkItemsResource;
  4960. begin
  4961. Result:=TProjectsJobsWorkItemsResource.Create(AOwner);
  4962. Result.API:=Self.API;
  4963. end;
  4964. Function TDataflowAPI.GetProjectsJobsInstance : TProjectsJobsResource;
  4965. begin
  4966. if (FProjectsJobsInstance=Nil) then
  4967. FProjectsJobsInstance:=CreateProjectsJobsResource;
  4968. Result:=FProjectsJobsInstance;
  4969. end;
  4970. Function TDataflowAPI.CreateProjectsJobsResource : TProjectsJobsResource;
  4971. begin
  4972. Result:=CreateProjectsJobsResource(Self);
  4973. end;
  4974. Function TDataflowAPI.CreateProjectsJobsResource(AOwner : TComponent) : TProjectsJobsResource;
  4975. begin
  4976. Result:=TProjectsJobsResource.Create(AOwner);
  4977. Result.API:=Self.API;
  4978. end;
  4979. Function TDataflowAPI.GetProjectsInstance : TProjectsResource;
  4980. begin
  4981. if (FProjectsInstance=Nil) then
  4982. FProjectsInstance:=CreateProjectsResource;
  4983. Result:=FProjectsInstance;
  4984. end;
  4985. Function TDataflowAPI.CreateProjectsResource : TProjectsResource;
  4986. begin
  4987. Result:=CreateProjectsResource(Self);
  4988. end;
  4989. Function TDataflowAPI.CreateProjectsResource(AOwner : TComponent) : TProjectsResource;
  4990. begin
  4991. Result:=TProjectsResource.Create(AOwner);
  4992. Result.API:=Self.API;
  4993. end;
  4994. initialization
  4995. TDataflowAPI.RegisterAPI;
  4996. end.