o
    QDi                     @  sP   d dl mZ ddlmZ ddlmZ ddlmZ ddlmZ G dd	 d	eZ	d
S )    )annotations   )platform)TableResource)Parser   )ParquetControlc                   @  s*   e Zd ZdZg dZdd Zd
ddZd	S )ParquetParserzJSONL parser implementation.)
arraybooleandatetimedatedurationintegernumberobjectstringtimec           
   	   c  s    t | jj}| jj}| jjr tjjj	j
| jjddd}|j}tj|}t|jdi | ddD ]2\}}t|dd }t|jddD ]\}}	|dkrS|dkrSqF|	V  qFW d    n1 saw   Y  q4d S )	NrbF)is_textr   )startpandas)dataformat )r   from_dialectresourcedialectnormpathremoter   r   iocommon
get_handlehandlefastparquetParquetFile	enumerateiter_row_groups	to_pythonr   cell_stream)
selfcontrolr#   handlesfilegroupdfr   linecellsr   r   \/var/www/Datamplify/venv/lib/python3.10/site-packages/frictionless/formats/parquet/parser.pyread_cell_stream_create   s&   

$z%ParquetParser.read_cell_stream_createsourcer   c                 C  s   t j| jj|  d S )N)r   r$   writer   r   	to_pandas)r*   r4   r   r   r2   write_row_stream.   s   zParquetParser.write_row_streamN)r4   r   )__name__
__module____qualname____doc__supported_typesr3   r7   r   r   r   r2   r	   	   s
    r	   N)

__future__r   r   	resourcesr   systemr   r+   r   r	   r   r   r   r2   <module>   s    