o
    +Âifˆ  ã                   @   st   d dl mZmZ d dl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 G dd„ deƒZG dd	„ d	eƒZd
S )é    )ÚABCÚabstractmethod)ÚOptionalÚUnioné   )ÚDatasetÚDatasetDictÚFeaturesÚIterableDatasetÚIterableDatasetDictÚ
NamedSplit)ÚNestedDataStructureLikeÚPathLikec                   @   st   e Zd Z							ddeee  dee dee dede	de	d	ee
 fd
d„Zedeeeeef fdd„ƒZdS )ÚAbstractDatasetReaderNFÚpath_or_pathsÚsplitÚfeaturesÚ	cache_dirÚkeep_in_memoryÚ	streamingÚnum_procc           	      K   sF   || _ |s
t|tƒr|nd| _|| _|| _|| _|| _|| _|| _	d S )NÚtrain)
r   Ú
isinstanceÚdictr   r   r   r   r   r   Úkwargs)	Úselfr   r   r   r   r   r   r   r   © r   úH/var/www/html/corbot_env/lib/python3.10/site-packages/datasets/io/abc.pyÚ__init__	   s   
zAbstractDatasetReader.__init__Úreturnc                 C   ó   d S ©Nr   ©r   r   r   r   Úread   ó   zAbstractDatasetReader.read)NNNNFFN)Ú__name__Ú
__module__Ú__qualname__r   r   r   r   r	   ÚstrÚboolÚintr   r   r   r   r   r
   r   r#   r   r   r   r   r      s2    ø
þýüûúù
ø r   c                   @   sX   e Zd Z					ddee dedededee f
dd	„Ze	d
e
eef fdd„ƒZdS )ÚAbstractDatasetInputStreamNFr   r   r   r   r   c                 K   s(   || _ || _|| _|| _|| _|| _d S r!   )r   r   r   r   r   r   )r   r   r   r   r   r   r   r   r   r   r   #   s   	
z#AbstractDatasetInputStream.__init__r   c                 C   r    r!   r   r"   r   r   r   r#   3   r$   zAbstractDatasetInputStream.read)NNFFN)r%   r&   r'   r   r	   r(   r)   r*   r   r   r   r   r
   r#   r   r   r   r   r+   "   s&    úþýüû
úr+   N)Úabcr   r   Útypingr   r   Ú r   r   r	   r
   r   r   Úutils.typingr   r   r   r+   r   r   r   r   Ú<module>   s     