z4TDigestCommandsMixin.tdigest_add..;s:::CU3ZZ:::r)r1rr2r8 ValueErrorTDIGEST_ERROR_PARSING_VALUEr4r)rr-r< values_to_adds r tdigest_addz TDigestCommandsMixin.tdigest_add0s 9 d9:: : @::6:::MM @ @ @d>?? ? @ ''' s /$Az TDIGEST.MERGEdestnumkeysct||kr,ttjd|d|}t ||dd\\}}}fd|D}t|t|krttj|rP|j0|ptd|D}t||_n|j |jttj|D]} |j | | tS)Nz tdigest.merge)r0overridec`g|]*}|jv j|j+Sr&)_dbgetr1)r@r)rs rrBz6TDigestCommandsMixin.tdigest_merge..Ms8ZZZQUQYIYIY48<<%%+IYIYIYrcg|] }|j Sr&)r)r@sources rrBz6TDigestCommandsMixin.tdigest_merge..Ss1[1[1[&2D1[1[1[r)lenrr2WRONG_ARGS_MSG6formatrr8r1maxrr9r4updatedr) rrGrHr' sources_namesrrJ_sourcesrOs ` r tdigest_mergez"TDigestCommandsMixin.tdigest_mergeBsQ t99w  d299/JJKK KXgX %1$wxx.B^%_%_"hZZZZ ZZZ w<<3}-- - -d9:: :  #z!)\S1[1[SZ1[1[1[-\-\ $[11    """ : d9:: : & &F J  f % % % %  rz TDIGEST.MAXc|jttjt |jdkrt dS|jdS)Nrnanr1rr2r8rPr?r:s r tdigest_maxz TDigestCommandsMixin.tdigest_max^sH 9 d9:: : sy>>Q  << y}rz TDIGEST.MINc|jttjt |jdkrt dS|jdS)NrrZr\r:s r tdigest_minz TDigestCommandsMixin.tdigest_minhsH 9 d9:: : sy>>Q  << y|rz TDIGEST.RANKc\|jttjt |jdkrdgSg}|D]k}||jdkr(|t |j;||j|dz l|S)Nrr[)r1rr2r8rPappend bisect_right)rr-r<resvs r tdigest_rankz!TDigestCommandsMixin.tdigest_rankrs 9 d9:: : sy>>Q    : :A39R=   3sy>>**** 3911!44q89999 rzTDIGEST.REVRANKc,|jttjt |jdkrdgSg}t |j}|D]?}|j|}||kr|dz }|||z @|S)Nrrarb)r1rr2r8rPrdrc)rr-r<relengthrflocs rtdigest_revrankz$TDigestCommandsMixin.tdigest_revranks 9 d9:: : sy>>Q  4KSY % %A)((++Cf}}q JJv| $ $ $ $ rzTDIGEST.QUANTILE quantilesc|jttjt |jdkrt dgSg}|D]}|dks|dkrttjt|t |jz}|t |jkr|dz}||j||S)NrbrZr) r1rr2r8rPr?TDIGEST_BAD_QUANTILEr!rc)rr-rlreqinds rtdigest_quantilez%TDigestCommandsMixin.tdigest_quantiles 9 d9:: : sy>>Q  %LL> ! ' 'A1uuA!$";<<<a#ci..())Cc#)nn$$q JJsy~ & & & & rz TDIGEST.CDFc|jttjg}|D]}|j|}|j|}|dkr|dR|t|jkr|d|t||zdz t|jz |S)zReturns, for each input value, an estimation of the fraction (floating-point) of (observations smaller than the given value + half the observations equal to the given value). Nrgg?) r1rr2r8 bisect_leftrdrcrPr?)rr-r<rerfleftrights r tdigest_cdfz TDigestCommandsMixin.tdigest_cdfs 9 d9:: : G GA9((++DI**1--Ezz 3SY'' 3 5$,!!344s39~~EFFFF rz TDIGEST.INFOc |jjt|jt|jdt|jdt|jt|jt|jd S)Nr) s CompressionsCapacitys Merged nodessUnmerged nodess Merged weightsUnmerged weights ObservationssTotal compressionss Memory usage)r1rrPr:s r tdigest_infoz!TDigestCommandsMixin.tdigest_infosc  I1SY ^^ !#)nn ! ^^#&sy>> ^^   rzTDIGEST.TRIMMED_MEANlowerupperc|jttj|dks |dks||krttjt |jdkrt dSt|t |jz}t|t |jz}|j||zdz}||dzkr||j|zdz }|S)NrrbrZrs)r1rr2r8rnrPr?r!)rr-rzr{rurvres rtdigest_trimmed_meanz)TDigestCommandsMixin.tdigest_trimmed_means 9 d9:: : 199 UU]]d788 8 sy>>Q  << 53sy>>)**EC NN*++i!+, D1H  5))Q.C rzTDIGEST.BYRANKranksc|jttjt |jdkrt dgSg}|D]|}|dkrttj|t |jkr#|t d\||j|}|S)NrrZinfr1rr2r8rPr?TDIGEST_BAD_RANKrcrr-r~reranks rtdigest_byrankz#TDigestCommandsMixin.tdigest_byranks 9 d9:: : sy>>Q  %LL> ! , ,Daxx!$"7888s39~~%% 5<<(((( 39T?++++ rzTDIGEST.BYREVRANKc|jttjt |jdkrt dgSg}|D]}|dkrttj|t |jkr#|t d\||j| dz |S)NrrZz-infrbrrs rtdigest_byrevrankz&TDigestCommandsMixin.tdigest_byrevranks 9 d9:: : sy>>Q  %LL> ! 1 1Daxx!$"7888s39~~%% 5==)))) 39dUQY/0000 rN)"rrr rr r rbytesr2FLAG_DO_NOT_CREATEFLAG_LEAVE_EMPTY_VALr rr6r;r r?rFr r!rXr]r_rrgrkrqrwrrryr}rrr&rrr$r$s. W s7||ox%(AA  +e    W s7||o%(AA      W s7||U#x%(AA  { U |      W s7||S%(x%(AA  +El  , W 33w<rs """"""""""''''''######888888EEEEEEEEEEEEEEFFFFFFFFFFFF'''''j''' CCCCCCCCCCr