Ë
|
nñúh¤ ã ó d Z ddlmZ ddlZddlZddlmZmZmZm Z m
|
Z
|
ddl Z ddl mZmZ ddlmc mZ ddlmZmZmZmZmZ ddlmZ ddl m Z dd l m Z m Z dd
|
l!m"Z"m#Z#m$Z$m%Z%m&Z& dd l'm(Z(m)Z) dd l*m+Z+ dd l,m-Z- ddl.m/Z/m0Z0m1Z1m2Z2 ddl3m4Z4 ddl5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z; erddl<m=Z=m>Z>m?Z? ddl@mAZA d$dZBd ZC G d d« ZD G d d« ZE G d deE« ZFd%dZG G d d e e « ZH G d d eH« ZI G d d!eH« ZJdd" d&d#ZKy)'a
|
Provide classes to perform the groupby aggregate operations.
|
|
These are not exposed to the user and provide implementations of the grouping
|
operations, primarily in cython. These classes (BaseGrouper and BinGrouper)
|
are contained *in* the SeriesGroupBy and DataFrameGroupBy objects.
|
é )Ú annotationsN)Ú TYPE_CHECKINGÚAnyÚCallableÚGenericÚfinal)ÚNaTÚlib)Ú ArrayLikeÚAxisIntÚNDFrameTÚShapeÚnpt©ÚAbstractMethodError)Úcache_readonly)Úmaybe_cast_pointwise_resultÚmaybe_downcast_to_dtype)Úensure_float64Ú ensure_int64Úensure_platform_intÚ ensure_uint64Úis_1d_only_ea_dtype)ÚisnaÚ
|
maybe_fill)Ú DataFrame)Úgrouper)ÚCategoricalIndexÚIndexÚ
|
MultiIndexÚ ensure_index)ÚSeries)Úcompress_group_indexÚdecons_obs_group_idsÚget_flattened_listÚget_group_indexÚget_group_index_sorterÚget_indexer_dict)ÚHashableÚIteratorÚSequence)ÚNDFramec ób t | t j « r|t k7 r t d« y y )Nz Must produce aggregated value)Ú
|
isinstanceÚnpÚndarrayÚobjectÚ
|
ValueError)ÚobjÚdtypes úJH:\Change_password\venv_build\Lib\site-packages\pandas/core/groupby/ops.pyÚcheck_result_arrayr6 Q s1 ô #rzzÔ"Ø F?ô Ð <Ó=Ð =ð ð #ó c óz t | d« r.| j } | j dk( rt | « dk( r| d } | S )zb
|
Extract the result object, it might be a 0-dim ndarray
|
or a len-1 0-dim, or a scalar
|
Ú_valuesé r )Úhasattrr9 ÚndimÚlen)Úress r5 Úextract_resultr? \ s: ô
|
sIÔ àkkØ 88q=S X¨]àa&CØ Jr7 c ó. e Zd ZU dZ eg d¢« Zd<dZi d ej e j d¬« d ej e j d¬« ddd d
|
d ej e j d ¬ « d ej e j d ¬ « ddddddddddd ej e j d¬ « d ej e j d¬ « ddd d d d d d!d"d#d$d%d&d'd(Z d)ed*< d d+iZed=d,« Zeej$ d>d-« « Zd?d.Zd@d/ZdAd0ZdAd1Zed2d2d3d4 dBd5« Zed3d6 dBd7« ZedCd8« Zed9d: dDd;« Z y2)EÚWrappedCythonOpaB
|
Dispatch logic for functions defined in _libs.groupby
|
|
Parameters
|
----------
|
kind: str
|
Whether the operation is an aggregate or transform.
|
how: str
|
Operation name, e.g. "mean".
|
has_dropped_na: bool
|
True precisely when dropna=True and the grouper contains a null value.
|
)ÚanyÚallÚrankÚcountÚsizeÚidxminÚidxmaxc ó. || _ || _ || _ y ©N©ÚkindÚhowÚhas_dropped_na)ÚselfrL rM rN s r5 Ú__init__zWrappedCythonOp.__init__~ s Ø ØØ ,Õr7 rB )Úval_testrC ÚsumÚ group_sumÚprodÚ
|
group_prodrG )ÚnamerH ÚminÚ group_minÚmaxÚ group_maxÚmeanÚ
|
group_meanÚmedianÚgroup_median_float64ÚvarÚ group_varÚstdÚsemÚskewÚ
|
group_skewÚfirstÚ group_nthÚlastÚ
|
group_lastÚohlcÚ
|
group_ohlcÚ group_cumprodÚ group_cumsumÚ group_cumminÚ group_cummaxÚ
|
group_rank)ÚcumprodÚcumsumÚcumminÚcummaxrD )Ú aggregateÚ transformzdict[str, dict]Ú_CYTHON_FUNCTIONSé c ó( || j d v ryy)Nrt ru )rv )ÚclsrM s r5 Úget_kind_from_howz!WrappedCythonOp.get_kind_from_how¢ s à #×'Ñ'¨ Ñ4Ñ 4Ø Ør7 c ó^ |j }| j | | }t |« r|}nt t |« }|r|S |t j t « k( rF|dv rt d| d| d« |dv r|S |dk( r |S d|j vrt d| d| d« |S t d|« ) N)r] rp z2function is not implemented for this dtype: [how->z,dtype->ú])ra rb rG rH rc r1 zPThis should not be reached. Please report a bug at github.com/pandas-dev/pandas/)
|
rV rv ÚcallableÚgetattrÚ
|
libgroupbyr/ r4 r1 ÚNotImplementedErrorÚ__signatures__)ry rL rM r4 Ú
|
is_numericÚ dtype_strÚftypeÚfs r5 Ú_get_cython_functionz$WrappedCythonOp._get_cython_functionª só ð
|
JJ Ø×%Ñ% dÑ+¨CÑ0ô E?ØAä
|
EÓ*AÙ ØHØ bhhvÓ&Ò &ØÐ+Ñ+ä)ð Ø E ¨)¨°Að7óð ð Ð:Ñ:àØ àð Hð ×!1Ñ!1Ñ1ä)ð Ø E ¨)¨°Að7óð ð Hä%ð0àóð r7 c ó2 | j }|dv r t |« }|S |j j dv ra|dv s| j dk( r| j r t |« }|S |dv r1|j j dk( r t |« }|S t |« }|S )zÖ
|
Cast numeric dtypes to float64 for functions that only support that.
|
|
Parameters
|
----------
|
values : np.ndarray
|
|
Returns
|
-------
|
values : np.ndarray
|
)r] ra rb rc Úiu)r_ r[ ru )rR ri rT rq rp Úi)rM r r4 rL rN r r )rO ÚvaluesrM s r5 Ú_get_cython_valsz WrappedCythonOp._get_cython_valsÕ s« ð hhà Ð2Ñ 2ô $ FÓ+Fð" ð \\× Ñ $Ñ &ØoÑ%Ø [Ò(¨T×-@Ò-@ô (¨Ó/ð ð ÐDÑDà<<×$Ñ$¨Ò+Ü )¨&Ó 1Fð ô +¨6Ó 2Fà r7 c óð | j }| j }| j j |d« }|dk( r||f}|S |dkD r t d« |dk( r|j
|
}|S |f|j
|
dd z }|S )Nr: ri z<arity of more than 1 is not supported for the 'how' argumentru )rM rL Ú _cython_arityÚgetr Úshape)rO Úngroupsr rM rL ÚarityÚ out_shapes r5 Ú_get_output_shapez!WrappedCythonOp._get_output_shapeú s ØhhØyyà×"Ñ"×&Ñ& s¨AÓ.ð &=Ø %Ð(Ið Ðð QYÜ%ØNóð ð [Ò Ø Ið Ðð !
|
V§\¡\°!°"Ð%5Ñ5IØÐr7 c ó¸ | j }|dk( rd}n2|dv rd}n+|j dv r|j |j }nd}t j |« S )NrD Úfloat64©rG rH ÚintpÚiufcbr1 )rM rL Úitemsizer/ r4 )rO r4 rM Ú out_dtypes r5 Ú_get_out_dtypez WrappedCythonOp._get_out_dtype s^ Øhhà &=Ø!IØ Ð(Ñ (ð IàzzWÑ$Ø $zzl¨5¯>©>Ð*:Ð ; à $ Üxx Ó"Ð"r7 c ó2 | j }|dv rA|t j t « k( r#t j t j « S |S |dv rA|j
|
dv r|S |j
|
dv r#t j t j « S |S )a
|
Get the desired dtype of a result based on the
|
input dtype and how it was computed.
|
|
Parameters
|
----------
|
dtype : np.dtype
|
|
Returns
|
-------
|
np.dtype
|
The desired dtype of the result.
|
)rR rq rR rT rp )r[ r] r_ ra rb ÚfcÚiub)rM r/ r4 ÚboolÚint64rL r )rO r4 rM s r5 Ú_get_result_dtypez!WrappedCythonOp._get_result_dtype s ð hhà Ð=Ñ =ؤÒ&Üxx¤§¡Ó)Ð)ð ð Ð;Ñ ;ØzzTÑ!Ø ØuÑ$Üxx¤§
|
¡
|
Ó+Ð+Ø r7 Nr )ÚmaskÚ result_maskÚinitialc
|
ó |j dk( r\|d d d
f } | |d d d
f }| |d d d
f } | j | f||||||d|¤}
|
|
|
j d dk( r|
|
d S |
|
j S | j |f||||||d|¤S )Nr: )Ú min_countr Úcomp_idsr¢ r£ r¤ r )r< Ú_call_cython_opr ÚT) rO r r¦ r r§ r¢ r£ r¤ ÚkwargsÚvalues2dr> s r5 Ú_cython_op_ndim_compatz&WrappedCythonOp._cython_op_ndim_compat7 sÙ ð ;;!Ò à d¢AgHØÐ ØD¢!G}ØÐ&Ø )¨$²¨'Ñ 2 Ø&$×&Ñ&Øð à#Ø Ø!ØØ 'Ø ñ ð ñ Cð yy|qÒ Ø1v ð 55Là#t×#Ñ#Ø ð
|
à ØØ ØØ#Øñ
|
ð ñ
|
ð
|
r7 )r¤ c ó
|
|} |j }
|
|
|
j dv } |
|
j dv } | r|j d« }d} n |
|
j dk( r|j d« }|j dk( r |j t j
|
« }| j dv rv| t |« }|
|
t k( r*|d r%|j « r|j « }d||< |j t d
|
¬ « j t j « }d} |j }||j }| |j }| j ||« } | j | j | j |j | « }| j! |« }| j# |j « }t% t j& | |¬ « « }| j d k( rt j( |t j* ¬ « }| j dv r&| j dk( r||d< |d#|||||||| d|¤ nÝ| j dv r$| j dv r| |d< |||||f|||d|¤ n«| j dv r& |d#|||||d|¤ |j t d
|
¬ « }nw| j dv r. |d#||||||d|¤ |
|
t k( rQ|j t « }n;t- | j d« | j dk7 r||d< |d#||||| |d |¤ | j d k( r| j d vr|j j d v rn| slt/ | j d v rd nd!|« }|k }|j « r;||| j1 « s&J |j d"« }t j2 ||< |j }| j | j4 vr)| j7 | j « }t9 ||« }|S |}|S )$Nr ÚmMr TÚbÚuint8Úfloat16)rB rC ÚskipnaF)Úcopy©r4 rt )rG rH rW rY r[ rg re rR rR r¤ )ÚoutÚcountsr Úlabelsr¦ r¢ r£ Úis_datetimelike)rb ra r_ ri rT r] )ra rb r¸ )r¦ r¢ r£ )rµ r r· r¢ r£ )rc )rµ r¶ r r· r¢ r£ z is not implementedrD r£ )rµ r r· r r¸ r¢ r r )rR rT r r: r © ) r4 rL ÚviewÚastyper/ Úfloat32rM r r1 rB r³ r Úint8r© r r r r r ÚemptyÚzerosr r rY rC ÚnanÚcast_blocklistr¡ r )rO r r¦ r r§ r¢ r£ r¤ rª Ú orig_valuesr4 r r¸ r Úfuncr Úresultr¶ ÚcutoffÚ empty_groupsÚ res_dtypeÚ op_results r5 r¨ z WrappedCythonOp._call_cython_opf s% ð à ØZZ 7Ð*
|
à **¨Ð,á Ø[[ Ó)FØ JØ ZZ3Ò Ø[[ Ó)FØ <<9Ò $Ø]]¤2§:¡:Ó.Fà 88~Ñ %Ø|ÜF|ØØ(Ò#àxxzà!'§¡£ Ø'+t Ø]]¤4¨e]Ó4×9Ñ9¼"¿'¹'ÓBFØ JàØ Ð Ø66DØÐ&Ø )mm à×*Ñ*¨7°FÓ; Ø×(Ñ(¨¯©°D·H±H¸f¿l¹lÈJÓWØ×&Ñ& vÓ.Ø×'Ñ'¨¯ © Ó5 äBHH Y°iÔ @ÓAØ 99 Ó #ÜXXg¬R¯X©XÔ6FØxxð ñ ð 88uÒ$ð )0F9Ñ%Ùð
|
Ø Ø!Ø!Ø#Ø 'Ø Ø +Ø$3ñ
|
ð ó
|
ð Ð LÑLØ88~Ñ-Ø0?FÐ,Ñ-ÙØØØØ ð ð
|
(Ø Ø +ñ ð ó ð ^Ñ+Ùð Ø Ø!Ø#Ø Ø +ñ ð ò ð ¤t°% Ó8ØXÑ%Ùð Ø Ø!Ø!Ø#Ø Ø +ñ ð òð F?Ø #]]¬6Ó 2Fô *¨T¯X©X¨JÐ6IÐ*JÓKÐKð xx6Ò!à(3}Ñ%Ù ð ØØ Ø Ø Ø /Øñ ð ò ð 99 Ò #¨¯©Ð8LÑ(Lð ||× Ñ DÑ(± ä $§(¡(¨oÑ"=QÀ1ÀiÓPØ %¨ Ø ×#Ñ#Ô%Ø"Ð.Ø *¨<Ñ 8× <Ñ <Ô >Ð>Ð >ð "(§ ¡ ¨yÓ!9Ü/1¯v©v|Ñ,àà 884×.Ñ.Ñ .ð
|
×.Ñ.¨{×/@Ñ/@ÓAIÜ/°¸ ÓBIð Ðð IàÐr7 c óª |j dkD r t d« |j dk( r |dk( sJ |« y t |j « s|dk( sJ y y )Né z.number of dimensions is currently limited to 2r: r )r< r r r4 )rO Úaxisr s r5 Ú_validate_axisz WrappedCythonOp._validate_axis sU à ;;?Ü%Ð&VÓWÐ WØ ;;!Ò Ø19Ð "dÓ "9Ü$ V§\¡\Ô2ð 19Ð 9ð 3r7 éÿÿÿÿ)r¦ c óâ | j ||« t |t j « s, |j d| j
|
| j |||d|¤S | j |f|||dd|¤S )zW
|
Call our cython function, with appropriate pre- and post- processing.
|
)rM rN r¦ r ÚidsN)r¦ r r§ r¢ r¹ )rÌ r. r/ r0 Ú _groupby_oprM rN r¬ )rO r rË r¦ r§ r rª s r5 Úcython_operationz WrappedCythonOp.cython_operation s ð ×ÑD &Ô)ä&¤"§*¡*Ô-à%6×%Ñ%ð ØHHØ #× 2Ñ 2Ø#Ø Ø ñ ð ñ ð ð +t×*Ñ*Ø ð
|
à ØØ Øñ
|
ð ñ
|
ð
|
r7 )rL ÚstrrM rÒ rN r ÚreturnÚNone)rM rÒ rÓ rÒ )rL rÒ rM rÒ r4 únp.dtyper r )r ú
|
np.ndarrayrÓ rÖ )r Úintr rÖ rÓ r )r4 rÕ rÓ rÕ )r rÖ r¦ r× r r× r§ rÖ r¢ ú npt.NDArray[np.bool_] | Noner£ rØ r¤ r rÓ rÖ )rË r r r rÓ rÔ ) r r rË r r¦ r× r§ rÖ r r× rÓ r ) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú frozensetrÁ rP Ú functoolsÚpartialr Ú group_any_allÚgroup_idxmin_idxmaxr` rv Ú__annotations__r Ú classmethodrz Úcacher r r r r¡ r r¬ r¨ rÌ rÑ r¹ r7 r5 rA rA j sN
ñ ñ ÚCóNó-ð
|
Ø Ð$9×$Ñ$ Z×%=Ñ%=ÈÔNð
|
à Ð$9×$Ñ$ Z×%=Ñ%=ÈÔNð
|
ð ;ð
|
ð Lð
|
ð
|
Ð'i×'Ñ'¨
|
×(FÑ(FÈXÔVð
|
ð Ð'i×'Ñ'¨
|
×(FÑ(FÈXÔVð
|
ð ;ð
|
ð ;ð
|
ð Lð
|
ð Ð,ð
|
ð ;ð
|
ð Ð$9×$Ñ$ Z×%9Ñ%9ÀÔFð
|
ð Ð$9×$Ñ$ Z×%9Ñ%9ÀÔFð
|
ð Lð
|
ð [ð
|
ð Lð!
|
ð" Lð#
|
ð( 'Ø$Ø$Ø$Ø ñ
|
ñ)*Ðó ð: QKMàòó ðð Ø__ð'Øð'Ø ð'Ø)1ð'Ø?Cò'ó ó ð'óR#óJó&#ó ð4 ð .2Ø48Øñ,
|
àð,
|
ð ð ,
|
ð
|
ð ,
|
ð ð ,
|
ð +ð,
|
ð 2ð,
|
ð ð,
|
ð
|
ò,
|
ó ð,
|
ð\ ð ñ`àð`ð ð `ð
|
ð `ð ð `ð +ð`ð 2ð`ð ð`ð
|
ò`ó ð`ðD ò ó ð ð ð ñ !
|
ð ð!
|
ð ð !
|
ð
|
ð !
|
ð ð !
|
ð ð!
|
ð
|
ò!
|
ó ñ!
|
r7 rA c óÐ e Zd ZU dZded< d# d$dZed%d« Zed&d« Zd'dZ ed(d« Z
|
d) d*d Z e d)d+d
|
« Z e ed « « Zed,d « Ze d-d « Ze ed.d« « Zed/d« Zed0d« Ze d1d« Zed2d« Ze ed3d« « Ze ed3d« « Zed4d« Zed-d« Ze d5d« Ze ed(d« « Z ed6d« Z ed7d« Z e d8d« Z e d9 d:d « Z e d; d<d « Z!e d=d « Z"e d) d>d « Z#e ed-d « « Z$e ed-d!« « Z%y")?Ú BaseGroupera
|
This is an internal Grouper class, which actually holds
|
the generated groups
|
|
Parameters
|
----------
|
axis : Index
|
groupings : Sequence[Grouping]
|
all the grouping instances to handle in this grouper
|
for example for grouper list to groupby, need to pass the list
|
sort : bool, default True
|
whether this grouper will give sorted result or not
|
|
r rË c ó| t |t « sJ |« || _ t |« | _ || _ || _ y rJ )r. r rË ÚlistÚ
|
_groupingsÚ_sortÚdropna)rO rË Ú groupingsÚsortrë s r5 rP zBaseGrouper.__init__K s9 ô $¤Ô&Ð,¨Ó,Ð&à Ü26°y³/Ø
|
Ø r7 c ó | j S rJ )ré ©rO s r5 rì zBaseGrouper.groupingsY s àÐ r7 c ó: t d | j D « « S )Nc 3 ó4 K | ] }|j y wrJ )r )Ú.0Úpings r5 ú <genexpr>z$BaseGrouper.shape.<locals>.<genexpr>_ s è ø Ò= dT\\Ñ=ùs )Útuplerì rï s r5 r zBaseGrouper.shape] s äÑ=¨d¯n©nÔ=Ó=Ð=r7 c ó, t | j « S rJ )ÚiterÚindicesrï s r5 Ú__iter__zBaseGrouper.__iter__a s ÜDLLÓ!Ð!r7 c ó, t | j « S rJ )r= rì rï s r5 ÚnkeyszBaseGrouper.nkeysd s ä4>>Ó"Ð"r7 c # óv K | j ||¬« }| j }t ||« E d{ y7 w)ú
|
Groupby iterator
|
|
Returns
|
-------
|
Generator yielding sequence of (name, subsetted object)
|
for each group
|
©rË N)Ú _get_splitterÚgroup_keys_seqÚzip)rO ÚdatarË ÚsplitterÚkeyss r5 Ú get_iteratorzBaseGrouper.get_iteratorh s8 è ø ð ×%Ñ% d°Ð%Ó6Ø×"Ñ"ÜtXÓ&×&Ò&ús /9±7²9c ól | j \ }}}t |||| j | j |¬« S )zV
|
Returns
|
-------
|
Generator yielding subsetted objects
|
)Ú
|
sorted_idsÚsort_idxrË )Ú
|
group_inforÿ Ú _sorted_idsÚ _sort_idx)rO r rË rÏ Ú_r s r5 rÿ zBaseGrouper._get_splitterw s< ð //QÜ Ø Ø Ø Ø×'Ñ'Ø^^Øô
|
ð
|
r7 c ó´ t | j « dk( r| j d S | j \ }}}t ||| j | j
|
« S ©Nr: r )r= rì Úlevelsr r% Úcodes©rO rÏ r r s r5 r zBaseGrouper.group_keys_seq sM ô t~~Ó !Ò #Ø;;q>Ð !à "ooOCGô & c¨7°D·K±KÀÇÁÓLÐ Lr7 c óP t | j « dk( r3t | j t « r| j d j
|
S | j D cg c] }|j }}| j D cg c] }|j }}t ||« S c c}w c c}w )z"dict {group name -> group indices}r: r ) r= rì r. Ú result_indexr rø r Ú _group_indexr( )rO ró Ú
|
codes_listr s r5 rø zBaseGrouper.indices s ô t~~Ó !Ò #¬
|
°4×3DÑ3DÔFVÔ(Wà>> !Ñ$×,Ñ,Ð ,Ø-1¯^©^Ö< TdjjÐ<
|
Ð<Ø.2¯n©nÖ= d×!Ó!Ð=Ð=Ü
|
¨DÓ1Ð1ùò =ùÚ=s ÁB Á=B#c ó t | j | j | j d¬« }t || j ¬« \ }}| j
|
r8t j |dk\ « }t j |dk( « | }|| }t || j « }| j
|
r|t j |« z }|S )zR
|
Get the original integer locations of result_index in the input.
|
T©rí Úxnull©rí r rÍ ) r& r r rê r# rN r/ Úwhererq r' r Útake)rO Ú group_indexr r¢ Ú null_gapsrÄ s r5 Ú result_ilocszBaseGrouper.result_ilocs sª ô &Ø JJ
|
|
¨¯©¸4ô
|
ô .¨kÀÇ
|
Á
|
ÔK Qà × Ò Ü88K¨1Ñ ,Ó-Dä +°Ñ"3Ó4°TÑ:IØ% dÑ+Kä'¨ °T·\±\ÓBà × Ò à bggi¨Ó0Ñ 0Fà r7 c óT | j D cg c] }|j c}S c c}w rJ )rì r ©rO ró s r5 r zBaseGrouper.codes¸ s ð (,§~¡~Ö6t
|
|
Ò6Ð6ùÒ6ó %c óT | j D cg c] }|j c}S c c}w rJ )rì r r s r5 r zBaseGrouper.levels½ s à.2¯n©nÖ= d×!Ó!Ò=Ð=ùÒ=r! c óT | j D cg c] }|j c}S c c}w rJ )rì rV r s r5 ÚnameszBaseGrouper.namesÁ s à&*§n¡nÖ5d Ò5Ð5ùÒ5r! c ó | j \ }}}|r t j ||dk7 |¬« }ng }t || j dd¬« S )z&
|
Compute group sizes.
|
rÍ )Ú minlengthr F)Úindexr4 r³ )r r/ Úbincountr" r )rO rÏ r r rµ s r5 rF zBaseGrouper.sizeÅ sJ ð
|
//Qá Ü++c #¨¡)n¸Ô@CàCÜc ×!2Ñ!2¸'ÈÔNÐNr7 c ó t | j « dk( r| j d j S g }| j D ]X }|j }t |t
|
« s|j |« 1|j |j d j « Z t j |« }| j j |« S )ú!dict {group name -> group labels}r: r ) r= rì ÚgroupsÚgrouping_vectorr. ræ Úappendr Ú from_arraysrË Úgroupby)rO Ú
|
to_groupbyró Úgvr' s r5 r+ zBaseGrouper.groupsÒ sª ô t~~Ó !Ò #Ø>> !Ñ$×+Ñ+Ð +àJØ ò GØ×)Ñ)Ü! "¤kÔ2Ø ×%Ñ% bÕ)à ×%Ñ% b§l¡l°1¡o×&EÑ&EÕFð Gô ×*Ñ*¨:Ó6EØ99×$Ñ$ UÓ+Ð +r7 c óF t | j d « j S ©Nr )r r Úis_monotonic_increasingrï s r5 Ú is_monotoniczBaseGrouper.is_monotonicâ s ô T__ QÑ'Ó(×@Ñ@Ð@r7 c óT t | j d dk j « « S )zE
|
Whether grouper has null value(s) that are dropped.
|
r )r r rB rï s r5 rN zBaseGrouper.has_dropped_naè s& ô T__ QÑ'¨!Ñ+×0Ñ0Ó2Ó3Ð3r7 c ó^ | j « \ }}t |« }t |« }|||fS rJ )Ú_get_compressed_codesr= r )rO r§ Ú obs_group_idsr s r5 r zBaseGrouper.group_infoð s6 à"&×"<Ñ"<Ó">Ñ -ämÓ$Ü& xÓ0à ¨Ð/Ð/r7 c ó& | j \ }}}|S rJ )r ©rO rÏ r s r5 Ú
|
codes_infozBaseGrouper.codes_infoù s ð OO QØ
|
r7 c óL t | j « dkD r:t | j | j dd¬« }t || j ¬« S | j d }|j t j t |j « t j ¬« fS )Nr: Tr r r r´ ) r= rì r& r r r# rê r/ Úaranger r )rO r ró s r5 r8 z!BaseGrouper._get_compressed_codesÿ sx ô
|
t~~Ó Ò "Ü)¨$¯*©*°d·j±jÀtÐSWÔXKÜ'¨ ¸$¿*¹*ÔEÐ Eð ~~aÑ Øzz299¤S¨×):Ñ):Ó%;Ä2Ç7Á7ÔKÐKÐKr7 c ó, t | j « S rJ )r= r rï s r5 r zBaseGrouper.ngroups s ô 4×$Ñ$Ó%Ð%r7 c ón | j }| j \ }}}t ||| j |d¬« S )NT)r )r r r$ r )rO r rÏ Úobs_idsr s r5 Úreconstructed_codesz BaseGrouper.reconstructed_codes s1 à
|
|
Ø //WaÜ# C¨°$·*±*¸eÈ4ÔPÐPr7 c ó6 t | j « dk( r5| j d j j | j d « S | j
|
}| j D cg c] }|j }}t ||d| j ¬« S c c}w )Nr: r F)r r Úverify_integrityr$ )r= rì Ú _result_indexÚrenamer$ rB r )rO r ró r s r5 r zBaseGrouper.result_index s ä t~~Ó !Ò #Ø>> !Ñ$×2Ñ2×9Ñ9¸$¿*¹*ÀQ¹-ÓHÐ Hà×(Ñ(Ø15· ± Ö@¨$×$Ó$Ð@Ð@ÜØ ¸ÀdÇjÁjô
|
ð
|
ùò As Á(Bc ó, t | j « dk( r| j d j gS g }t | j | j « D ]< \ }}t |« }|j j |« }|j |« > |S r )r= rì Ú_group_arrayliker rB r r r- )rO Ú name_listró r r s r5 Úget_group_levelsz BaseGrouper.get_group_levels" s ô t~~Ó !Ò #ØNN 1Ñ%×6Ñ6Ð7Ð 7à Ü t~~¨t×/GÑ/GÓHò %KD%Ü'¨Ó.EØ×*Ñ*×/Ñ/°Ó6Fà × Ñ VÕ $ð %ð Ðr7 c ó¦ |dv sJ t ||| j ¬« }| j \ }} } | j }
|
|j d|||||
|
d|¤S )z;
|
Returns the values of a cython operation.
|
)ru rt rK )r rË r¦ r§ r r¹ )rA rN r r rÑ ) rO rL r rM rË r¦ rª Úcy_oprÏ r r s r5 Ú_cython_operationz BaseGrouper._cython_operation5 sr ð Ð1Ñ1Ð1Ð1ä T¨sÀ4×CVÑCVÔWàOO QØ,,Ø%u×%Ñ%ð
|
ØØØ ØØñ
|
ð ñ
|
ð
|
r7 c óà t |j t j « sd}| j ||« }t j |d¬« }|rt ||j d¬« }|S |}|S )a1
|
Parameters
|
----------
|
obj : Series
|
func : function taking a Series and returning a scalar-like
|
preserve_dtype : bool
|
Whether the aggregation is known to be dtype-preserving.
|
|
Returns
|
-------
|
np.ndarray or ExtensionArray
|
TF)Ú try_float)Ú numeric_only) r. r9 r/ r0 Ú _aggregate_series_pure_pythonr
|
Úmaybe_convert_objectsr r4 )rO r3 rà Úpreserve_dtyperÄ Únpvaluesrµ s r5 Ú
|
agg_serieszBaseGrouper.agg_seriesQ sj ô" #++¤r§z¡zÔ2ð
|
"Nà×3Ñ3°C¸Ó>ä×,Ñ,¨V¸uÔEÙ Ü-¨h¸¿ ¹ ÐPTÔUCð
|
ð CØ
|
r7 c ó | j \ }}}t j |d¬« }d}| j |d¬« }t |« D ]7 \ }} || « }
|
t |
|
« }
|
|st |
|
| j « d}|
|
||< 9 |S )NÚOr´ Fr rþ T)r r/ r¾ rÿ Ú enumerater? r6 r4 ) rO r3 rà r r rÄ Ú initializedr r Úgroupr> s r5 rQ z)BaseGrouper._aggregate_series_pure_pythonr s ð 1gä'¨Ô-Ø à×%Ñ% c°Ð%Ó2ä! (Ó+ò HAuÙu+CÜ Ó%Cá ä" 3¨¯ © Ô4Ø " àF1Ið ð r7 c óz d}| j ||¬« }| j }g }t ||« }|D ]R \ } }
|
t j |
|
d| « |
|
j
|
} ||
|
« } |st | | |« sd}|j | « T t |« dk( r$t |dd « dv r ||j d d « ||fS )NFrþ rV Tr rÙ )rc rR rT ) rÿ r r r1 Ú __setattr__ÚaxesÚ_is_indexed_liker- r= r~ Úiloc) rO r
r rË Úmutatedr Ú
|
group_keysÚ result_valuesÚzippedÚkeyrZ Ú
|
group_axesr> s r5 Úapply_groupwisezBaseGrouper.apply_groupwise sÜ ð Ø×%Ñ% d°Ð%Ó6Ø×(Ñ(
|
Ø ô Z Ó*à ò &JCô × Ñ u f¨cÔ 2ð JÙE(CÙÔ#3°C¸ÀTÔ#JØ Ø × Ñ Õ %ð &ô z?aÒ ¤G¨A¨z¸4Ó$@ð E
|
ñ %
|
ñ diimÔ à gÐ%Ð%r7 c ó: | j \ }}}t ||« S rJ )r r' r s r5 r zBaseGrouper._sort_idx´ s ð //QÜ% c¨7Ó3Ð3r7 c óX | j \ }}}|j | j « S rJ )r r r r; s r5 r
|
zBaseGrouper._sorted_ids» s& ð OO QØxxÓ'Ð'r7 N)TT)
|
rË r rì zSequence[grouper.Grouping]rí r rë r rÓ rÔ ©rÓ zlist[grouper.Grouping])rÓ r )rÓ zIterator[Hashable]©rÓ r× ©r )r r rË r rÓ z#Iterator[tuple[Hashable, NDFrameT]])r r, rË r rÓ Ú DataSplitter)rÓ z$dict[Hashable, npt.NDArray[np.intp]]©rÓ únpt.NDArray[np.intp])rÓ z#list[npt.NDArray[np.signedinteger]]©rÓ z list[Index]©rÓ zlist[Hashable])rÓ r" )rÓ zdict[Hashable, np.ndarray])rÓ r ©rÓ z6tuple[npt.NDArray[np.intp], npt.NDArray[np.intp], int])rÓ z:tuple[npt.NDArray[np.signedinteger], npt.NDArray[np.intp]])rÓ zlist[npt.NDArray[np.intp]]©rÓ r )rÓ zlist[ArrayLike])rÍ )
|
rL rÒ rM rÒ rË r r¦ r× rÓ r )F)r3 r" rà r rS r rÓ r )r3 r" rà r rÓ znpt.NDArray[np.object_])r
r r zDataFrame | SeriesrË r rÓ ztuple[list, bool])&rÙ rÚ rÛ rÜ râ rP Úpropertyrì r rù rû r r rÿ r r rø r r r r$ rF r+ r5 rN r r< r8 r rB r rJ rM rU rQ rf r r
|
r¹ r7 r5 ræ ræ 9 sn
ñ ð Kð Øð àð ð .ð ð ð ð
|
ð ð
|
ó ð ò ó ð ð ò>ó ð>ó"ð ò#ó ð#ð /0ð 'Ø ð 'Ø$+ð 'à ,ó 'ð ó
|
ó ð
|
ð ØñMó ó ðMð ò2ó ð2ð òó ðð4 Ø ò7ó ó ð7ð ò>ó ð>ð ò6ó ð6ð ò
|
Oó ð
|
Oð ò ,ó ð ,ð ØòAó ó ðAð Øò4ó ó ð4ð ò0ó ð0ð òó ðð
|
ð
|
Là Cò
|
Ló ð
|
Lð Øò&ó ó ð&ð òQó ðQð
|
ò
|
ó ð
|
ð ò ó ð ð$ ð ð
|
àð
|
ð ð
|
ð
|
ð
|
ð ð
|
ð
|
ò
|
ó ð
|
ð6 àBGð Øð Ø!)ð Ø;?ð à ò ó ð ð@ ðØðØ!)ðà òó ðð. àEFð$&Øð$&Ø!3ð$&Ø;Bð$&à ò$&ó ð$&ðR Øò4ó ó ð4ð
|
Øò(ó ó ñ(r7 ræ c óî e Zd ZU dZded< ded< d ddZed « Zedd « Z edd
|
« Z
|
ddd Z ed « Z edd « Z edd« Zedd« Zed d« Zed d« Zed d« Zy) Ú
|
BinGrouperaå
|
This is an internal Grouper class
|
|
Parameters
|
----------
|
bins : the split index of binlabels to group the item of axis
|
binlabels : the label list
|
indexer : np.ndarray[np.intp], optional
|
the indexer created by Grouper
|
some groupers (TimeGrouper) will sort its axis and its
|
group_info is also sorted, so need the indexer to reorder
|
|
Examples
|
--------
|
bins: [2, 4, 6, 8, 10]
|
binlabels: DatetimeIndex(['2005-01-01', '2005-01-03',
|
'2005-01-05', '2005-01-07', '2005-01-09'],
|
dtype='datetime64[ns]', freq='2D')
|
|
the group_info, which contains the label of each item in grouped
|
axis, the index of label in label list, group number, is
|
|
(array([0, 0, 1, 1, 2, 2, 3, 3, 4, 4]), array([0, 1, 2, 3, 4]), 5)
|
|
means that, the grouped axis has 10 items, can be grouped into 5
|
labels, the first and second items belong to the first label, the
|
third and forth items belong to the second label, and so on
|
|
znpt.NDArray[np.int64]Úbinsr Ú binlabelsNc ó¬ t |« | _ t |« | _ || _ t | j « t | j « k( sJ y rJ )r rv r! rw Úindexerr= )rO rv rw ry s r5 rP zBinGrouper.__init__ä sD ô ! Ó& Ü% iÓ0Ø ô 4>>Ó"¤c¨$¯)©)£nÒ4Ð4Ñ4r7 c ó t | j | j « D ci c] \ }}|t ur|| }}}|S c c}}w )r* )r rw rv r )rO rd ÚvaluerÄ s r5 r+ zBinGrouper.groupsò sK ô " $§.¡.°$·)±)Ó <÷
|
áUØ#~ð Jð
|
ñ
|
ð
|
ùó
|
s ¤>c ó y)Nr: r¹ rï s r5 rû zBinGrouper.nkeysþ s ð r7 c ó | j \ }}}| j &t j || j f« }|| }|S rJ )r ry r/ Úlexsort)rO rÏ r Úsorters r5 r< zBinGrouper.codes_info sB ð OO QØ <<Ð #ÜZZ d§l¡lÐ 3Ó4FØf+CØ
|
r7 c # ó K |dk( rfd}nfd}t j | « }d}t | j | j « D ] \ }}|t
|
ur | |||« f |} ||k r| j d ||d« f yyw)rý r c ó" j | | S rJ ©r_ ©ÚstartÚedger s r5 ú<lambda>z)BinGrouper.get_iterator.<locals>.<lambda> s ø ¨¯©°5¸Ð)> r7 c ó. j d d
| |
f S rJ r r s r5 r z)BinGrouper.get_iterator.<locals>.<lambda> s ø ¨¯©²1°e¸D°j°=Ñ)A r7 rÍ N)r= r] r rv rw r )rO r rË ÚslicerÚlengthr r
Úlabels ` r5 r zBinGrouper.get_iterator s øè ø ð 19Û>FãAFäTYYt_Ó%àÜ tyy¨$¯.©.Ó9ò KD%ØCÑ ØV E¨4Ó 0Ð0Ò0ØEð ð
|
6>Ø.. Ñ$¡f¨U°DÓ&9Ð9Ó 9ð ùs B Bc óÜ t j t « }d}t | j | j
|
« D ]- \ }}||k s |t urt t ||« « ||< |}/ |S r3 )Ú collectionsÚ defaultdictrè r rw rv r Úrange)rO rø r r Úbins r5 rø zBinGrouper.indices% sh ä ×)Ñ)¬$Ó/à Ü dnn¨d¯i©iÓ8ò JE3Ø3wؤÑ#Ü%)¬%°°3«-Ó%8GENØð ð
|
r7 c óö | j }t j |t j ¬« }t j t j
|
d| j f « }t |« }|t | j « k( r*t j t j |« |« }n<t j t j
|
dt j |« f |« }t |« ||fS )Nr´ r rÍ )
|
r r/ r> r ÚdiffÚr_rv r r= Úrepeat)rO r r9 Úrepr§ s r5 r zBinGrouper.group_info1 s² à,,Ü '´·±Ô9 ÜggbeeAtyyLÑ)Ó*ä! #Ó&Ø c$))nÒ $Üyy¤§¡¨7Ó!3°SÓ9Häyy¤§¡ r¬2¯9©9°WÓ+=Ð'=Ñ!>ÀÓDHô Ó )Ø Ø ð
|
ð
|
r7 c ó t j dt j | j dd | j d d k7 « dz f gS )Nr r: rÍ )r/ r Ú flatnonzerorv rï s r5 rB z BinGrouper.reconstructed_codesC sB ô a ¨¯ © °!°"¨ ¸¿¹À3ÀB¸ Ñ(GÓHÈ1ÑLÐLÑMÐNÐNr7 c ó t | j « dk7 r't | j d « r| j dd S | j S )Nr r: )r= rw r rï s r5 r zBinGrouper.result_indexH s> ä t~~Ó !Ò #¬¨T¯^©^¸AÑ->Ô(?Ø>> ! "Ð%Ð %à~~Ð r7 c ó | j gS rJ )rw rï s r5 r zBinGrouper.levelsO s àÐ Ð r7 c ó0 | j j gS rJ )rw rV rï s r5 r$ zBinGrouper.namesS s à×#Ñ#Ð$Ð$r7 c ó¨ | j }| j d }|j |« }t j ||dd |j
|
¬« }|gS )Nr F)Úin_axisÚlevelÚuniques)rw r r r ÚGroupingr9 )rO Úlevr r· ró s r5 rì zBinGrouper.groupingsW sN ànnØ Ñ"Ø% Ü× Ñ Ø F E°¸s¿{¹{ô
|
ð v r7 rJ ©rÓ rÔ rj rm rk )r r, rË r rq )rÓ zlist[np.ndarray]rr ro rp ri )rÙ rÚ rÛ rÜ râ rP r r+ rs rû r< r rø r rB r r r$ rì r¹ r7 r5 ru ru  sø
ñ ð< Ó ØÓð ð 5ð
|
|
ó 5ð ñ ó ð ð òó ðð òó ðô:ð2 ñ ó ð ð ò
|
ó ð
|
ð" òOó ðOð ò ó ð ð ò ó ð ð ò%ó ð%ð òó ñr7 ru c óæ t | t « r0t |« dkD ry| j | j || « S t | t
|
« r!| j | j || « S y)Nr: F)r. r" r= r] Úequalsr )r3 r] rË s r5 r^ r^ b sa Ü#vÔ Ü t9q=ØØxx~×$Ñ$ T¨$¡ZÓ0Ð0Ü CÔ #Øxx~×$Ñ$ T¨$¡ZÓ0Ð0à r7 c óV e Zd Zdd ddZd dZed
|
d« Zd dZy) rl r rþ c ó || _ t |« | _ || _ || _ || _ || _ t |t « sJ |« y rJ ) r r r· r Ú_slabelsr rË r. r× )rO r r· r r r rË s r5 rP zDataSplitter.__init__r sH ð Ü)¨&Ó1 Ø à" Ø!à Ü$¤Ô$Ð* dÓ*Ñ$r7 c # ó K | j }| j dk( ry t j | j | j « \ }}t ||« D ]# \ }}| j |t ||« « % y wr3 )Ú _sorted_datar r
|
Úgenerate_slicesr¥ r Ú_chopÚslice)rO ÚsdataÚstartsÚendsr Úends r5 rù zDataSplitter.__iter__ sr è ø Ø×!Ñ!à <<1Ò ð ä×*Ñ*¨4¯=©=¸$¿,¹,ÓG ä f dÓ+ò 7JE3Ø**U¤E¨%°Ó$5Ó6Ó 6ñ 7ùs A=A?c ód | j j | j | j ¬« S )Nrþ )r r r rË rï s r5 r§ zDataSplitter._sorted_data s! àyy~~dnn°4·9±9~Ó=Ð=r7 c ó t | « rJ r )rO r« Ú slice_objs r5 r© zDataSplitter._chop s Ü! $Ó'Ð'r7 N)r r r· rn r r× r rn r rn rË r rÓ rÔ )rÓ r* )rÓ r )r± rª rÓ r, )rÙ rÚ rÛ rP rù r r§ r© r¹ r7 r5 rl rl q sn ð ñ+àð+ð %ð+ð ð +ð 'ð +ð )ð+ð ð+ð
|
ó+ó( 7ð ò>ó ð>ô(r7 rl c ó e Zd ZddZy)ÚSeriesSplitterc óº |j j |« }|j ||j ¬« }|j |_ |j |d¬« S )N©r] r/ ©Úmethod)Ú_mgrÚ get_sliceÚ_constructor_from_mgrr] rV Ú_nameÚ __finalize__)rO r« r± ÚmgrÚsers r5 r© zSeriesSplitter._chop sP àjj×"Ñ" 9Ó-Ø×)Ñ)¨#°C·H±HÐ)Ó=ØJJ Ø× Ñ ¨iÐ Ó8Ð8r7 N)r« r" r± rª rÓ r" ©rÙ rÚ rÛ r© r¹ r7 r5 r³ r³ s ô9r7 r³ c ó e Zd ZddZy)Ú FrameSplitterc ó¶ |j j |d| j z
|
¬« }|j ||j ¬« }|j |d¬« S )Nr: rþ rµ r/ r¶ )r¸ r¹ rË rº r] r¼ )rO r« r± r½ Údfs r5 r© zFrameSplitter._chop¥ sQ ð jj×"Ñ" 9°1°t·y±y±=Ð"ÓAØ × (Ñ (¨°3·8±8Ð (Ó <Øu¨YÓ7Ð7r7 N)r« r r± rª rÓ r r¿ r¹ r7 r5 rÁ rÁ ¤ s ô8r7 rÁ rþ c óX t | t « rt }nt } || |||||¬« S )N)r r rË )r. r" r³ rÁ )r r· r r r rË Úklasss r5 rÿ rÿ ° s4 ô $Ô Ü$2ô á Ø fg¨¸ZÈdô ð r7 r )rË r rÓ r )r r, r· rn r r× r rn r rn rË r rÓ rl )LrÜ Ú
|
__future__r r rÞ Útypingr r r r r Únumpyr/ Ú pandas._libsr r
|
Úpandas._libs.groupbyÚ_libsr/ r Úpandas._typingr r r r r Ú pandas.errorsr Úpandas.util._decoratorsr Úpandas.core.dtypes.castr r Úpandas.core.dtypes.commonr r r r r Úpandas.core.dtypes.missingr r Úpandas.core.framer Úpandas.core.groupbyr Úpandas.core.indexes.apir r r r! Úpandas.core.seriesr" Úpandas.core.sortingr# r$ r% r& r' r( Úcollections.abcr) r* r+ Úpandas.core.genericr, r6 r? rA ræ ru r^ rl r³ rÁ rÿ r¹ r7 r5 ú<module>rÙ s: ðñõ #ã Û ÷õ ó ÷÷ *Ð )÷õ õ .Ý 2÷÷õ ÷õ
|
(Ý '÷ó õ &÷÷ ñ ÷ñ õ ,ó>ò ÷ L
|
ñ L
|
÷^F(ñ F(ôR ]ô ]ó@ô '(78Ñ$ô '(ôT9\ô 9ô 8Lô 8ð& ñØ
|
ðà ðð ðð
|
#ð ð %ð ð ðð ôr7
|
