U
|
¬ý°d ã @ s¼ d Z ddlmZ ddlZddlZddlmZmZmZ ddl Z
|
ddl m Z ddl mZ ddlmZmZ dd d
|
d d Zejdd ddddddddZejdd ddddddddZdS )z6Common utilities for Numba operations with groupby opsé )Ú annotationsN)Ú TYPE_CHECKINGÚAnyÚCallable)ÚScalar)Úimport_optional_dependency)ÚNumbaUtilErrorÚjit_user_functionr ÚNone)ÚfuncÚreturnc C sp t | stdtt | ¡j ¡ }ddg}t|}t||k sP|d|
|krltd| d| j d| dS )a^
|
Validate user defined function for ops when using Numba with groupby ops.
|
|
The first signature arguments should include:
|
|
def f(values, index, ...):
|
...
|
|
Parameters
|
----------
|
func : function, default False
|
user defined function
|
|
Returns
|
-------
|
None
|
|
Raises
|
------
|
NumbaUtilError
|
z5Numba engine can only be used with a single function.ÚvaluesÚindexNz
|
The first z arguments to z must be )
|
ÚcallableÚNotImplementedErrorÚlistÚinspectÚ signatureÚ
|
parametersÚkeysÚlenr Ú__name__)r Z udf_signatureZ expected_argsZmin_number_args© r úQd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\pandas/core/groupby/numba_.pyÚ validate_udf s ÿ
|
ÿþÿr )ÚmaxsizezCallable[..., Scalar]ÚboolzPCallable[[np.ndarray, np.ndarray, np.ndarray, np.ndarray, int, Any], np.ndarray])r ÚnopythonÚnogilÚparallelr c sX t | |||tr ddl ntd j|||ddddddddd fd d
|
}|S ) a
|
Generate a numba jitted agg function specified by values from engine_kwargs.
|
|
1. jit the user's function
|
2. Return a groupby agg function with the jitted function inline
|
|
Configurations specified in engine_kwargs apply to both the user's
|
function _AND_ the groupby evaluation loop.
|
|
Parameters
|
----------
|
func : function
|
function to be applied to each group and will be JITed
|
nopython : bool
|
nopython to be passed into numba.jit
|
nogil : bool
|
nogil to be passed into numba.jit
|
parallel : bool
|
parallel to be passed into numba.jit
|
|
Returns
|
-------
|
Numba function
|
r NÚnumba©r r r ú
|
np.ndarrayÚintr ©r r ÚbeginÚendÚ num_columnsÚargsr c s t |t |kstt |}t ||f¡} |¡D ]X}||| ||
} |¡D ]4}
|
| || ||
|
|
f } | | f| |||
|
f< qVq4|S ©N©r ÚAssertionErrorÚnpÚemptyZprange© r r r% r& r' r( Z
|
num_groupsÚresultÚiZ group_indexÚjÚgroup©r Z
|
numba_funcr r Ú group_aggc s z*generate_numba_agg_func.<locals>.group_agg©r r r r Zjit)r r r r r4 r r3 r Úgenerate_numba_agg_func> s
|
"r6 zCallable[..., np.ndarray]c sX t | |||tr ddl ntd j|||ddddddddd fd d
|
}|S ) a
|
Generate a numba jitted transform function specified by values from engine_kwargs.
|
|
1. jit the user's function
|
2. Return a groupby transform function with the jitted function inline
|
|
Configurations specified in engine_kwargs apply to both the user's
|
function _AND_ the groupby evaluation loop.
|
|
Parameters
|
----------
|
func : function
|
function to be applied to each window and will be JITed
|
nopython : bool
|
nopython to be passed into numba.jit
|
nogil : bool
|
nogil to be passed into numba.jit
|
parallel : bool
|
parallel to be passed into numba.jit
|
|
Returns
|
-------
|
Numba function
|
r Nr r! r" r# r r$ c s¢ t |t |kstt |}t t | |f¡} |¡D ]d}||| ||
} |¡D ]@}
|
| || ||
|
|
f } | | f| ||| ||
|
|
f< qZq8|S r) r* r. r3 r r Úgroup_transform s (z6generate_numba_transform_func.<locals>.group_transformr5 )r r r r r7 r r3 r Ú generate_numba_transform_funcz s
|
"r8 )Ú__doc__Ú
|
__future__r Ú functoolsr Útypingr r r Únumpyr, Zpandas._typingr Zpandas.compat._optionalr Zpandas.core.util.numba_r r r Ú lru_cacher6 r8 r r r r Ú<module> s '
|
;
|
|
