
    &`iq                     R    d dl mZ d dlmZ d dlmZ erd dlZ G d de          ZdS )    )TYPE_CHECKING)ArrowBlockBuilder)FileBasedDatasourceNc                   ,    e Zd ZdZdZdddefdZd ZdS )	BinaryDatasourcez8Binary datasource, for reading and writing binary files.bytesfzpyarrow.NativeFilepathc              #      K   |                                 }t                      }| j        |i}|                    |           |                                V  d S )N)readallr   _COLUMN_NAMEaddbuild)selfr	   r
   databuilderitems         /home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/data/_internal/datasource/binary_datasource.py_read_streamzBinaryDatasource._read_stream   sW      yy{{#%%!4(Dmmoo    c                     dS )N    )r   s    r   _rows_per_filezBinaryDatasource._rows_per_file   s    qr   N)__name__
__module____qualname____doc__r   strr   r   r   r   r   r   r   
   sQ        BBL2 #        r   r   )typingr   ray.data._internal.arrow_blockr   )ray.data.datasource.file_based_datasourcer   pyarrowr   r   r   r   <module>r$      s                < < < < < < I I I I I I NNN    *     r   