>ie;dZddlmZddlZddlmZddlm Z ddl m Z e dZ e dZe dZe dZe d Ze d Ze d Ze d Ze d Ze dZe dZe dZe dZe dZe dZe dZe dZe dZ d dZdZ d!dZ!dZ"d"dZ#d#dZ$dS)$z4 Dispatch in dask.dataframe. Also see extension.py ) annotationsN)Dispatchmake_meta_dispatch make_meta_obj meta_nonemptymeta_lib_from_arrayhash_object_dispatchgroup_split_dispatchget_parallel_typeCategoricalDtypeconcattolistis_categorical_dtypeunion_categoricalsgrouperpartd_encode_dispatchpyarrow_schema_dispatchfrom_pyarrow_table_dispatchto_pyarrow_table_dispatchto_pandas_dispatchouterFTc t|dkr|dStt|d}||f|||||d|S)aConcatenate, handling some edge cases: - Unions categoricals between partitions - Ignores empty partitions Parameters ---------- dfs : list of DataFrame, Series, or Index axis : int or str, optional join : str, optional uniform : bool, optional Whether to treat ``dfs[0]`` as representative of ``dfs[1:]``. Set to True if all arguments have the same columns and dtypes (but not necessarily categories). Default is False. ignore_index : bool, optional Whether to allow index values to be ignored/dropped during concatenation. Default is False. ignore_order : bool, optional Whether to ignore the order when doing the union of categoricals. Default is False. r)axisjoinuniformfilter_warning ignore_index)lenconcat_dispatchdispatchtype)dfsrrrrrkwargsfuncs 7lib/python3.11/site-packages/dask/dataframe/dispatch.pyr r #ss< 3xx1}}1v ''SV 55t  )%      ct|d|}tt|}||S)Ndtype)getattris_categorical_dtype_dispatchr!r"objr%s r&rrPs: #w $ $C ( 1 1$s)) < rYs #"""""X233)) )) h455x 677x 677H011%X&899(8$$(8$$ ()? @ @&h';<<8I&& !899"(#<==&h'DEE$H%@AAX233   * * * * Z 8888  0(0(0(0(fVVVVVVr'