+
    QV-j  ã                   ód   € ^ RI Ht ^ RIt^RIHtHt ^RIHt ^RIH	t	 ^RI
Ht  ! R R]4      tR# )	é    )ÚOptionalN)ÚFeaturesÚ
NamedSplit)ÚDownloadMode)ÚSpark)ÚAbstractDatasetReaderc                   óL   a a€ ] tR t^t oRtRV3R lV 3R llltR tRtVtV ;t	# )ÚSparkDatasetReaderzÕA dataset reader that reads from a Spark DataFrame.

When caching, cache materialization is parallelized over Spark; an NFS that is accessible to the driver must be
provided. Streaming is not currently supported.
c                ó˜   <€ V ^8„  d   QhRS[ P                  P                  RS[S[,          RS[S[,          RS[RS[RS[RS[RS[R	S[/	# )
é   ÚdfÚsplitÚfeaturesÚ	streamingÚ	cache_dirÚkeep_in_memoryÚworking_dirÚload_from_cache_fileÚfile_format)ÚpysparkÚsqlÚ	DataFramer   r   r   ÚboolÚstr)ÚformatÚ__classdict__s   "€Úb/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/datasets/io/spark.pyÚ__annotate__ÚSparkDatasetReader.__annotate__   sy   ø€ ÷ 
ñ 
á�K‰K×!Ñ!ð
ñ ™
Õ#ð
ñ ™8Õ$ð	
ñ
 ð
ñ ð
ñ ð
ñ ð
ñ #ð
ñ ñ
ó    c
                ó„   <€ \         SV `  ! RR VRVRVRVRV/V
B  W€n        W�n        \	        RRVRVRVRV/V
B V n        R# )	r   r   r   r   r   r   r   N© )ÚsuperÚ__init__Ú_load_from_cache_fileÚ_file_formatr   Úbuilder)Úselfr   r   r   r   r   r   r   r   r   ÚkwargsÚ	__class__s   &&&&&&&&&&,€r   r$   ÚSparkDatasetReader.__init__   s’   ø€ ô 	‰Òñ 	
Øð	
àð	
ð  ð	
ð *ð		
ð
  ð	
ð ò	
ð &:Ô"Ø'ÔÜñ 
Øð
àð
ð  ð
ð $ð	
ð
 ñ
ˆŽr    c                óT  € V P                   '       d'   V P                  P                  V P                  R 7      # V P                  '       d   RM\
        P                  pV P                  P                  VV P                  R7       V P                  P                  V P                  R 7      # ))r   N)Údownload_moder   )
r   r'   Úas_streaming_datasetr   r%   r   ÚFORCE_REDOWNLOADÚdownload_and_preparer&   Ú
as_dataset)r(   r-   s   & r   ÚreadÚSparkDatasetReader.read1   s€   € Ø�>�>ˆ>Ø—<‘<×4Ñ4¸4¿:¹:Ð4ÓFÐFØ $× :× :Ð :™Ä×@]Ñ@]ˆØ�‰×)Ñ)Ø'Ø×)Ñ)ð 	*ô 	
ð �|‰|×&Ñ&¨T¯Z©ZÐ&Ó8Ð8r    )r&   r%   r'   )NNTNFNTÚarrow)
Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r$   r2   Ú__static_attributes__Ú__classdictcell__Ú__classcell__)r*   r   s   @@r   r
   r
      s   ù‡ € ñ÷
õ 
÷>9ò 9r    r
   )Útypingr   r   Ú r   r   Údownloadr   Úpackaged_modules.spark.sparkr   Úabcr   r
   r"   r    r   Ú<module>rB      s$   ðÝ ã ç #Ý #Ý 0Ý &ô.9Ð.ö .9r    