<>i SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK rSSKJrJr SSKJr SSKr"SS5r"SS\5r"S S \5r"S S \5r\R4S 5r\R4S5r\R4S5r\R4"\R<"SSS9\R<"SSS9/S9S5rSr Sr!Sr"\RFRISSS/5S5r%Sr&\RFR(S5r'S r(S!r)\RFR(\RFRTS"55r+\RFR(S#5r,S$r-\RFRIS%\R\R_5\R\R_S&S'9/5S(5r0S)r1\RFRIS%\R\R_5\R\R_S&S'9/5S*5r2S+r3\RFR(S,5r4\RFR(S-5r5S.r6\RFRnS/5r8S0r9\RFRIS%\R\Ru5\R\RuS1S29\R\RuS1S39\R\Ru\R\RvRxS49\R\RuS1\R\RvRxS59/5S65r=S7r>S8r?S9r@S:rAS;rB\RFR(S<5rC\R4S=5rDS>rES?rFS@rGSArH\RFRSB5rJSCrKSDrLSErM"SFSG\R5rO"SHSI\5rP\R4SJ5rQ\RFRSK5rS\RFRSL5rT\RFR(SM5rU\RFR(SN5rV\RFR(\RFRISOSPSQ/5SR55rWSSrX\RFR(ST5rY\RFR(SqSUj5rZ\RFR(SV5r[\RFR(SW5r\\RFR(SX5r]\RFR(SY5r^\RFR(SZ5r_\RFR(S[5r`\RFR(S\5raS]rbS^rcS_rdS`reSarfSbrgScrhSdriSerjSfrkSgrl\R4Sh5rm\RFRn\RFRISiSjSk/S1Sl9Sm55rn\R4Sn5ro\RFRISoSjSk/S1Sl9Sp5rpg!\ a Sr GN2f=f!\ a GN(f=f)r)UserListN)changed_environ invoke_script)assert_frame_equalc<\rSrSrSrS4SjrSrSrS SjrSr g) IpcFixture,Nc,[R"5$NioBytesIOU/var/www/html/land-tabula/venv/lib/python3.13/site-packages/pyarrow/tests/test_ipc.pyIpcFixture./s BJJLrc:XlUR5Ulgr ) _sink_factoryget_sinksink)self sink_factorys r__init__IpcFixture.__init__/s)MMO rc"UR5$r )rrs rrIpcFixture.get_sink3s!!##rc6URR5$r )rgetvaluers r get_sourceIpcFixture.get_source6syy!!##rcSn[R"S[R"54S[R"54/5nUR UR U5n/n[ U5HZn[R"[ U5Vs/sHn[R"5PM sn/SQ/US9n URU 5 M\ U(a1[RRU5n URU 5 OUHn URU 5 M URUlUR!5 U$s snf)Nonetwo)fooNbarbazbazquxschema)par,float64utf8 _get_writerrrange record_batchrandomappendTable from_batches write_table write_batchstats write_statsclose) r num_batchesas_tablenrowsr,writerbatchesi_batchtables r write_batchesIpcFixture.write_batches9sUBJJL1E27793EFG!!$))V4{#AOO+0<8>>>V\\"eD,<,<&====rrF) rGrHrIrJis_filerRr0rfrKrrrrMrMSsGGC>rrMc&\rSrSrSrSrSrSrSrg)StreamFormatFixturenFNcT[RRUUURS9$rP)r-rS new_streamrRrUs rr0StreamFormatFixture._get_writervs+vv   LL!  rr) rGrHrIrJuse_legacy_ipc_formatrRrir0rKrrrrkrkns"GG rrkc\rSrSrSrSrg)MessageFixture~c.[R"X5$r r-RecordBatchStreamWriterrUs rr0MessageFixture._get_writer))$77rrN)rGrHrIrJr0rKrrrrrrr~s8rrrc[5$r )rrrr ipc_fixturerzs <rc[5$r )rMrrr file_fixturer|s  rc[5$r )rkrrrstream_fixturer~   rr|z File Format)idr~z Stream Format)paramsc8URUR5$r )getfixturevalueparamrequests rformat_fixturers  " "7== 11rcSn[R"[R5 [RR [R "U55 SSS5 g!,(df  g=fNr)pytestraisesr- ArrowInvalidrSrZrYbufs rtest_empty_filers> C r ' -. ( ' 's 4A$$ A2c"URSS9 g)NFrXrfr|s rtest_file_simple_roundtriprs!!5!1rc"URSS9 g)NTrXrrs rtest_file_write_tablers!!4!0rrc,[R"5$r r rrrrrs BJJLrc,[R"5$r )r-BufferOutputStreamrrrrrs B ! ! #rcN[U5nUR5n[R"UR 55n[R R U5nUR5n[RRU5nURU5(degr ) rMrEr-rYr!rSrZread_allr5r6r_)rfixturer@rdreresultexpecteds rtest_file_read_allrs|  -G##%GOOG$6$6$89M VV  m ,F __ Fxx$$W-H == " "" "rc|UR5 UR5n[RR U5n[RR [R "U55n[R "U5nUR5nUR5nUR5nURU5(deURU5(deURnURS:XdeURS:XdeURU:XdeURU:XdegNr$) rEr!r-rSrZrYRecordBatchFileReaderrr_r9 num_messagesr[) r|sourcereader1reader2reader3result1result2result3st1s rtest_open_file_from_bufferrs  $ $ &Fffv&Gffrv67G&&v.G G G G >>' " "" " >>' " "" " --C   q   ! !Q && & ==C   ==C  rcjUR5Vs/sHoR5PM nn[R"UR 55n[R R U5nUR5n[R"U5RSS9n[XV5 gs snfNT)drop) rE to_pandasr-rYr!rSrZ read_pandaspdconcat reset_indexr)r|rCframesrdrerrs rtest_file_read_pandasrs-9-G-G-I J-IEoo-IF JOOL$;$;$=>M VV  m ,F    !Fyy ,,$,7Hv(KsB0cUR5 UR5nURS5Rn[ US5nUR U5 SSS5 [ RR[R"U55R5n[ RR[ R"U55R5nURU5(deg!,(df  N=f)N file.arrowwb)rEr!joinstrpathopenwriter-rSrZpathlibPathrOSFiler_)r|tmpdirrpathft1t2s rtest_file_pathlibrs  $ $ &F ;;| $ , ,D dD Q     ',,t, - 6 6 8B   "))D/ * 3 3 5B 99R===  s C== D c[R"S5n[R"[R 5 [R RU5 SSS5 g!,(df  g=fr)r rrrr-rrS open_streamrs rtest_empty_streamrs= **S/C r ' 3 ( ' 's A$$ A2c&[R"5n[R"[R"SU5/5nUR S5R n[R "US5n[RRXB5n[R"S/US9n[R"U/U5nURU5 SSS5 SSS5 [SU5 g!,(df  N#=f!,(df  N,=f)zARROW-15783: Verify to_pandas works for interval types. Interval types require static structures to be enabled. This test verifies that they are when no other library functions are invoked. numsrrtypeNzread_record_batch.py) r-month_day_nano_intervalr,fieldrrrrSrTarrayr2rr)rmdn_interval_typer,rrr?interval_arrayrCs r"test_read_year_month_nano_intervalrs224 YY):;< =F ;;| $ , ,D 4 $ VV__T *fXXyk8IJNOO^$4f=E LL +  ($/ + *  s%4 DAC1D1 C? ;D Dc t[R"[RR S5[R "S[R SSS/SS/SS9S.5n[RRU5nURURUR5nURU5 SSS5 [RR[R "UR#555R%5n['UR)5U5 g!,(df  Nx=f)Nr$r'r(T categoriesorderedr%r&)r DataFramenpr3randn Categoricalnanr- RecordBatch from_pandasr0rr,r8rSrrYr!rrr)r~dfrCwrrDs r!test_stream_categorical_roundtripr s yyq!~~ubffeUEB*/&*, B NN & &r *E  # #N$7$7 F" u GVV  0I0I0K L Mhj u("- G Fs %D)) D7cUR5 UR5n[RR U5n[RR [R "U55n[R "U5nUR5nUR5nUR5nURU5(deURU5(deURnURS:XdeURS:XdeURU:XdeURU:Xde[U5[UR5:Xdegr)rEr!r-rSrrYRecordBatchStreamReaderrr_r9rr[rcr:) r~rrrrrrrrs rtest_open_stream_from_bufferrs#  "  & & (Fff  (Gff  !89G((0G G G G >>' " "" " >>' " "" " --C   q   ! !Q && & ==C   ==C   :~99: :: :rrRF use_threadscFUR5 UR5n[RR X!S9nUR 5 UR nURS:XdeURS:Xde[U5[UR5:XdegNrQrr$) rEr!r-rSrrr9rr[rcr:)r~rRrrests rtest_open_stream_optionsr5s   "  & & (F VV    8F OO B ??a   A %% % 9n889 99 9rcUR5 UR5n[R"[5 [ R RUSS9 SSS5 g!,(df  g=fNTrQ)rEr!rr TypeErrorr-rSr)r~rs r#test_open_stream_with_wrong_optionsrGsK  "  & & (F y ! 640 " ! ! A## A1cUR5 UR5n[RR X!S9nUR 5 UR nURS:XdeURS:Xdegr) rEr!r-rSrZrr9rr[)r|rRrrers rtest_open_file_optionsrOsn   $ $ &F VV  f  6F OO B ??a   A %% %rcUR5 UR5n[R"[5 [ R RUSS9 SSS5 g!,(df  g=fr)rEr!rrrr-rSrZ)r|rs r!test_open_file_with_wrong_optionsr`sK  $ $ &F y ! . " ! !rc [R"[RR S5[R "S[R SSS/SS/SS9S.5n[RRUSS9n[RRUSS9nURURUR5nURU5 URU5 SSS5 [RR![R""UR%555R'5n[)UR+5[R,"X/SS 95 g!,(df  N=f) Nr$r'r(TrrFpreserve_index ignore_index)rrrr3rrrr-r5rrr0rr,rrSrrYr!rrrr)r~rrDrCrs rtest_stream_write_dispatchrhs yyq!~~ubffeUEB*/&*, B HH E :E NN & &r% & @E  # #N$7$7 F"   GVV  0I0I0K L Mhj u(yy"=? G Fs #E++ E9c $[R"S[RR S505n[ R RUSSSS9n[ R RUSS9n[ RRX#U/5nURURUR5nURUSS9 SSS5 [[ RR!UR#555n[[%[&U55/SQ:Xde[ RRU5n[)UR+5[R,"USSXSS/S S 95 g!,(df  N=f) Nr% Fr) max_chunksize)rrr$rTr)rrrr3rr-rrr5r6r0rr,r7listrSrr!mapr\rrr)r~rb1b2rDrr@ result_tables rtest_stream_write_table_batchesr }s>  ryyr" B  # #BsGE # BB  # #Bu # =B HH ! !22, /E  # #N$7$7 F" uB/ G266%%n&?&?&ABCG C! "o 55 588((1L|--/yy"Sb'2#2w!7.245 G Fs <F FcUR5n[R"UR55n[RR U5nUR RUSR 5(deSn[U5H$upVURX5(deUS- nM& U[U5:Xde[R"[5 UR5 SSS5 g!,(df  g=fNrr)rEr-rYr!rSrr,r_r]r\rr StopIterationread_next_batch)r~r@rdretotalrA next_batchs rtest_stream_simple_roundtriprs**,GOON$=$=$?@M VV   .F ==   1 1 2 22 2 E"6*   ,,,,  + CL  } %  & % %s #C== D c"[R"5n[S5Vs/sHn[R"SS5PM nn[ R RU/S/S9n[ RRSS9n[ RRXRUS9nURU5 SSS5 [UR55n[R"5n[ R"SS S 9n[ RRUS9n[ RRXsRUS9nURU5 SSS5 [UR55n X:wde[ RR!U5R#5n [ RR!U5R#5n X:Xdegs snf!,(df  GN8=f!,(df  N=f) Ni'rrvaluesnameszstd compressionrQr$)compression_level)r rr1r3randintr-r5 from_arraysrSIpcWriteOptionsRecordBatchFileWriterr,r7r\r CodecrZr) rrBrrDrRr?len1sink2codeclen2rrs rtest_compression_roundtripr"s ::G  # #w'?'? ?? ? VV   .F ==   1 1 2 22 2 E"6*   ,,,,  + CL  } %  & % %s 2E  Ec[RR5nURSLdeURSLdeUR [RR R:XdeUR/:XdeSUlURSLde[RR RUlUR [RR R:Xde[RR RUlUR [RR R:XdeSUlURSLdeSS/UlURSS/:Xde[R"[5 SUlSSS5 [RRSS[RR RS/S9nURSLdeURSLdeUR [RR R:XdeURS/:Xdeg!,(df  N=f)NTFrr)rensure_native_endianensure_alignmentincluded_fields)r-rSIpcReadOptionsrr6r7 AlignmentAnyr8DataTypeSpecificAt64ByterrrrQs rtest_read_optionsr>sff##%G   $ && &  ' '4 // /  # #rvv'7'7';'; ;; ;  " "b (( (#(G  ' '5 00 0!vv//@@G  # #rvv'7'7'H'H HH H!vv//88G  # #rvv'7'7'@'@ @@ @G   % '' ' !fG  " "q!f ,, , y !"& "ff##))::QC$G   % '' '  ' '5 00 0  # #rvv'7'7'H'H HH H  " "qc )) ) " !s (I%% I3c[RR5n[RRS/S9n[RR [R "/SQ5[R "/SQ5/SS/S9nUR URUR5nURU5 SSS5 UR5n[RRXQS9n[RRXR[R"5S 9nUR5nUR5n URS :XdeU RS:Xde[RR [R "/SQ5/S/S9n X:XdeX:Xdeg!,(df  N=f) Nr)r8r'r(bazr*rrrabrrQ)rR memory_poolr)r-rSr9r5rrr0rr,r7r!rsystem_memory_poolr num_columns) r~options1options2rDrrrrrrrs r!test_read_options_included_fieldsrK8svvv$$&Hvv$$aS$9H HH "((+G"H!#,!7"9(+Sz ! 3E  # #N$7$7 F" u G  & & (Fff   :Gff  b.C.C.E!GG G G   ! ## #   ! ## #xx##RXXl%;$TR[R"5T5nU(a1[RR U5nUR U5 OUHnUR U5 M URsSSS5 $!,(df  g=fr )r0r-MockOutputStreamr5r6r7r8r9)r@r=r?rDrCrr,s rrE,test_dictionary_delta..write_batches_sv  ' '(;(;(=(.039--g6""5)$E&&u-%<<000s AB Br$rT)emit_dictionary_deltasrr)unify_dictionariesrXrh)r- dictionaryint8r/rrrr,rirrrr[num_dictionary_batchesnum_replaced_dictionariesnum_dictionary_deltasrprSrrR) rtydatavr@batches_delta_onlyrErr,s ` @rtest_dictionary_deltar]Qs9 rwwy"'') ,B ! EN ( FO  DA ""BHHQ$8#9'"K !! QZ  F    ]]2?? + ' ",]]2?? + , -, +7 #$$)))((A---++q000''1,,,+/N(VV33#4%N ]]2?? + ' ", +7 #$$)))((A---++q000''1,,, ) *B A %% % $ $ )) ) ' '1 ,, , # #q (( (VV334N w .B A %% %((A---++q000''1,,,((A---++q000''1,,,A&, +, +, +s*c\ [R"[R"S[R"55/5n[RR [R "5U5nUR(aeUR[RRR:Xde[RR[R "5U5nUR(aeUR[RRR:Xde[SS5 [RR [R "5U5nUR(deUR[RRR:Xde[RR[R "5U5nUR(deUR[RRR:XdeSSS5 [SS5 [RR [R "5U5nUR(aeUR[RRR:Xde[RR[R "5U5nUR(aeUR[RRR:XdeSSS5 [SS5 [SS5 [RR [R "5U5nUR(deUR[RRR:Xde[RR[R "5U5nUR(deUR[RRR:XdeSSS5 SSS5 g!,(df  GN9=f!,(df  GNA=f!,(df  N;=f!,(df  g=f)Nr'ARROW_PRE_0_15_IPC_FORMAT1ARROW_PRE_1_0_METADATA_VERSION)r-r,rint32rSrnr_use_legacy_format_metadata_versionr*r$rTrr+)r,r?s r!test_envvar_set_legacy_ipc_formatres YY 34 5F VV  r446 ?F((( (  # #rvv'='='@'@ @@ @ VV__R224f =F((( (  # #rvv'='='@'@ @@ @ 4c :""2#8#8#:FC((((''266+A+A+D+DDDD!6!6!8&A((((''266+A+A+D+DDDD ; 93 ?""2#8#8#:FC,,,,''266+A+A+D+DDDD!6!6!8&A,,,,''266+A+A+D+DDDD @ 93 ? 8# >VV&&r'<'<'>GF,, ,,++rvv/E/E/H/HH HHVV__R%:%:% @ ?s?C5Q( C5Q: R!C5R R( Q7: R  R R R+c8UR5n[R"UR55n[RR U5nUR 5n[RRU5nURU5(degr ) rEr-rYr!rSrrr5r6r_)r~r@rdrerrs rtest_stream_read_allrgsp**,GOON$=$=$?@M VV   .F __ Fxx$$W-H == " "" "rcBUR5Vs/sHoR5PM nnUR5n[RR U5nUR 5n[R"U5RSS9n[XV5 gs snfr) rErr!r-rSrrrrrr)r~rCrrdrerrs rtest_stream_read_pandasris-;-I-I-K L-KEoo-KF L"--/M VV   .F    !Fyy ,,$,7Hv( MsBcUR5nUR5n[R"U5n[RR U5nU[ U54$r )rEr!r-rY MessageReaderrr)r~r@rd buf_readerres rexample_messagesrmsQ**,G"--/M/J    ) )* 5F DL  rcL[R"[5 [[R "55 SSS5 [R"[5 [[R "55 SSS5 g!,(df  NP=f!,(df  g=fr )rrrreprr-Messagerkrrrtest_message_ctors_no_segfaultrqsZ y ! RZZ\ " y ! R     " ! " ! " !sBB B B#cUup[U5S:XdeUSRS:Xde[USR[R 5(de[USR [R 5(deUSR[RR:XdeUSSHnURS:Xde[UR[R 5(de[UR [R 5(deUR[RR:XaMe g)Nrrr,rz record batch) r\rr`metadatar-Bufferbodyr'r*r$)rmrBmessagesmsgs rtest_message_readerrxs"KA x=A   A;  x '' ' hqk**BII 6 66 6 hqk&& 2 22 2 A; ' '2+=+=+@+@ @@ @|xx>)))#,, 2222#((BII....##r'9'9'<'<<<< rcUupUSnUR5n[R"UR5S-5n[RR U5n[RR U5n[RR UR55n[RR U5n UR U5(deUR U5(deUR U5(deUR U 5(de[R"[RSS9 [RR [R"S55 SSS5 [R"[5 [RR U5 SSS5 g!,(df  NQ=f!,(df  g=f)NrrzCorrupted messagematchsab) serializer-rY to_pybytesrSr2r_rrrEOFError) rmrBrvrwrrerestored restored2 restored3 restored4s r#test_message_serialize_read_messagersQ"KA 1+C --/C __S^^-1 2Fvv""3'H##F+I##CNN$45I##F+I ::h    ::i  ::i  ::i  r.A B BOOE23 C x  F# !  C B ! s4G $ G G G,cUupUH;n[U5nSU;deSU;deSU;deSUR3U;aM;e g)Nz {self.type}z{metadata_len}z {body_len}ztype: )strr)rmrBrvrwss r%test_message_repr_shows_actual_valuesrs_"KA HA%%%q(((1$$$z"a''' rc|UupUHn[R"5n[R"USS9nURU5 SSS5 UR 5n[R R [R"USS95nURU5(aMe g!,(df  Nm=f)Ngzipr) r-r output_stream serialize_tor rSr2 input_streamr_)rmrBrvr3raw_outcompressed_outcompressed_bufrs r!test_message_read_from_compressedrs#KA'')   g6 :n   0;!))+$$R__^AG&IJ}}W%%%% : :s B-- B; cUup[RRUS5nURUSR5(degr )r-rS read_schemar_r,)rmr@rvr,s rtest_message_read_schemar*sA(G VV   ,F ==** + ++ +rcUup[XSS5HFup4[RRXCR5nUR U5(aMFe g)Nr)zipr-rSread_record_batchr,r_)rmr@rvrCr3 read_batchs rtest_message_read_record_batchr0sP(Gg|4VV--g||D   ''''5rc*[R"[R"S/[R"5S9/S/S9n[R"5n[R R XR5nURU5 SSS5 UR5n[R"[SS9 [R RX0R5 SSS5 g!,(df  Nj=f!,(df  g=f)Nfoorstrsrz type record batch but got schemarz)r-r2rr/rrSrnr,r8r rrIOErrorr)rCstreamr?rs r.test_read_record_batch_on_stream_error_messager8s OORXXvhRWWY?@#)( ,E  " " $F   6<< 0F5! 1 // C w? A   ll3 A A 1 0 A As=C3*D3 D Dc&\rSrSrSrSrSrSrg)StreamReaderServeriIcP[R"[R[R5UlURR S5 URR S5 URR 5up#XlSUl/Ul SUl U$)N) 127.0.0.1rr) socketAF_INET SOCK_STREAM_sockbindlisten getsockname _do_read_all_schema_batches_table)r do_read_allhostports rinitStreamReaderServer.initKsu]]6>>63E3EF  () !ZZ++- '    rcURR5upURSS9n[RR U5nUR UlUR(aUR5Ul O/[U5H upVURRU5 M" UR5 URR5 g!UR5 URR5 f=f)Nrbmode)racceptmakefiler-rSrr,rrrrr]rr4r;)r connectionclient_addressrrerArCs rrunStreamReaderServer.runVs%)ZZ%6%6%8"  ((d(3FVV''/F!==DL  $oo/ )& 1HAMM((/!2     JJ        JJ   s BC,D cnURUR(a UR4$UR4$r )rrrrrs r get_resultStreamReaderServer.get_resultes2 T->->dkk$ $]]$ $r)rrrrrN)rGrHrIrJrrrrKrrrrrIs  $rrc2\rSrSrSrSrSrSrSrSr g) SocketStreamFixtureijcgr rrs rrSocketStreamFixture.__init__ls rc`[5UlURRU5nURR5 [R"[R [R 5UlURRSU45 UR5Ul g)Nr) r_serverrstartrrrrconnectrr)rrrs r start_server SocketStreamFixture.start_serverqsp)+ ||  - ]]6>>63E3EF  K./MMO rc0SSKnURRURSS55 URR 5 UR R 5 URR5 URR5$)NrQ) structrrpackflushrr;rrr)rrs rstop_and_get_result'SocketStreamFixture.stop_and_get_resultysa  C+,   ||&&((rc4URRSS9$)Nrr)rrrs rrSocketStreamFixture.get_sinkszz"""--rc.[R"X5$r rurUs rr0SocketStreamFixture._get_writerrxr)rrrN) rGrHrIrJrrrrr0rKrrrrrjs $).8rrc[5$r )rrrrsocket_fixturerrrc@URSS9 UR5nUR5up#URUSR5(de[ U5[ U5:Xde[ U5HupEX4RU5(aMe g)NFrr)rrErr_r,r\r])rwriter_batches reader_schemareader_batchesrArCs rtest_socket_simple_roundtriprsE2#113N$2$F$F$H!M   q 1 8 8 9 99 9 ~ #n"5 55 5n- ''.....rcURSS9 UR5nUR5up#[RR U5nUR U5(deg)NTr)rrErr-r5r6r_)rrrBrrs rtest_socket_read_allrsZD1#113N224IAxx$$^4H == " "" "rcN[R"SS/05n[RR U5n[R "5n[ X5 UR5n[RRUSS5nUR5n[X5 g)Nr'?) rrr-rrr write_filer rSrrr)rrCrbufferrerdfs rtest_ipc_file_stream_has_eosrs usen %B NN & &r *E "Du ]]_FVV  qr +F    Crrc~[R"SS/05n[RR U5n[R "5n[ X5 UR5n[R"U5n[U5nUSR5n[R"U5n[X5 g)Nr'rr) rrr-rrrrr rY read_filerr)rrCrrrer@rZrs rtest_ipc_zero_copy_numpyrs usen %B NN & &r *E "Du ]]_F __V $FG 1:   !D ,,t Crripc_typerfilec [R"SS/05n[RR U5n[R "5nSn[R R[R RS.UnU"X2R5n[U5HnURUS[U50S9 M URU5 SSS5 UR5nUS:XaB[R RU5n [U R!55n SSS5 O\[R R#U5n [U R$5Vs/sHnU R'U5PM n nSSS5 [U5HnnW UR(R*S:Xde[-XR.[R05(deXR.S[U50:XaMne W UR(R*S:XdeXR.beg!,(df  GNq=f!,(df  N=fs snf!,(df  N=f) Nr'rr)rrbatch_id)custom_metadatarr)rrr-rrrrSrnrTr,r1r8rr rr!iter_batches_with_custom_metadatarZr[get_batch_with_custom_metadatarCnum_rowsr`rKeyValueMetadata) rrrCr batch_count file_factoryr?rArrebatch_with_metass r+test_batches_with_custom_metadata_roundtriprs# usen %B NN & &r *E "DK ff//FFOO--57L dLL )V{#A   uz3q66J  K$ 5! * ]]_F8 VV   '6#F$L$L$NO ( 'VV  f %).v/H/H)I K)IA!' E Ea H)I  K&; "((11Q666   / /1D1DFF FF"22z3q66JJJJ   K ( . . 7 71 << <  ( 8 8 @@ @1 * )( ' K& %s6?III+0I& I+ I I#&I++ I9c~[RR[R"/SQ5[R"/SQ5/SS/S9n[R"5n[R R XR5 SSS5 UR5n[R RU5nUR5nSSS5 WRRUR5(de[U5S:Xdeg!,(df  N=f!,(df  N]=f)NrBr@rDrErr) r-r5rrrrSrnr,r rrr_r\)rDrrrers rtest_ipc_stream_no_batchesrs HH "((<"8"$((+G"H"J(+Sz ! 3E  "D   4 .  /]]_F   F #v" $ ==   - -- - v;!   / . $ #s DD. D+. D<cSnSn[R"S[RR U505n[ R RU5n[ RRU5X-:deg)Nrrr') rrrr3rr-rrrSget_record_batch_size)NitemsizerrCs rtest_get_record_batch_sizers_ AH ubiiooa01 2B NN & &r *E 66 ' ' .!, ?? ?rc|[R"X(aSOSS9n[R"X!S9n[X05 g)Nrr)nthreadsr)r-serialize_pandasdeserialize_pandasr)rrrrs r"_check_serialize_pandas_round_tripr s0  b 1 CC  " "3 @Fv"rc[R"/SQSS9nSS/n[R"/SQ[S5S.XS 9n[ U5 g) Nrmy_indexnamer'r(rg?g333333?abcr'r(indexcolumnsrIndexrrrr r rs r test_pandas_serialize_round_triprsB HHYZ 0EenG U 4 B'r*rc[R"/SQSS9nSS/n[R"/SQ[S5S.XS 9n[ US S 9 g) Nrrrr'r(rrrr Trr rs r)test_pandas_serialize_round_trip_nthreadsrsD HHYZ 0EenG U 4 B'rtsD d367 8B  b !C  " "3 'Fv"rcF[R"S/SQ0/SQS9n[R"S/SQ05n[R"USS9n[R"U5n[ X15 [R"USS9n[R"U5n[ X05 g)NrDr)r FrT)rrr-rrr)rrrrs r'test_serialize_pandas_no_preserve_indexrFs~ sI&i 8B||S),-H  b 7C  " "3 'Fv(  b 6C  " "3 'Fv"rcSn[R"[RR U5S[R SSS/S.5n[ RRU5nURR5nUR5n[ RRU5n[ RRXE5nURU5(deg)Nr$r'r(r)r*r)rrrr3rrr-rrr,r|rSrrr_)r>rrCs_schemas_batch recons_schema recons_batchs r#test_schema_batch_serialize_methodsr$Ts E yyu%rvvuh68 9B NN & &r *E||%%'HooGFF&&x0M66++GCL   u % %% %rcSSS.nSSS.n[R"S[R"55n[R"S[R"5US9n[R"X#/US9nUR 5n[R RU5nURU5(deURU:XdeUSRbeUS RU:Xdeg) Nsbarsfield)rskindsschemarDrErsrr) r-rrUstringr,r|rSrr_rs)field_metadataschema_metadataf0f1r,r r"s r'test_schema_serialization_with_metadatar,ds$x8N% :O #rwwy !B #ryy{^ .make_schemasyy7BHHJ/011rcx>T"5n[R"/SQ/US9n[R"SS//US9nX/$)Nrr+rCr$)r-r2)r,batch1batch2r4s r make_batches1test_py_record_batch_reader..make_batchess;)V<1a&&9rr) rweakrefrefr-RecordBatchReaderr6riterrrrr0)r9r@rrer4s @rtest_py_record_batch_readerr?s2 |~&G W B   * *;=+2 47=tF||~---t||  48LN+,G W B   * *;=+2 47=tF||~---t||  4nG y !%%22rxxz " #W.  " y !%%224A  " !5 4 4 4 4 " ! " !s0-F< -G77G!G0< G  G G-0 G>c ~"SS5n[R"[R"/SQ[R"5S9/S/S9[R"[R"/SQ[R"5S9/S/S9/nU"U5n[RR U5n[R RU5nUR5U:Xde[R RU5nUR5U:Xde[R RX!SRS 9nUR5U:Xde[R"[R"S[R"55/5n[R RX%S 9nUR5URU5:Xde[R"[RR S S 9 [R RU[R"[R"S[R""[R"555/5S 9 SSS5 [R"[$5 [R RUSS5 SSS5 [R"[$5 [R RX1SS 9 SSS5 g!,(df  N=f!,(df  Nc=f!,(df  g=f) Nc$\rSrSrSrSSjrSrg)Atest_record_batch_reader_from_arrow_stream..StreamWrappericXlgr r@)rr@s rrJtest_record_batch_reader_from_arrow_stream..StreamWrapper.__init__s"LrNc[RRURSRUR5nUR U5$)Nr)r-r=r6r@r,__arrow_c_stream__)rrequested_schemares rrGTtest_record_batch_reader_from_arrow_stream..StreamWrapper.__arrow_c_stream__sA))66 Q&& 6F,,-=> >rrDr )rGrHrIrJrrGrKrrr StreamWrapperrBs  # ?rrJrrrDrrCr$rrr+Field 0 cannot be castrz)r-r2rr0r5r6r= from_streamrr,rrbcastrrlibArrowTypeErrorlist_r)rJrZwrapperrre good_schemas r*test_record_batch_reader_from_arrow_streamrTsK?? )"((*=>seL )"((*=>seL DD!Gxx$$T*H  ! ! - -h 7F ??  (( ( ! ! - -g 6F ??  (( ( ! ! - -g1gnn - MF ??  (( ())RXXc288:678K  ! ! - -g - JF ??  k : :: : rvv,,4L M (( BIIrxxRXXbhhj5I'J&KL )  N y ! ((a6 " y ! ((q'(B " ! N M " ! " !s%A0L &L"!L. L L+. L<c [R"[R"S[R"55/5n[R"[R "/SQ[R"5S9/S/S9[R"[R "/SQ[R"5S9/S/S9/n[R RU5n[RRX5nURU5R5U:Xde[R"[R"S[R"55/5n[RRX5nURU5R5URU5:Xde[RRX5n[R"[SS9 UR[R"/55 SSS5 [RRX5n[R"[RR SS9 UR[R"[R"S[R""[R"555/55 SSS5 [R"[R"S[R$"55/5n[R "[&R("S S S 5/[R$"5S9n[R"U/S/S9[R"U/S/S9/n[R RU5n[RRX5nURU5R5U:Xdeg!,(df  GN=f!,(df  GN1=f) NrDrrrrKzTarget schema's field namesrzrLir )r-r,rr0r2rr5r6r=rNrrbrrr,rOrPrQdate32datetimedate) schema_srcrZ table_srcre schema_dstarrs rtest_record_batch_reader_castr^sBHHS"((*567J )"((*=>seL )"((*=>seL D%%d+I ! ! . .z @F ;;z " + + - :: :BHHS"((*567J  ! ! . .z @F ;;z " + + - 1K KK K ! ! . .z @F z)F G BIIbM" H ! ! . .z @F rvv,,4L M BIIrxxRXXbhhj-ABCDE N BHHS"))+678J ((HMM$2./biik BC OOSE# /#se1T UD%%d+I  ! ! . .z @F ;;z " + + - :: : H G N Ms+&O %A#O2 O/2 PcR[R"[R"S[R"55/5n[R"[R "/SQ[R"5S9/S/S9/n[R"[R "/SQ[R"5S9/S/S9/n[R RU5n[R RU5n[RRX5n[R"[R"S[R"55/5nURU5R5URU5:Xde[RRX5n[R"[R"S[R"5SS9/5nURU5R5URU5:Xde[RRX5nURU5n[R"[RRSS 9 UR5 SSS5 g!,(df  g=f) NrD)rrNrrrF)nullablezCan't cast arrayrz)r-r,rr0r2rr5r6r=rbrNrrrrOr)rZdata_with_nullsdata_without_nullstable_with_nullstable_without_nullsrer\ casted_readers r#test_record_batch_reader_cast_nullsrfsBHHS"((*567J ,RXXZ@A#OO )"((*=>seLxx,,_=((//0BC ! ! . .z KFBHHS"((*567J ;;z " + + -1A1F1Fz1R RR R ! ! . .z NFBHHS"((*uEFGJ ;;z " + + -1D1I1I*1U UU U ! ! . .z KFKK +M rvv**2D E  F E Es >J J&c[R"S/SQ05nSSS.n[R"5n[RR X R US9nUR U5 SSS5 UR5n[RRU5nURU:XdeSSS5 g!,(df  NZ=f!,(df  g=f)NrDrstests0.1.0)screatorsversionr& r-rDrrSrTr,r7r rZrs)tblmetarwrrs r+test_record_batch_file_writer_with_metadatarm0s ((C# $CX 6D "D zzD 9Q c :]]_F   & !QzzT!!! " ! : 9 " !sC&C C C"c[R"S/SQ05n[R"5n[RR XR 5nUR U5 SSS5 UR5n[RRU5nURbeSSS5 g!,(df  NW=f!,(df  g=f)NrDrrh)rirrkrrls r1test_record_batch_file_writer_with_empty_metadataro>s ((C# $C "D zz *a c +]]_F   & !Qzz!!! " ! + * " !sB<"C < C  CcU"S0UD6nUR5nUR5HupEUcM [U[5(dUOSUS3nUS:Xa*[R R U5RnO/US:Xa)[R RU5RnUSU3U;aMe g)N"r7r'=r) __repr__itemsr`rr-rSr:rr*) options_obj options_argsrRroargvalr/s rcheck_ipc_options_reprryKs)L)G    D &&( ; %c3//r#b\ $ $FF$$S)..E & &FF**3/44Eaw4''')rcURS:Xa,SS[RRRSSSSS.$URS:Xa,SS[RRR SSSSS.$0$)NdefaultFT)r(r)r'rrrRrSallr)rr-rSr*r$r+rs rwrite_options_argsr}]s}} ! !& " 6 6 9 9&+"'   % !% " 6 6 9 9! &*"&   rr}r{r|)indirectcL[[RRU5 gr )ryr-rSr)r}s rtest_write_options_reprrws 266113EFrcURS:Xa)S[RRRSSS.$URS:Xa+S[RRR S/SQS.$0$)Nr{T)r6r7rr8r|Fr)rr-rSr:r;r<rs rread_options_argsrso}} !$( " 0 0 4 4#   % $) " 0 0 A A (    rrcL[[RRU5 gr )ryr-rSr9)rs rtest_read_options_reprrs266002CDrrh)q collectionsrrXr rrr3r threadingr;numpyr ImportErrorpyarrowr-pyarrow.tests.utilrrpandas.testingrpandasrrrMrkrrrrzr|r~rrrrrmark parametrizerrrrr processesrrrrSr9rrrrrr rrr"r0rr*r+r4r>rKr]rergrirmrqrxrrrrrrrThreadrrrsocketsrrrrrrrrrrrrrrr$r,rrr1r?rTr^rfrmroryr}rrrrrrrs*$!  = 1 $$N> >6  *  8Z8 !! LL  LL   2 2/ 21#* #  # .))  00$ . . ;2FFFFe,% :  :1FFFFe,% &  &/??(55.!$<.,bFFFFt,FFT2FFBFF,B,B,E,EFFFT,.FF,B,B,E,EG %!!.*D2H-V!IH#))!!! = $0 ( & &, ( 4"$))$B8*8<!!//##  "    h%78"A9"AJ$@@## ++== + +++ ## # # & &7$" O ' * Z.Cb";J!: " "($29e,t=G=G &)U+d<E<Eo+ B  s"Y Y"YY"Y,+Y,