ó ¦–Õ\c@s ddlZddlZddlZddlZddljjZ ddl Z ddl Z ddl j ZddlmZmZmZmZddddddd d d d d dg Ze jdeƒd„ƒZd„Zd„Zd„Zd„Zd„Ze jjdd„d„d„d„e jd„de jjddƒƒgƒe jjde e!gƒd „ƒƒZ"d!„Z#e jjd"d#d$gƒd%„ƒZ$e jjdd&„d'„d(„d)„d*„d+„d,„gƒd-„ƒZ%d.„Z&d/„Z'd0„Z(d1„Z)d2„Z*d3„Z+d4„Z,d5„Z-d6„Z.e jjd7e e!gƒd8„ƒZ/e jjd9d:d;gƒd<„ƒZ0d=„Z1e jjdd>„d?„d@„dA„dB„e jdC„de jjdDƒƒgƒdE„ƒZ2dF„Z3dG„Z4dH„Z5dI„Z6e jjdJiiddK6dL6iddM6ddL6dK6iddL6ddgdK6iej7dL6dej8ej9ej:gdK6ddddddd d d d dg d iddL6d dK6d dN6d d gdM6iiddK6dL6id dM6d dL6dK6gƒe jjd:e!dgƒe jjddO„dP„dQ„dR„dS„gƒdT„ƒƒƒZ<e jjdJiddL6ddK6ddN6dgddddddd d d d g ddgƒe jjd:e!dgƒe jjddU„dV„dW„gƒdX„ƒƒƒZ=dY„Z>dZ„Z?d[„Z@e jjdd\„d]„d^„d_„d`„gƒda„ƒZAe jjddb„dc„dd„gƒde„ƒZBe jjddf„dg„dh„di„e jdj„de jjddkƒƒgƒe jjdldm„dn„do„gƒdp„ƒƒZCdq„ZDdr„ZEe jjdsdtdudvgƒe jjd:dwdxgƒe jjd;ddtdxdvgƒdy„ƒƒƒZFdz„ZGd{„ZHd|„ZId}„ZJe jjd~dKdNdKdNggƒe jjddMdMdLggƒe jjd€dd‚dƒgƒd„„ƒƒƒZKe jjd€dd‚gƒd…„ƒZLd†„ZMd‡„ZNdˆ„ZOd‰„ZPdŠ„ZQe jjd‹dMdMgdMdLgdLggƒdŒ„ƒZRe jjdd‚dƒdd ddddd ddd d dgƒdŽ„ƒZSe jjdddMgdMdgdgdgƒe jjd‘ejTejUd’„gƒd“„ƒƒZVejWdd”„d•„d–„ƒZXejWdd—„d˜„ƒZYe jjd™iddL6ieXdL6e!fiddL6ieYdL6e fddgeXeYge!fiddgdL6ieXeYgdL6e!fgƒdš„ƒZZe jjd›deXfdgeXgfddgeXeYgfgƒdœ„ƒZ[d„Z\dž„Z]dŸ„Z^d „Z_e jjd€d¡„d¢„d£„d¤„d¥„d¦„gƒd§„ƒZ`d¨„Zae jjbed©kddªƒe jjd«d¬dtdwd­gƒd®„ƒƒZcd¯„ZddS(°iÿÿÿÿN(t assert_eqtassert_dask_graphtassert_max_depstPANDAS_VERSIONtsumtmeantmintmaxtcounttsizetstdtvartnuniquetfirsttlasttprodtparamscCs|jS(s+ Aggregations supported for groups (tparam(trequest((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytagg_funcsc Cs4tjiddddddddd g d 6td ƒd 6ƒ}tj|dƒ}|jd ƒ}|jd ƒ}t|tjjƒs‰t‚t|j tj jjƒsªt‚t|j tjƒsÅt‚t |j |j ƒ|jd ƒd }|jd ƒd }t|tjj ƒst‚t|j tj jj ƒs:t‚t|j tjƒsUt‚t |j |j ƒ|jd ƒd g}|jd ƒd g}t|tjjƒs¯t‚t|j tj jjƒsÐt‚t|j tjƒsët‚t |j |j ƒ|j|jƒd }|j|jƒd }t|tjj ƒsEt‚t|j tj jj ƒsft‚t|j tjƒst‚t |j |j ƒ|j|jƒd g}|j|jƒd g}t|tjjƒsát‚t|j tj jjƒst‚t|j tjƒst‚t |j |j ƒdS( Niiiiiiii i txt abcbabbcdaty(tpdt DataFrametlisttddt from_pandastgroupbyt isinstancetDataFrameGroupBytAssertionErrort_metatcoretobjRt SeriesGroupBytSeriesR(tpdftddftgptdp((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytgroupby_internal_reprsB+!!!!!c Cs1tjiddddddddd g d 6td ƒd 6ƒ}tj|dƒ}tjtƒ|jd ƒWdQXtjtƒ|jd d gƒWdQX|jd ƒ}d}tjtƒ}|d WdQX|t |j ƒksìt ‚tjtƒ}|d d gWdQX|t |j ƒks-t ‚dS(Niiiiiiii i RRRtAsColumn not found: ( RRRRRtpytesttraisestKeyErrorRtstrtvalueR(R%R&R(tmsgterr((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt groupby_errorHs+cCstjiddgdd6tjjdƒd6tjjdƒd6ƒ}tj|dƒ}t|jdƒj ƒj ƒ|j ƒjdƒj ƒƒt|j|dƒj ƒj ƒ|j ƒj|dƒj ƒƒt|j|ddƒj ƒj ƒ|j ƒj|ddƒj ƒƒdS( Niii R*itBtCi( RRtnptrandomtrandnRRRRt_headRthead(R%R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytgroupby_internal_head_s #c sdtjiddddddddd g d 6ddddddd d d g d 6d d dddddd d d g ƒ}tj|ddƒ‰tjt‡fd†ƒtjt‡fd†ƒd tˆj d ƒƒksÜt ‚d„}t j ƒmt j dƒˆj d ƒj|ƒjjdƒs)t ‚t|j d ƒj|ƒˆj d ƒj|ƒƒWdQXdS(Niiiiiiiii taitbtindext npartitionscs ˆjdƒS(Ntdoes_not_exist(R((R&(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytutcsˆjdƒjS(NR;(RR?((R&(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@vRAcSs |jd|j|jjƒƒS(NR<(tassignR<R(tdf((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytfuncystignoreRD(RRRRR+R,R-tAttributeErrortdirRRtwarningstcatch_warningst simplefiltertapplyt_namet startswithR(RCRD((R&s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_full_groupbyos+%$!   *c stjiddddddddd g d 6ddddddd d d g d 6d d dddddd d d g ƒ}tj|ddƒ}dd„}|jjƒ‰|jjƒ‰|jjƒ}|jjƒ}tj ‡fd†ƒƒ}tj ‡fd†ƒƒ}|j d ƒj |ˆƒ}t j ƒ’t jdƒt|j d ƒj |ˆdˆƒ|j d ƒj |ˆd|ƒƒt|j d ƒj |ˆƒ|j d ƒj |ˆƒƒt|j d ƒj |ˆdˆƒ|j d ƒj |ˆdˆƒƒt|j d ƒj |ˆƒ|j d ƒj ||ƒdtƒt|j d ƒj |ˆƒ|j d ƒj ||d|ƒƒt|j d ƒj |ˆdˆƒ|j d ƒj |ˆd|d|ƒƒWdQXtjtƒ&}|j d ƒj |ˆd|ƒWdQXdt|jƒkr#dt|jƒks)t‚tjtƒ&}|j d ƒj ||dˆƒWdQXdt|jƒkrŠdt|jƒkst‚t|j d ƒj |ˆƒ|j d ƒj ||d|ƒƒt|j d ƒj |ˆdˆƒ|j d ƒj |ˆd|d|ƒƒdS(Niiiiiiiii R;iR<R=R>cSs(|jd|j|jjƒ||ƒS(NR<(RBR<R(RCtctd((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyRDŠscsˆS(N(((RO(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@’RAcsˆS(N(((RP(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@“RARERPt check_dtypetmetas dask.delayed(RRRRR;RR<RtdasktdelayedRRKRHRIRJRtFalseR+R,t ValueErrorR.R/R( RCR&RDtc_scalartd_scalart c_delayedt d_delayedRRtexc((RORPs@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt test_full_groupby_apply_multiarg„sH+%$   !"!"""!.%0%0"!tgroupercCsdgS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¼RAcCs ddgS(NR;R<((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@½RAcCs|dS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¾RAcCs|d|dgS(NR;R<((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¿RAcCs|ddk|ddkgS(NR;iR<i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÀRAtmarkstreasonsnot yet supportedtreversec Cs7dddddddddg }|r=|ddd…}ntjidd dd ddd ddg d 6dd dd ddd ddg d 6d dddd ddddg d6d|ƒ}tj|ddƒ}d„}tjƒOtjdƒt|j||ƒƒj |ƒ|j||ƒƒj |ƒƒWdQXdS(Niiiiiii iÿÿÿÿiiiR;RPR<R=R>cSs |jd|j|jjƒƒS(NR<(RBR<R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyRDÎsRE( RRRRRHRIRJRRRK(R]R`R=RCR&RD((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_full_groupby_multilevel»s !+"%    cCstjitdƒd6tdƒd6ƒ}tj|ddƒ}|jdƒ}dt|ƒkset‚dt|ƒks}t‚dS(Ni R;sb c d eR>i(RRtrangeRRRRGR(RCR&tg((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_dirÙs )t schedulertsynctthreadsc CsKtjiddddddddd g d 6ddddddd d d g d 6d d dddddd d d g ƒ}tj|ddƒ}|jd ƒ}|jd ƒ}t|jd ƒjjƒ|j|j ƒjjƒƒd„}d„}d„}t j j d|ƒ:t jdƒ$t|jd ƒj|ƒ|jd ƒj|ƒƒt|jd ƒj|ƒjd ƒ|jd ƒj|ƒjd ƒƒt|j|j ƒj|ƒ|j|j ƒj|ƒƒt|jjd ƒj|ƒ|jjd ƒj|ƒƒt|jj|j ƒj|ƒ|jj|j ƒj|ƒƒWdQXWdQXdS(Niiiiiiiii R;iR<R=R>cSs |jd|j|jjƒƒS(NR<(RBR<R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyRDìscSs|dg|dgjƒS(NR<(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytfunc2ïscSs |jƒS(N(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytfunc3òsRe(RRRRt set_indexRRR<RR=RStconfigtsetR+twarnstNoneRK(ReR%R&tddf2tpdf2RDRhRi((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_on_indexás,+%$4   !"cCs|jdƒdS(NR;R<(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCs|jddgƒS(NR;R<(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ RAcCs|jddgƒdS(NR;R<RO(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ RAcCs|j|dƒddgS(NR;R<RO(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ RAcCs|jdƒddgS(NR;R<RO(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ RAcCs|jdƒdgS(NR;R<(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ RAcCs|jdddgƒS(NR;R<RO(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCsF|dkrdStjiddddddgd6ddddddgd6ddddddgd6ddddddgd 6ƒ}tj|dƒ}||ƒ}||ƒ}t||ƒ}t||ƒ}t|tjjƒsæt‚t|tj jj ƒst‚|d kr/t |ƒ|ƒj t ƒƒnt |ƒ|ƒƒdS( NR iiiR;iR<RORPR(RRRRtgetattrRRt_GroupByRR!tGroupByRtastypetfloat(R]RRCR&t dask_groupt pandas_grouptdask_aggt pandas_agg((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_multilevel_getitems "   cCs\tjiddddddgd6ddddddgd6ddddddgd6ddddddgd6ƒ}tj|dƒ}|jdgƒjƒ}|jdgƒjƒ}t||ƒ|jddgƒjƒ}|jddgƒjƒ}t||ƒ|j|d|dgƒjƒ}|j|d|dgƒjƒ}t||ƒdS( NiiiR;iR<RORP(RRRRRRR(RCR&tsoltres((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_multilevel_agg)s"  ##cCsçitjidddgd6dddgd6dd dd gƒd6tjidddgd6d d dgd6dd dd gƒd6tjidd dgd6ddd gd6ddddgƒd6}|d}tj|d |d dddgƒ}|jƒ}xãd|j|jf|jd|jdfgD]²\}}|j|ƒ}|j|ƒ}t|jdƒ|jdƒƒt|jd ƒ|jd ƒƒt|jjd ƒ|jjd ƒƒt|jjdƒ|jjdƒƒq-WdS(NiiiR;iiR<R=iiRiii (Ri(Ri(Ri(Ri(R<R<( RRRtcomputeR<RRt get_groupR;(tdskRRRPtfulltddkeytpdkeyt ddgroupedt pdgrouped((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_get_group=s"/,, $ '%cCs”tdƒ}tjjt|ƒƒ}tjtd|d|ƒƒ}tj |ddƒ}|j dƒdj ƒ}t |j dƒdj ƒ|ƒdS(NtaaabbccccdddeeetstringstdataR>i( RR5R6R7tlenRRtdictRRRR R(R‰RŠtpststexpected((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_dataframe_groupby_nuniqueTs  cCs‘tdƒ}tttdƒƒ}tjtd|d|ƒƒ}tj|ddƒ}|jdƒdj ƒ}t |jdƒdj ƒ|ƒdS(NRˆt123111223323412R‰RŠR>i( RtmaptintRRRŒRRRR R(R‰RŠRRŽR((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt6test_dataframe_groupby_nunique_across_group_same_value]s  cCs¡tjidddgd6dddgd6ƒ}tj|dƒ}d „}tjtƒ|jdƒj|ƒ}WdQX|jdƒj|ƒ}t ||ƒdS( NiiiRiiiRcSs|djƒS(NR(R(RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@iRA( RRRRR+Rmt UserWarningRRKR(RCR&RDtresultR((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt$test_series_groupby_propagates_namesfs/ cCsltjdddddgƒ}|j|ƒ}tj|ddƒ}|j|ƒ}|j|dƒ}|j|dƒ}xî||f||fgD]Ô\}}t|jƒ|jƒƒt|jƒ|jƒƒt|jƒ|jƒƒt|j ƒ|j ƒƒt|j ƒ|j ƒƒt|j ƒ|j ƒƒt|j ƒ|j ƒƒt|j ƒ|j ƒƒqWdS(NiiR>(RR$RRRRRRRRR R RR(RŽtpd_grouptssRwt pd_group2t dask_group2tdgtpdg((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_series_groupbyps%c Cs;tjdddddgƒ}tj|ddƒ}d}tjtƒ}|jgƒWdQX|t|j ƒksyt ‚tjtƒ}|jgƒWdQX|t|j ƒks¹t ‚tj|ddƒ}tjt ƒ|j|ƒWdQXtjt ƒ|jdƒWdQXtjt ƒ|jdƒWdQXdS(NiiR>sNo group keys passed!iR( RR$RRR+R,RVRR.R/RtNotImplementedErrorR-(RŽR™R0R1tsss((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_series_groupby_errors…s cCs«tjƒ}tj|ddƒ}t|jj|jjƒj ƒ|jj|jjƒj ƒdt ƒt|j|jjƒjj ƒ|j|jjƒjj ƒdt ƒdS(NR>it check_names( ttmtmakeTimeDataFrameRRRR*RR=tmonthR RU(RCR&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_index_arrayœs  %csAtjƒ‰tjˆddƒ‰tjt‡‡fd†ƒdS(NR>icsˆjˆjjdtƒS(Ntas_index(RR=R¥RU((R&RC(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@­RA(R£R¤RRR+R,t TypeError(((R&RCs@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_set_index©s  temptyc sG|rBtjidgd6dgd6ddgƒjd }g}nƒdddg}tjidddd d dd d d g d6d dd d d ddddg d6dddd d dd dddg ƒ}tj|dd ƒ‰xFd)ˆj|jfˆjd|jdfgD]\}}tˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjjƒ|j|ƒjjƒƒtˆj|ƒjjƒ|j|ƒjjƒƒtˆj|ƒjjƒ|j|ƒjjƒƒx||D]t}tˆj|ƒjj|ƒ|j|ƒjj|ƒƒtˆj|ƒjj|ƒ|j|ƒjj|ƒƒq¥Wtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒj ƒ|j|ƒj ƒƒtˆj|ƒj ƒ|j|ƒj ƒƒtˆj|ƒj ƒ|j|ƒj ƒƒtˆj|ƒj ƒ|j|ƒj ƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒx||D]t}tˆj|ƒj|ƒ|j|ƒj|ƒdtƒtˆj|ƒj|ƒ|j|ƒj|ƒdtƒq§Wq Wxqˆj|jfˆjd|jdfgD]C\}}tˆjj|ƒjƒ|jj|ƒjƒdtƒtˆjj|ƒj ƒ|jj|ƒj ƒdtƒtˆjj|ƒj ƒ|jj|ƒj ƒdtƒtˆjj|ƒj ƒ|jj|ƒj ƒdtƒtˆjj|ƒj ƒ|jj|ƒj ƒdtƒtˆjj|ƒjƒ|jj|ƒjƒdtƒtˆjj|ƒjƒ|jj|ƒjƒdtƒtˆjj|ƒjƒ|jj|ƒjƒdtƒx||D]t}tˆjj|ƒj|ƒ|jj|ƒj|ƒƒtˆjj|ƒj|ƒ|jj|ƒj|ƒƒqWqPWxñ dd d gD]à }tˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjj ƒ|j|j|kƒjj ƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjjƒ|j|j|kƒjjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒj ƒ|j|j|kƒj ƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒtˆjˆj|kƒjƒ|j|j|kƒjƒƒxQ|D]I}tˆjˆj|kƒj|ƒ|j|j|kƒj|ƒƒq:Wq§Wx d*ˆj|jfˆjd|jdfˆjd k|jd kfgD]¾\}}tˆj|ƒjjƒ|j|ƒjjƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjj ƒ|j|ƒjj ƒƒtˆj|ƒjjƒ|j|ƒjjƒƒtˆj|ƒjjƒ|j|ƒjjƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒj ƒ|j|ƒj ƒƒtˆj|ƒj ƒ|j|ƒj ƒƒtˆj|ƒj ƒ|j|ƒj ƒƒtˆj|ƒj ƒ|j|ƒj ƒjtƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒtˆj|ƒjƒ|j|ƒjƒƒxE|D]=}tˆj|ƒjj|ƒ|j|ƒjj|ƒƒqSWqÖWtˆjdƒjjƒjƒtˆjdƒjjƒjƒksàt‚tˆjˆjd kƒjj ƒjƒtˆjˆjd kƒjj ƒjƒks:t‚tjt‡fd†ƒtjt‡fd†ƒtjt‡fd†ƒtjt‡fd†ƒtjt‡fd†ƒtˆjdƒjjƒdƒtˆjdƒjj ƒdƒtˆjdƒjj ƒdƒtˆjdƒjj ƒdƒtˆjdƒjjƒdƒtˆjdƒjjƒdƒtˆjdƒjjƒdƒtˆjdƒjjƒdƒtˆjdƒjj ƒdƒtˆjdƒjj ƒdƒtˆjdƒjj ƒdƒtˆjdƒjjƒd ƒtˆjdƒjƒd!ƒtˆjdƒj ƒd"ƒtˆjdƒj ƒd#ƒtˆjdƒj ƒd$ƒtˆjdƒjƒd%ƒtˆjdƒjƒd&ƒtˆjdƒjƒd'ƒtˆjdƒj ƒd!ƒtˆjdƒj ƒd$ƒtˆjdƒjƒd(ƒdS(+Ngð?R;R<R=iiiiiiiiii R>RQR¢cs ˆjdƒS(NR(R((R&(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@=RAcsˆjddgƒS(NR;R(R((R&(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@>RAcsˆjdƒdS(NR;R(R((R&(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@?RAcsˆjdƒdS(NR;R<R(R<R(R((R&(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@@RAcsˆjdƒddgS(NR;R<R(R((R&(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ARAsseries-groupby-sumsseries-groupby-minsseries-groupby-maxsseries-groupby-countsseries-groupby-varsseries-groupby-firstsseries-groupby-lastsseries-groupby-prodsseries-groupby-nuniquesseries-groupby-sizesdataframe-groupby-sumsdataframe-groupby-minsdataframe-groupby-maxsdataframe-groupby-countsdataframe-groupby-firstsdataframe-groupby-lastsdataframe-groupby-prodsdataframe-groupby-size(R<R<(R;R;(RRtilocRRR<RRR;RRRRR R R RR R RRRURuRvtsortedRSRR+R,R-R(RªR%tddofsRƒR„tddofti((R&s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt"test_split_apply_combine_on_series°s&3 +%$<11111111  +++++++++ '977777777 $CCCCCCCCCCCCCCCCCCCC================== !*B11111111++++++4++++ $*'3tkeywordt split_everyt split_outc CsÚtjidddddddddg dd6dddddddddg dd 6ƒ}tj|d d ƒ}d „}x‘tD]‰}|d kr˜q€n||jd ƒ|id|6}||jd ƒ|ƒ}t||ƒ||jd ƒ|ƒj|jks€t‚q€W||jd ƒdddid|6}||jd ƒdddƒ}t||ƒ||jd ƒdddƒj|jkst‚xˆtD]€}||jd ƒj |id|6}||jd ƒj |ƒ}t||ƒ||jd ƒj |ƒj|jks—t‚q—W||jd ƒj dddid|6}||jd ƒj dddƒ}t||ƒ||jd ƒj dddƒj|jks§t‚x—tD]}||j j|j ƒ|id|6}||j j|j ƒ|ƒ}t||dt ƒ||j j|j ƒ|ƒj|jks®t‚q®W||j j|j ƒdddid|6}||j j|j ƒdddƒ}t||ƒ||j j|j ƒdddƒj|jksÖt‚dS(NiiiiiiidR;R<R>ic[st||ƒ|S(N(Rr(Rctmtkwargs((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytcallesR R R®R¢( RRRRt AGG_FUNCSRRRLRR;R<RU(R±R%R&R¶R´R}R|((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_reduction_split_sB/,   " .( 0 % 1+! 3 (4.$ c Cs¨tjiddddgdd6tjjdƒd6tjjdƒd 6tjjdƒd 6ƒ}tj|dƒ}tjt ƒ"t |j dƒj d „ƒ|j dƒj d „ƒƒt |j |dƒj d „ƒ|j |dƒj d„ƒƒt |j |ddƒj d„ƒ|j |ddƒj d„ƒƒt |j dƒdj d„ƒ|j dƒdj d„ƒƒt |j |dƒdj d„ƒ|j |dƒdj d„ƒƒt |j |ddƒdj d„ƒ|j |ddƒdj d„ƒƒt |j j |dƒj d„ƒ|j j |dƒj d„ƒƒt |j j |ddƒj d„ƒ|j j |ddƒj d„ƒƒt |j dƒdd gj d„ƒ|j dƒdd gj d„ƒƒt |j |dƒdd gj d„ƒ|j |dƒdd gj d„ƒƒt |j |ddƒdd gj d„ƒ|j |ddƒdd gj d „ƒƒWdQXdS(!NiiiiiR*iR3R4tDcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@šRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@›RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@žRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¡RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¤RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¥RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@§RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¨RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ªRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@«RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@®RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¯RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@±RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@²RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@µRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¶RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¸RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¹RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@»RAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¼RA(RRR5R6R7RRR+RmR•RRRKR3(R%R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_apply_shuffle’s8  #$ #$'("#&'%&)*-cCsdS(NtAA((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÀRAcCs ddgS(NR»tAB((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÁRAcCs|dS(NR»((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÂRAcCs|d|dgS(NR»R¼((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÃRAcCs |ddS(NR»i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÄRAcCs|dd|ddgS(NR»iR¼((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÅRAtNotImplementedc Cs‡tjiddddgdd6ddddgdd6tjjdƒd 6tjjdƒd 6tjjdƒd 6ƒ}tj|dƒ}tjt ƒêt |j ||ƒƒj d „ƒ|j ||ƒƒj d „ƒƒt |j ||ƒƒd j d„ƒ|j ||ƒƒd j d„ƒƒt |j ||ƒƒd d gj d„ƒ|j ||ƒƒd d gj d„ƒƒWdQXdS(NiiiiiR¼R»iR3R4R¹cSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÑRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÒRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÕRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÖRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÙRAcSs |jƒS(N(R(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÚRA( RRR5R6R7RRR+RmR•RRRK(R]R%R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_apply_shuffle_multilevel¿s !"%&+cCstjiddddgd6ddddgd6ddddgd6ƒ}tj|ddƒ}t|jdƒjƒ|jdƒjƒƒt|jddgƒjƒ|jddgƒjƒƒt|jdƒjd„ditd6td6td6ƒ|jdƒjd „ƒƒdS( NiiiiiR>cSs|S(N((R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@æRARRcSs|S(N((R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@çRA( RRRRRRRRKR“(RCR&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_numeric_column_namesÝs+76c Cs–tjjjƒ}|jd|d<|jd|di tshufflettaskscSsdS(NR*((R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ñRAcSs|jS(N(R*(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ñRAcss|]}d|dkVqdS(tpartdiN((t.0tk((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pys öscss|]}d|dkVqdS(RÂiN((RÃRÄ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pys üs(RtutilttestingR¤R*R3RRRSRkRlRRKR‹R+RmR•RRtanyR(RCR&tindR;R<((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_apply_tasksês $ !'c Cs»tjidddddgd6dddddgd 6ƒ}tj|d dƒ}tjjd d ƒPt|jd ƒj d „dit d6t d 6ƒ|jd ƒj d„ƒƒWdQXdS(NiiiiiR*t1R;R3R>Ret processescSs|S(N((R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RARRcSs|S(N((R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RA( RRRRRSRkRlRRRKR“tobject(RCR&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_multiprocessingÿs% c Cstjiddddddddd g d 6ddddddd d d g d 6d d dddddd d d g ƒ}tj|ddƒ}|jd ƒjd ks§t‚|j|d ƒjd ksÉt‚|j|d dkƒjj|d dkjkst‚|jd d gƒjd d gks+t‚|j|d |d gƒjd d gks]t‚|j|d d gƒjd d gks‹t‚dS(Niiiiiiiii R;iR<R=R>(RRRRRR=RRL(R‚RP((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_normalize_index s+%$"8*2tspecROR<R;RPcCsdS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@#RAcCs ddgS(NR;RP((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@$RAcCs|d|dgS(NR;RP((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@%RAcCs|dS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@&RAcCs|ddkS(NR;i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@'RAc Cs+tjidddddddddg dd6dddddddddg dd6d ddddd d dd g dd 6dddddddd dg dd6dd dddgƒ}tj|ddƒ}tjdƒHt|j||ƒƒj |ƒ|j||ƒƒj |d|ƒƒWdQXdS(Niiiiii R;R<iiiiRORPtcolumnsR>R²( RRRRR+RmRnRRtagg(RÏR²R]R%R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_aggregate__exampless/&&)cCs|d|dgS(NR;RP((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ARAcCs|dS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@BRAcCs|ddkS(NR;i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@CRAc Cs?tjidddddddddg dd6dddddddddg dd6d ddddd d dd g dd 6dddddddd dg dd6dd dddgƒ}|d }tj|ddƒ}|d }tjdƒHt|j||ƒƒj |ƒ|j||ƒƒj |d|ƒƒWdQXdS(Niiiiii R;R<iiiiRORPRÐR>R²( RRRRR+RmRnRRRÑ(RÏR²R]R%RR&tds((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_series_aggregate__examples9s /&&)  cCs|}|dkrdStjiddddgd6ddddgd6ddddgd6ddddgd 6d dddd gƒ}tj|d dƒ}|jdd gƒj|ƒ}|d d hkrÚ|jtƒ}nt||jdd gƒj|ƒƒdS(NR iiR;iiR<RORPRÐR>RR ( RRRRRRÑRuRvR(RRÏR%R&R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt%test_aggregate__single_element_groupsWs c CsÑddlm}d d g}d ddg}||ƒ\}}}||ƒ\}}}t|ƒt|ƒksst‚t|ƒt|ƒks‘t‚t|ƒt|ƒks¯t‚t|ƒt|ƒksÍt‚d S(s²Aggregate reuses intermediates. For example, with sum, count, and mean the sums and counts are only calculated once accross the graph and reused to compute the mean. iÿÿÿÿ(t_build_agg_argstfooRtinputtbarRtbazRN(R×RRØ(RÙRRØ(R×RRØ(RÙRRØ(RÚRRØ(tdask.dataframe.groupbyRÖR‹R( RÖt no_mean_spectwith_mean_spectno_mean_chunkst no_mean_aggstno_mean_finalizerstwith_mean_chunkstwith_mean_aggstwith_mean_finalizers((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt5test_aggregate_build_agg_args__reuse_of_intermediatesos  c s•tjddgƒ‰‡fd†}iidd6d6idd6d d6d6idd6d dgd6d dd dd d d ddddg d dd dd d ddddg }tjidddddddddg dd6dddddddddg dd6dddddddddg dd6dddddddddg dd6dddddgƒ}tj|ddƒ}x|D]}|jddgƒj|ddƒ}|jddgƒj|ddƒ}||ƒ}||ƒ}t|dƒt|dƒ||kst ‚xz|D]r} |jddgƒj| ddƒ} t | j ƒt |j ƒkset ‚t | j ƒt |j ƒkst ‚qWq~WdS( Nt dask_holderRScsˆd„|jjƒDƒƒS(NcSs2i|](\}}|djdƒr||“qS(it aggregate(RM(RÃRÄtv((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pys Žs (RStitems(R"(Rå(s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@sRROR<RR;RRRR R R R RRiiiiiidiiiiRPRÐR>R²( t collectionst namedtupleRRRRRRÑRRR‹RS( t get_agg_dasktspecsR%R&RÏtresult1tresult2t agg_dask1t agg_dask2t other_spectother((Rås@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_aggregate__dask‹s0&$$/&&) $$     $$cCsdgS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¸RAcCs ddgS(NR;R<((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¹RAcCs|dS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ºRAcCs|d|dgS(NR;R<((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@»RAcCs|ddk|ddkgS(NR;iR<i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@¼RAc CsÏd„}tjidddddddddg dd 6dddddddddg dd 6d ddddd ddd g dd6d ddddd ddd g dd6ddd d dgƒ}tj|ddƒ}t||j||ƒƒd|ƒ||j||ƒƒd|ddƒƒ|dkrËt||j||ƒƒddg|ƒ||j||ƒƒddg|ddƒƒt||j||ƒƒ|ƒ||j||ƒƒ|ddƒƒndS(Nc[st||ƒ|S(N(Rr(RcR´Rµ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR¶¿siiiiiii R;R<iiiRPRORÐR>R²R (RRRRRR(R]RR¶R%R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt&test_dataframe_aggregations_multilevel·s /&&)") (/cCs|dS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@×RAcCs|d|dgS(NR;R<((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ØRAcCs|ddk|ddkgS(NR;iR<i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÙRAc Csd„}tjidddddddddg dd 6dddddddddg dd 6d ddddd ddd g dd6ddd d gƒ}tj|ddƒ}t||dj||ƒƒ|ƒ||dj||ƒƒ|ddƒd|ddhkƒdS(sp similar to ``test_dataframe_aggregations_multilevel``, but series do not support all groupby args. c[st||ƒ|S(N(Rr(RcR´Rµ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR¶ásiiiiiii R;R<iiiRORÐR>R²R¢RR N(RRRRRR(R]RR¶R%R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt#test_series_aggregations_multilevelÖs /&)"(cCs|dS(NR;((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@óRAcCs|ddkS(NR;i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ôRAcCs|d|dgS(NR;R<((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@õRAcCs|ddkgS(NR;i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@öRAcCs|ddk|ddkgS(NR;iR<i((RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@÷RAs/index dtype does not coincide: boolean != emptytgroup_and_slicecCs|j||ƒƒS(N(R(RCR]((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ûRAcCs|dj||ƒƒS(NRO(R(RCR]((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@üRAcCs|j||ƒƒdS(NRO(R(RCR]((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ýRAc Cstjidddddddddg dd6dddddddddg dd 6d ddddd ddd g dd 6dd d dgƒ}tj|ddƒ}|||ƒjƒjd ƒ}|||ƒjjƒ}|||ƒjjƒjd ƒ}t||ƒt||ƒdS(Niiiiiii R;R<iiiRORÐR>( RRRRR R9R t_meta_nonemptyR(RöR]R%R&RRRt meta_nonempty((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_meta_contentòs/&)! c CsÓtjidddddddddg dd6dddddddddg dd 6d ddddd ddd g dd 6dd d dgƒ}tj|ddƒ}tj|ddƒ}|jdd gƒ|j|d|d gƒtjtƒ|j|dƒWdQXtjtƒ |j|d|d gƒWdQXtjtƒ |j|d|d gƒWdQXtjtƒ |j|d|d gƒWdQXtjtƒ|j|dd gƒWdQXdS(Niiiiiii R;R<iiiRORÐR>(RRRRRR+R,RŸ(R%tddf3tddf7((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupy_non_aligned_indexs$/&)!!!c Csktjidddddddddg dd6dddddddddg dd 6d ddddd ddd g dd 6dd d dgƒ}tj|ddƒ}|d}|j|ƒ|j||gƒtjtƒ|jdƒWdQXtjtƒ|j|dgƒWdQXtjtƒ|j|ƒWdQXtjtƒ|j||gƒWdQXdS(Niiiiiii R;R<iiiRORÐR>R×( RRRRRR+R,R-RV(RCRŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt test_groupy_series_wrong_grouper-s /&)  R>iiiiic Cs!tjitjdƒdd6tjdƒd6ƒ}tj||ƒ}|jdƒjj d|d|ƒ}|j |j |j ƒƒ}ddl m}||ƒ\}} |j|pµd ksÁt‚tg|jƒD]\} } | sÑ| ^qу|ksþt‚t||jdƒjj ƒƒdS( Nidi RRR²R³iÿÿÿÿ(tget_depsi(RRR5tarangetonesRRRRR t__dask_optimize__RSt __dask_keys__t dask.coreRþR>RR‹RèR( R>R²R³RCR&R–RRþt dependenciest dependentsRÄRç((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_hash_groupby_aggregateHs =cCs»tjitjdƒdd6tjdƒd6ddddd gd d 6ƒ}tj|d dƒ}|jddgƒjj d dƒ}|jddgƒjj ƒ}t ||dt ƒdS(Nidi RRiiiiiitzR>R³RQ( RRR5RÿRRRRRRRRU(RCR&R–R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt#test_split_out_multi_column_groupby]s $cCsétjtjiddddgd6ddddgd6ƒddƒ}|jdƒjƒjdksht‚|jdƒjddƒjdks’t‚|jdƒjddƒjdks¼t‚tj t ƒ|jdddƒWdQXdS( NiiR*iiR3R>R³( RRRRRRR>RR+R,R¨(R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_split_out_numjs" $**c Cstjtjiddddgd6ddddgd6ƒddƒ}tjtƒ|jdddƒWdQXtjtƒ|jdd dƒWdQXtjtƒ|jdd tƒWdQXtjtƒ|jdd tƒWdQXtjtƒ|jdd t ƒWdQXdS( NiiR*iiR3R>taxistlevelR§tsorttsqueeze( RRRRR+R,R¨RRUtTrue(R&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_not_supportedxs" cCstjidddgd6dddgd6ƒ}tj|ddƒ}t|j|jƒdjƒ|j|jƒdjƒƒdS( NR×RÙR*iiiiR>(RRRRRRR*R(RCR&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_numeric_columnˆs/tseltkeyRDtcumsumtcumprodtcumcountc Cs"tjidddddddddg dd6dddddddddg dd6tjjd ƒd 6tjjd ƒd 6d ddd d gƒ}tj|jd ddgdfi ( RRR5R6R7tnanR«RRRRRr(RDRRRCR&RPRcRœ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_cumulatives/&2c CsÇtjidddddddddg dd6tjjdƒd 6tjjdƒd 6ƒ}tj|jdR (iúÿÿÿiÿÿÿÿ( RRR5R6R7RR«RRRRrR(RDRCR&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_cumulative_axis1 s/!c CsÌtjitjjdddƒd6tjjdƒd6tjjdƒd6ƒ}tj|ddƒ}||jd k}||jd k}|j |j ƒ}|jj |j ƒ}|j ƒ|j ƒ|jj ƒ|jdƒ|j ƒ|j ƒ|j ƒ|jdƒg}x.|D]&}tjtƒ|jƒWdQXqWd „}|j |j ƒ} |j|d |ƒ| j|ƒf|jj|d |jƒ| jj|ƒfg} x!| D]\} } t| | ƒq«WdS( Nii i2R;R<ROR>igà?cSs|dS(Ni((R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytadd1ÃsRR(RRR5R6trandintR7RRR<RR;RR R R€R+R,RVRRKR( RCR&tfilteredt dfilteredt ddf_grouptds_grouptbadR"Rtdf_grouptgoodR}R|((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_unaligned_index«s2"         !0c Cs7tjtdtdƒƒdtjddddƒƒ}d|d iRRRÐR×RÙN(RRRŒRt date_rangeRRRrRtrenameRSRtequalsR( RCR&topstoptddf0tddf1tres0_atres1_atres0_btres1_b((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt"test_groupby_dataframe_cum_cachingÎs     c Cs3tjtdtdƒƒdtjddddƒƒ}d|d iN( RRRŒRR(RRRRSRRrR*R( RCR+R,R&tdcumR/R0tcumR1R2((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_series_cum_cachingés    cCsŸtjiddddgd6ddddgd6ƒ}tj|ddƒ}|jdƒdjd d gƒ}|jdƒdjd d gƒ}t||ƒdS( NiiiiR;iR<R>RR(RRRRRRÑR(RPR;R–R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_slice_agg_reducess 5""cCsŒtjiddddgd6ƒ}tj|ddƒ}|jdƒdjddgƒ}|jdƒdjddgƒ}t||ƒdS( NiiiiR;R>RR(RRRRRRÑR(RPR;R–R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_agg_grouper_single s """tslice_cCsŸtjiddddgd6ddddgd6ƒ}tj|ddƒ}|jdƒ|jdd gƒ}|jdƒ|jdd gƒ}t||ƒdS( NiiiiR;R<R>RR(RRRRRRÑR(R9RPR;R–R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt!test_groupby_agg_grouper_multiples 5""Rc CsAd„}tjiddddddgd6ddddddgd6tjdƒd6ddddddgd6ƒjdƒ}tj|d |jjƒƒ}tj|d |jjƒd t ƒ}||j ddgƒ|ƒ}|d d hkr|j t ƒ}n||j ddgƒ|ƒ}t ||ƒ||j ddgƒ|ƒ}t ||ƒd d d ddddddh }||kr±|j ddgƒj|ƒ}t ||ƒn||j ddgƒ|ƒ}|d d hkró|j t ƒ}n||j ddgƒ|ƒ}t ||ƒ||j ddgƒ|ƒ}t ||ƒ||krƒ|j ddgƒj|ƒ}t ||ƒn||j dƒ|ƒ}|d d hkr¿|j t ƒ}n||j dƒ|ƒ}t ||ƒ||j dƒ|ƒ}t ||ƒ||kr=|j dƒj|ƒ}t ||ƒndS(Nc[st||ƒ|S(N(Rr(RcR´Rµ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR¶%siitidxR;iR<ROR>R RR RR R RR RR(RRR5RÿRjRRR=R RURRuRvRRÑ(RR¶RCR&t ddf_no_divsRR–taca_agg((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt'test_groupby_column_and_index_agg_funcs sN " $  !       t group_argsR;t apply_funccCstj|ƒtj|ƒS(N(R5RR(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@nRAc Cs´tjiddddddgd6ddddddgd6tjdƒd6ƒjdƒ}tj|d|jjƒƒ}tj|d|jjƒdt ƒ}|j |ƒj |ƒ}t j ƒît jd ƒ|j |ƒj |ƒ}t||d t ƒ|j|jkst‚t|jƒt|jƒ|jks<t‚|j |ƒj |ƒ}t||d t ƒ|j|jkst‚t|jƒt|jƒ|jksªt‚WdQXdS( NiiR;R;iR<R>R REtcheck_divisions(RRR5RÿRjRRR=R RURRKRHRIRJRt divisionsRR‹RSR>(R?R@RCR&R<RR–((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt#test_groupby_column_and_index_applyks"" $  +cCs|jƒ|jƒfS(N(RR(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@—RAcCs|jƒ|jƒfS(N(R(ts0ts1((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@˜RAcCs||S(N((RDRE((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@™RAcCs |jƒS(N(R(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@œRAcCs |jƒS(N(R(RD((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@œRAs#pandas_spec, dask_spec, check_dtypecCs“tjidddgdd6dddgdd6ƒ}tj|ddƒ}|jdƒj|ƒ}|jdƒj|ƒ}t||d|ƒdS( NiiiRciR<R>RQ(RRRRRRæR(t pandas_spect dask_specRQRCR&RR–((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt%test_dataframe_groupby_agg_custom_sumŸs 7spandas_spec, dask_speccCs£tjidddgdd6dddgdd6ƒ}tj|ddƒ}|dj|dƒj|ƒ}|dj|dƒj|ƒ}t||dtƒdS( NiiiRciR<R>RQ(RRRRRRæRRU(RFRGRPR;RR–((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt#test_series_groupby_agg_custom_mean¯s 7  cCs¤tjidddgdd6dddgdd6ƒ}tj|ddƒ}tjdd „d „ƒ}tjtƒ(|jdƒj i|dgd6ƒWd QXd S( s7for a single input column only unique names are allowediiiRciR<R>RcSs |jƒS(N(R(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÃRAcSs |jƒS(N(R(RD((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÃRAN( RRRRt AggregationR+R,RVRRæ(RPR;R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyt=test_groupby_agg_custom__name_clash_with_internal_same_column¾s 7cCsätjidddgdd6dddgdd6ddd gdd 6ƒ}tj|d dƒ}tjd d „d„d„ƒ}|jdƒji|d6d d 6ƒ}|jdƒjidd6d d 6ƒ}t||dtƒdS(sEcustom aggregation functions can share the name of a builtin functioniiiRciR<iiiROR>RcSs|jƒ|jƒfS(N(RR(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÑRAcSs|jƒ|jƒfS(N(R(RDRE((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÒRAcSs||S(N((RDRE((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ÓRARRQN( RRRRRJRRæRRU(RPR;RR–R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytBtest_groupby_agg_custom__name_clash_with_internal_different_columnÉsK &&cCs4d„}tjdd„|d„ƒ}tjidddddgdd6dddddgdd 6d d d d d gdd 6ƒ}tj|dd ƒ}|d j|d|d gƒj|ƒ}tjiddgd6ddgd 6d d gd 6ƒ}|d j|d|d gƒjdƒ}t||ƒdS(NcSsd„}|j|ƒS(NcSsG|jd\}x-|jdD]\}|j|ddƒ}qW|gS(Niit fill_value(R«tadd(RŽR}R¯((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytimplâs(RK(RŽRO((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytagg_modeás t custom_modecSs|jd„ƒS(NcSs |jƒgS(N(t value_counts(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@îRA(RK(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@îRAcSs|jd„ƒS(NcSs|djƒS(Ni(tidxmax(R¯((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ðRA(R’(RŽ((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@ðRAiiitg0tg1iiitccR>R(RRJRRRRRÑR(RPRRPR;tactualR((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_agg_custom__modeÞs    *6*c Cs±tjidddddddddg d6dddd d d d d dg d6ƒ}tj|ddƒ}|jdƒdjdƒ}|jdƒdjdƒ}t||ƒdS(NiiiiR*g¢E¶óýÔè¿gš™™™™™Ù¿gV-²ïë¿gÙÎ÷S㥫?gNbX9´ö?g¼t“Vî¿g‹lçû©ñî¿g•C‹lû¿gZd;ßOå¿R3R>R (RRRRRRÑR(R%R&RWR((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_select_column_aggs+cCs |jƒS(N(R (R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCs|jdƒjƒS(NR(RR (R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCs|jdƒjƒS(NR(RR (R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCs|jdƒjƒS(NR(RR(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCs|jdƒjƒS(NR(RR(R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCs|jdƒjjƒS(NR(RRR (R((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@RAcCsqtjidddgd6dddgd6dd d gd 6ƒ}tj|d dƒ}t||ƒ||ƒƒdS( NiiRR;R<RORg&@g6@g€@@RR>(RRRRR(RDRCR&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_std_object_dtype s cCsEtjjƒjd }t|jdƒjƒ|jdƒjƒƒdS(Nitname(RStdatasetst timeseriest partitionsRRR (RC((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_timeseries ss0.22.0s_Parameter min_count not implemented in DataFrame.groupby().sum() and DataFrame.groupby().prod()t min_countiicCsgtjidddgd6tjddgd6tjddgd 6dd d gd 6ƒtjidddgd6dtjtjgd6tjddgd 6dd d gd 6ƒg}g|D]}tj|d d ƒ^q´}x‹t||ƒD]z\}}t|jdƒj d|ƒ|jdƒj d|ƒƒt|jdƒj d|ƒ|jdƒj d|ƒƒqåWdS(NR*R3tgroupiitval1iitval2ii tval3R>R`( RRR5RRRtzipRRRR(R`tdfsRCtddfsR&((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_with_min_count&s   (cCsõtjiddddgd6ddddgd6ƒ}tj|ddƒjdƒ}|jdƒ}d „}|jdƒj|ƒ}t||jdƒj|d |ƒƒ|jdd tƒj|ƒ}t||jdd tƒj|d |ƒƒdS( NiiiR;iiR<R>cSs |jƒS(N(tcopy(Rc((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyR@HRARRt group_keys( RRRRRjRRKRRU(RCR&R%RDR((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pyttest_groupby_group_keys@s  %(eRéRHtnumpyR5tpandasRtpandas.util.testingRÅRÆR£R+RStdask.dataframet dataframeRtdask.dataframe.utilsRRRRR·tfixtureRR)R2R:RNR\tmarkt parametrizeRtxfailRRURaRdRqR{R~R‡RR”R—RžR¡R¦R©R°R¸RºR¾R¿RÉRÍRÎRRR R RnRÒRÔRÕRäRóRôRõRùRüRýRRR RRRRR"R3R6R7R8R:R>RRRCRJt custom_meant custom_sumRHRIRKRLRXRYRZR_tskipifRhRk(((s@lib/python2.7/site-packages/dask/dataframe/tests/test_groupby.pytsF      "* -    7 ' $&      $¯$3 - 3   &)$%,  !     ,      0   !-$ #    * $I $ *'  8  '  %  -