Ë
    tPêj‰  ã                  óR   — d Z ddlmZ ddlZddlmZ ddlZddlm	Z	  G d„ de	«      Z
y)	z$Parquet serializer for Focus export.é    )ÚannotationsN)ÚFinalé   )ÚFocusSerializerc                  ó   — e Zd ZdZdZdd„Zy)ÚFocusParquetSerializerz3Serialize normalized Focus frames to Parquet bytes.Úparquetc                óÔ   — |j                  «       s|nt        j                  |j                  ¬«      }t	        j
                  «       }|j                  |d¬«       |j                  «       S )z/Encode the provided frame as a parquet payload.)ÚschemaÚsnappy)Úcompression)Úis_emptyÚplÚ	DataFramer   ÚioÚBytesIOÚwrite_parquetÚgetvalue)ÚselfÚframeÚtargetÚbuffers       ús/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/integrations/focus/serializers/parquet.pyÚ	serializez FocusParquetSerializer.serialize   sJ   € à%*§^¡^Ô%5™¼2¿<¹<ÈuÏ|É|Ô;\ˆÜŸ
™
›ˆØ×Ñ˜V°ÐÔ:Ø�‰Ó Ð ó    N)r   zpl.DataFrameÚreturnÚbytes)Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú	extensionr   © r   r   r   r      s   „ Ù=à€Iô!r   r   )r!   Ú
__future__r   r   Útypingr   Úpolarsr   Úbaser   r   r#   r   r   ú<module>r(      s#   ðÙ *å "ã 	Ý ã å !ô
!˜_õ 
!r   