+
    xȇi                     D   R t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIHt	 ^ RI
Ht ]P                  P                  t]P                  ! R4      t]P                  ! R4      t]P                  ! R4      t]P&                  ! R. R
O4      t]P*                  R 4       t ! R R	4      tR# )z
Tests for the Apache Iceberg format.

Tests in this file use a simple Iceberg catalog based on SQLite, with the same
data used for Parquet tests (``pandas/tests/io/data/parquet/simple.parquet``).
N)read_iceberg	pyicebergzpyiceberg.catalogzpyarrow.parquetCatalogc           
   #   <  "   R V R2pRV 2p\        V R4      '       d   V P                  MRp\        P                  T;'       g    RRVVR7      pVP	                  R4       \
        P                  \        P                  ! \        4      P                  R	,          R
,          R,          4      pVP                  RVP                  R7      pVP                  V4       Vey   \        P                  P                  4       R,          p\        VRRR7      ;_uu_ 4       p	V	P!                  RV RV RV 24       RRR4       \"        P$                  ! \        4       \'        T;'       g    RW#R7      x  Ve   XP)                  4        R# R#   + '       g   i     L[; i5i)z
sqlite:///z/catalog.sqlitezfile://paramNdefaultsql)typeuri	warehousensdataparquetzsimple.parquetns.my_table)schemaz.pyiceberg.yamlwzutf-8)encodingzcatalog:
  z:
    type: sql
    uri: z
    warehouse: namer
   r   )hasattrr   pyiceberg_catalogload_catalogcreate_namespacepq
read_tablepathlibPath__file__parentcreate_tabler   appendhomeopenwrite	importlibreloadr   unlink)
requesttmp_pathr
   r   catalog_namecatalogdftableconfig_pathfs
   &&        l/Users/max/.openclaw/workspace/postharvest/venv/lib/python3.14/site-packages/pandas/tests/io/test_iceberg.pyr*   r*      sp     xj
0C($I$+GW$=$=7==4L,,!!		 - G T"	X%%.:=MM
B   ryy AE	LLll''),==+sW55GG . 

 {  6 	*+
|00yc
OO   65s+   AFCFF	6/F&#F	F	Fc                      a  ] tR t^Ct o R t]P                  P                  RRR.RR7      R 4       tR t	R	 t
R
 tR t]P                  P                  RRR.RR7      R 4       tR tR tRtV tR# )TestIcebergc                    \         P                  ! R . ROR. RO/4      p\        RRVP                  /R7      p\        P
                  ! W24       R# )ABr   r
   catalog_propertiesN         foor<   r<   pd	DataFramer   r
   tmassert_frame_equalselfr*   expectedresults   &&  r/   	test_readTestIceberg.test_readD   sK    <<Y*
  %w{{3
 	f/    r*   r   pandas_testsT)indirectc                    \         P                  ! R . ROR. RO/4      p\        RVP                  R7      p\        P
                  ! W24       R# )r3   r4   r   r)   Nr7   r;   )r>   r?   r   r   r@   rA   rB   s   &&  r/   test_read_by_catalog_name%TestIceberg.test_read_by_catalog_nameQ   sF    <<Y*
  
 	f/rH   c                    \         P                  ! R ^^.RRR./4      p\        RRVP                  /RR7      p\        P
                  ! W24       R# )r3   r4   r<   r   r
   zA > 1)r6   
row_filterNr=   rB   s   &&  r/   test_read_with_row_filter%TestIceberg.test_read_with_row_filter_   sU    <<aVeU^
  %w{{3

 	f/rH   c           	     X   \         P                  ! R . R
O/4      p\        RRVP                  /R.RR7      p\        P
                  ! W24       \        P                  ! \        RR7      ;_uu_ 4        \        RRVP                  /R.RR7       R	R	R	4       R	#   + '       g   i     R	# ; i)r3   r   r
   aF)r6   columnscase_sensitivez^Could not find column)matchTNr7   )	r>   r?   r   r
   r@   rA   pytestraises
ValueErrorrB   s   &&  r/   test_read_with_case_sensitive)TestIceberg.test_read_with_case_sensitivem   s    <<Y

  %w{{3E 	
 	f/]]:-EFF$)7;;#7#	 GFFFs   1BB)	c                    \         P                  ! R ^^.RRR./4      p\        RRVP                  /^R7      p\        P
                  ! W24       R# )r3   r4   r<   r   r
   )r6   limitNr=   rB   s   &&  r/   test_read_with_limit TestIceberg.test_read_with_limit   sU    <<aVeU^
  %w{{3

 	f/rH   c                    \         P                  ! R . ROR. RO/4      pVP                  RRVP                  /VP                  R7       \        RRVP                  /R7      p\        P                  ! W24       R# )	r3   r4   ns.new_tabler
   )r6   locationr5   Nr7   r;   r>   r?   
to_icebergr
   r   r   r@   rA   rC   r*   r+   rE   s   &&  r/   
test_writeTestIceberg.test_write   sv    \\Y*
 	 %w{{3&& 	 	

  %w{{3
 	f)rH   c                    \         P                  ! R . ROR. RO/4      pVP                  RVP                  R7       \	        RVP                  R7      p\
        P                  ! W24       R# )r3   r4   rb   rL   Nr7   r;   )r>   r?   re   r   r   r@   rA   rf   s   &&  r/   test_write_by_catalog_name&TestIceberg.test_write_by_catalog_name   sc    \\Y*
 	  	 	
  
 	f)rH   c                Z   \        R RVP                  /R7      p\        P                  ! R. R	OR. R
O/4      p\        P                  ! W#.RR7      pVP                  R RVP                  /VP                  RR7       \        R RVP                  /R7      p\        P                  ! WT4       R# )r   r
   r5   r3   r4   T)ignore_indexr6   rc   r    Nr7   r;   )	r   r
   r>   r?   concatre   r   r@   rA   )rC   r*   originalnewrD   rE   s   &&    r/   *test_write_existing_table_with_append_true6TestIceberg.test_write_existing_table_with_append_true   s     %w{{3
 llY*
 99h_4@ %w{{3&&	 	 	
  %w{{3
 	f/rH   c                    \         P                  ! R . ROR. R	O/4      pVP                  RRVP                  /VP                  RR7       \        RRVP                  /R7      p\        P                  ! W24       R# )
r3   r4   r   r
   Frn   r5   Nr7   r;   rd   rf   s   &&  r/   +test_write_existing_table_with_append_false7TestIceberg.test_write_existing_table_with_append_false   sy    \\Y*
 	 %w{{3&&	 	 	
  %w{{3
 	f)rH    N)__name__
__module____qualname____firstlineno__rF   rX   markparametrizerM   rQ   r[   r_   rg   rj   rr   ru   __static_attributes____classdictcell__)__classdict__s   @r/   r1   r1   C   s     0 [[YN(CdS0 T00,0*$ [[YN(CdS* T*"00* *rH   r1   r   )__doc__collectionsr$   r   rX   pandasr>   pandas._testing_testingr@   pandas.io.icebergr   r|   
single_cpu
pytestmarkimportorskipr   r   r   
namedtupler   fixturer*   r1   rw   rH   r/   <module>r      s          *[[##
,	''(;< *+

 
 ,H
I # #L[* [*rH   