4YshG<ddlmZmZddlmZmZmZddlmZddl m Z ddl m Z ddl mZ GddeZGd d eZd ZGd d eZGddeZGddeZGddeZGddeZGddeZGddeZGddeZy))LiteralXSD)_eval NotBoundError_val)numeric)type_promotion)SPARQLTypeError)Decimalc(eZdZdZdZdZdZdZy) Accumulatorz7abstract base class for different aggregation functionsc|j|_|j|_|js|j |_d|_y|j|_t|_y)NF) resvarvarsexprdistinct dont_careuse_rowsetseen)self aggregations /var/www/sten-cake5-migrate2.hellocrow.space/lexinfo-master/env/lib/python3.12/site-packages/rdflib/plugins/sparql/aggregates.py__init__zAccumulator.__init__sK??$$ ##>>DL!DM'00DMDIcy)zskips distinct testTrrows rrzAccumulator.dont_carercFt|j||jvS)ztests distinct with set)rrrrs rrzAccumulator.use_row sTYY$DII55rc>|j||j<y)zsets final value in bindingsN) get_valuerrbindingss r set_valuezAccumulator.set_value$s!^^-rN)__name__ __module__ __qualname____doc__rrrr'rrrr r sA6.rr c<eZdZfdZdZdZdZdZdZxZ S)Counterc|tt| |d|_|jdk(r|j |_yy)Nr*)superr-rvaluer eval_full_roweval_rowrr __class__s rrzCounter.__init__*s7 gt%k2 99  ..DM rc |j|}|xjdz c_|jr|jj |yy#t$rYywxYwN)r3rr1rradd)rr aggregatorvals rupdatezCounter.update1sT --$C a == IIMM#      sA AAc,t|jSN)rr1rs rr$zCounter.get_value;stzz""rc.t|j|Sr>)rrrs rr3zCounter.eval_row>sTYY$$rc|Sr>rrs rr2zCounter.eval_full_rowAs rc<|j||jvSr>)r3rrs rrzCounter.use_rowDs}}S!22r) r(r)r*rr<r$r3r2r __classcell__r5s@rr-r-)s!/#%3rr-cntd|Dr"td|Drtt|S|S)Nc3<K|]}t|tywr>) isinstancefloat.0args r z$type_safe_numbers..Is 2c:c5 ! 2c3<K|]}t|tywr>)rGr rIs rrLz$type_safe_numbers..Is;%( 3 ;rM)anymaprH)argss rtype_safe_numbersrRHs8 2T 22s;,0;85$ Krc*eZdZfdZdZdZxZS)SumcHtt| |d|_d|_yNr)r0rTrr1datatyper4s rrz Sum.__init__Qs  c4!+.  rcj t|j|}|j}| |j}nt||j}||_t t |j t||_|jr|jj|yy#t$rYywxYwr>) rrrWr sumrRr1rrrr9rrr r:r1dts rr<z Sum.updateVs $))S)EBz^^#B7DM.tzz75>JKDJ}} e$   sB"B&& B21B2cDt|j|jS)N)rW)rr1rWr?s rr$z Sum.get_valuefstzzDMM::rr(r)r*rr<r$rCrDs@rrTrTPs  ;rrTc*eZdZfdZdZdZxZS)AveragecVtt| |d|_d|_d|_yrV)r0r_rcounterrYrWr4s rrzAverage.__init__ks' gt%k2  rc t|j|}|j}tt |jt ||_| |j}nt ||j}||_|jr|jj||xjdz c_ y#t$rYyt$rYywxYwr7) rrrWrYrRrr rrr9rarr rZs rr<zAverage.updateqs $))S)EB,TXXwu~FGDHz^^#B7DM}} e$ LLA L     sB7B:: CCCc:|jdk(r tdS|jtjtj fvr"t|j |jz Stt|j t|jz SrV)rarrWrrHdoublerYr r?s rr$zAverage.get_valuesk <<1 1:  ==SYY 3 3488dll23 37488,wt||/DDE Err]rDs@rr_r_js &Frr_c.eZdZdZfdZdZdZxZS)Extremumz+abstract base class for Minimum and Maximumc\tt| |d|_|j|_yr>)r0rfrr1rrr4s rrzExtremum.__init__s$ h&{3 ~~ rcb|j#t|j||j<yyr>)r1rrr%s rr'zExtremum.set_values( :: !!(!4HTXX  "rc |jt|j||_y|j|jt|j||_y#t$rYyt $rYywxYwr>)r1rrcomparerr rr r:s rr<zExtremum.updatesc zz!"499c2 "\\$**eDIIs6KL      s'A 5A A6+A65A6)r(r)r*r+rr'r<rCrDs@rrfrfs5& 5 rrfceZdZdZy)Minimumc&t||tSN)key)minrrval1val2s rrjzMinimum.compare44((rNr(r)r*rjrrrrmrm)rrmceZdZdZy)Maximumc&t||tSro)maxrrrs rrjzMaximum.comparerurNrvrrrryryrwrryc.eZdZdZfdZdZdZxZS)Sampleztakes the first eligible valuecNtt| ||j|_yr>)r0r}rrrr4s rrzSample.__init__s fd$[1~~ rc t|j||j|j<|j|j=y#t $rYywxYwr>)rrr&r accumulatorsrrks rr<z Sample.updatesJ ,1$))S,AJ   )''1   sAA AAcyr>rr?s rr$zSample.get_valuer!r)r(r)r*r+rr<r$rCrDs@rr}r}s(& rr}c*eZdZfdZdZdZxZS) GroupConcatcdtt| |g|_|jxsd|_y)N )r0rrr1 separatorr4s rrzGroupConcat.__init__s+ k4)+6 $..5#rc t|j|}|jj||jr|j j |yy#t$rYywxYwr>)rrr1appendrrr9r)rr r:r1s rr<zGroupConcat.updatesY $))S)E JJ  e $}} e$   sAA A('A(clt|jjd|jDS)Nc32K|]}t|ywr>)str)rJvs rrLz(GroupConcat.get_value..s*Fa3q6*Fs)rrjoinr1r?s rr$zGroupConcat.get_values&t~~***F4::*FFGGrr]rDs@rrrs6 Hrrc6eZdZdZeeeeee e dZ dZ dZ dZy) Aggregatorz&combines different Accumulator objects)Aggregate_CountAggregate_Sample Aggregate_Sum Aggregate_Avg Aggregate_Min Aggregate_MaxAggregate_GroupConcatci|_i|_|D]`}|jj|j}|t d|jz|||j|j <by)NzUnknown aggregate function )r&raccumulator_classesgetname Exceptionr)r aggregationsaaccumulator_classs rrzAggregator.__init__so  rsFF3:8 .&.43k3>;+;4 Fk FF{8)h) )h) [,H+H*##r