o
    1 i                     @   s  d dl Z d dlmZ d dlmZ d dlmZmZ d dl	m
Z
 d dlmZmZmZ d dlmZ d dlmZmZ d d	lmZmZmZmZ d d
lmZmZmZmZmZmZ d dl m!Z!m"Z" d dl#m$Z$ d dl%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZR dZSe  z5d dlTZUd dlVmWZWmXZX e ZYeYdu seYedkrnd dlZm[Z[ e[ddZ\eYedkre\reUj]^d W n
 e_y   Y nw g dZ`dS )    N)parse)get_pyarrow_version)ActorPoolStrategyTaskPoolStrategy)TFXReadOptions)ExecutionOptionsExecutionResources	NodeIdStr)configure_logging)DataContextDatasetContext)DatasetSchemaSinkModeClickHouseTableSettings)BlockBasedFileDatasinkDatasink
DatasourceFileShuffleConfigReadTaskRowBasedFileDatasink)DataIteratorDatasetIterator)Preprocessor)-
from_arrowfrom_arrow_refsfrom_blocks	from_daft	from_daskfrom_huggingface
from_items	from_mars
from_modin
from_numpyfrom_numpy_refsfrom_pandasfrom_pandas_refs
from_sparkfrom_tf
from_torchrangerange_tensor
read_audio	read_avroread_bigqueryread_binary_filesread_clickhouseread_csvread_databricks_tablesread_datasource
read_deltaread_delta_sharing_tables	read_hudiread_icebergread_images	read_json
read_lance	read_mcap
read_mongo
read_numpyread_parquetread_parquet_bulkread_snowflakeread_sql	read_textread_tfrecordsread_unity_catalogread_videosread_webdataset)ArrowTensorTypeArrowVariableShapedTensorTypez21.0.0)env_bool!RAY_DATA_AUTOLOAD_PYEXTENSIONTYPEFz14.0.1T)?r   r   r   r   r   r   r   r   r   r   r   r   r   r	   r   r   r   r   r   r   r   r    r   r   r!   r"   r#   r$   r%   r&   r'   r(   r)   r   r*   r+   r,   r-   rB   r/   r0   r1   r3   r4   r5   r6   r7   r8   r9   r:   r;   r=   r<   r>   r?   r@   rA   rC   rD   rE   rF   r   r   )aZpandasZpackaging.versionr   parse_versionZray._private.arrow_utilsr   Zray.data._internal.computer   r   Z2ray.data._internal.datasource.tfrecords_datasourcer   Z'ray.data._internal.execution.interfacesr   r   r	   Zray.data._internal.loggingr
   Zray.data.contextr   r   Zray.data.datasetr   r   r   r   Zray.data.datasourcer   r   r   r   r   r   Zray.data.iteratorr   r   Zray.data.preprocessorr   Zray.data.read_apir   r   r   r   r   r   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   r9   r:   r;   r<   r=   r>   r?   r@   rA   rB   rC   rD   rE   rF   Z_map_actor_contextZpyarrowpaZ$ray.air.util.tensor_extensions.arrowrG   rH   Zpyarrow_versionZray._private.ray_constantsrI   rJ   ZPyExtensionTypeZset_auto_loadModuleNotFoundError__all__ rO   rO   ]/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/ray/data/__init__.py<module>   sD    2