<>i SSKrSSKJr SSKJrJrJrJrJr SSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKrSSjr\S5rSrS r\R@RCS S 5\R@RCS S 5S55r"Sr#Sr$Sr%Sr&Sr'Sr(Sr)Sr*Sr+Sr,Sr-Sr.Sr/Sr0Sr1Sr2Sr3S r4S!r5S"r6\R@RCS#/S$Q5S%5r7\R@R(S&5r8\R@R(S'5r9\R@R(S(5r:\R@R(S)5r;S*rS-r?\R@R(S.5r@\R@R(S/5rAS0rBS1rC\R@R(S25rDS3rES4rF\R@R(\R@RCS5\R"S6\R@R\RRS79S89S9S:S;S55rK\R@R(\R@RCS5\R"S6\R@R\RRS79S89S9S:S;S[5n[R"U5nUR5S:XdeSnSnUR U5 UR5[ U5:XdeUR U5 X#-nUR 5nXT:XdeUR(aeUR5 UR(de[R"[SS9 [R"[55 SSS5 g!,(df  g=f)Nrs engañadosfoobarbinary file expectedmatch) rpa PythonFilerrlengetvalueclosedcloserr* TypeErrorr)bufr%s1s2expectedresults r&test_python_file_writer?Ls )C cA 668q== B BGGBK 668s2w  GGBKwH \\^F   xx<GGI 88O8 y(> ? hj! @ ? ?s &D DcFSn[U5n[R"USS9nUR5[ U5:XdeUR 5S:XdeUR S5S:XdeUR 5S:XdeURS5 UR 5S:XdeURS5 UR 5S:XdeUR S5nUS :Xde[ U5S :XdeUR5[ U5:XdeUR(aeUR5 UR(de[R"[S S 9 [R"[5SS9 SSS5 g!,(df  g=f) Nsome sample datarmodersomer2 sample data r0r1)rr3r4rr5rrrr7r8rr*r9r)datar:r%vs r&test_python_file_readrLhs; D $-C c$A 668s4y  668q== 66!9   668q==FF1I 668q==FF1I 668q== r A    q6R<< 668s4y  xx<GGI 88O8 y(> ? hjs+ @ ? ?s +F F nbytes)rrd file_offset)rNrrrPcSn[R"[U5SS9nUS:dUS:aL[R"[R SS9 UR XS9 SSS5 UR5 gUR XS9n[U[U55n[X-[U55n[X%U5nURSS 9URS5:XdeURS S 9URS 5:XdeUR5UR5:Xde[U5S -nURU5URU5:Xde[R"[S S9 URS5 SSS5 UR5 UR(deg!,(df  GN_=f!,(df  ND=f) Nsdata1data2data3data4data5rBrCrzshould be a positive valuer1)rQrMrE)rMseekable)r3r4rrr* ArrowInvalid get_streamr8minr5rOSErrorrr7) rMrQrJr%streamstartendr:ns r&test_python_file_get_streamr^s} (D gdm#.Az[1_ ]]2??!=? LL[L @?  +E  SY 'E k"CI .C $S/ "C ;;a; CHHQK // / ;;a; CHHQK // / ;;=CHHJ && & D A A ;;q>SXXa[ (( ( wj 1 A 2 LLN ===???6 2 1sF8:G 8 G GcSn[U5n[R"USS9nURSSS9nUS:Xde[ U5S:XdeURSS S9nX@:Xde[ U5S :Xdeg) NrArBrCr)rMoffsetse samrGr)rr3r4read_atr5)rJr:r%rKws r&test_python_file_read_atres~ D $-C c$A 1 %A == q6Q;; A &A 99 q6R<\rSrSrSr\S5rUU4SjrSrg)0test_python_file_read_buffer..DuckReadercgr)r,selfs r&r86test_python_file_read_buffer..DuckReader.close r-cgNFr,rvs r&r77test_python_file_read_buffer..DuckReader.closedr-c0>UT:Xde[T5SU$r)) memoryview)rwrMrnrms r& read_buffer.DuckReader.read_buffers#V# ##g&w/ /r-r,N) __name__ __module__ __qualname____firstlineno__r8propertyr7r__static_attributes__)rnrmsr& DuckReaderrss&      0 0r-rrBrCxr)rkr3r4rr5rtobytesord)rJr duck_readerr%r:rnrms @@r&test_python_file_read_bufferrs F DoG 0 0,K { -mmF#3x6!!!#&&(GGV,<<<< Y 3qzSY&&& . - -s A0B66 Cc[R"[S5SS9n[U[5(de[U[ 5(deSSS5 g!,(df  g=f)Nr-rBrC)r3r4r isinstancerrr%s r&test_python_file_correct_abcrsH ws|# .!!^,,,,!V$$$$ / . .s /A A&cSn[U5n[U5n[R"USS9n[X25H upEXE:XaM e SSS5 g!,(df  g=f)Nsline1 line2 line3 rBrC)rr3r4zip)rJr:buf2r%rr=s r&test_python_file_iterablersU D $-C 4=D s %!!lND# ##+ & % %sAA A!c Sn[U5 g)NcB[R"[US55$Nrb)r3r4r)r$s r&factory-test_python_file_large_seeks..factory s}}T(D122r-)r')rs r&test_python_file_large_seeksr s3gr-cSn[R"U5nUR5S:XdeUR5[ U5:XdeUR S5S:XdeUR5S:XdeUR S5 UR5S:XdeUR SS5 UR5[ U5:XdeUR S5 UR5S:XdeUR S5S:XdeUR(aeUR5 UR(deg) NrArrErFrTrrGrH) r3 BufferReaderrrr5rrr7r8)rJr%s r&test_bytes_readerrs D A 668q== 668s4y  66!9   668q==FF1I 668q==FF1aL 668s4y  FF1I 668q== 66": '' 'xx<GGI 88O8r-c[R"[5 [R"S5 SSS5 g!,(df  g=f)Nzsome sample data)rr*r9r3rr,r-r&test_bytes_reader_non_bytesr-s' y ! *+ " ! !s ; A cSSKnSnU"5nUR"5 UR5S:XdeURceg)Nrc|SS-n[R"U5nURS5 URS5$)NrArrS)r3rrr)rJreaders r& get_buffer>test_bytes_reader_retains_parent_reference..get_buffer6s6"T)& A!!!$$r-ssample)gccollect to_pybytesparent)rrr:s r&*test_bytes_reader_retains_parent_referencer2sA % ,CJJL >> y (( ( :: !! !r-c[RR[U5S5n[ US5n[ R "U5nUR5(deUR5(aeUR5(aeURS5 SSS5 [ US5n[ R "U5nUR5(deUR5(aeUR5(deUR5S:XdeSSS5 [5n[ R "U5nUR5(deUR5(aeUR5(aeURS5 UR5S:Xdeg!,(df  GN#=f!,(df  N=f)Nfoo.txtrsfoobar r)r pathjoinstrrr3r4writablereadablerUrrrr6)tmpdirrr%pfbios r&test_python_file_implicit_moderBsX 77<<F Y /D dD Q ]]1 {{}}};;==  ;;==      dD Q ]]1 {{}}};;==  {{}}}wwyK'''  )C s B ;;==={{}} {{}} HH[ <<>[ (( ()    sA-F?7A2G? G GcSS/n[RR[U5S5n[ US5n[ R "USS9nUR5(deURU5 UR5 SSS5 [ US5n[ R "USS9nUR5(deUR5S RU5:XdeUR5 SSS5 g!UR5 f=f!,(df  N=f!UR5 f=f!,(df  g=f) Nsline1 s line2 line3rrrdrCrrBr-) r rrrrr3r4r writelinesr8rr)rlinesrr%s r&test_python_file_writelinesr[s , -E 77<<F Y /D dD Q  ac*A::<< < LL  GGI  dD Q  ac*A::<< <668sxx. .. GGI   GGI   GGI  sGD!=D 9D!E AD22E DD!! D/2EE Ec[5n[R"U5n[R"U5nAU"5beUR (ae[R"U5nUR 5 UR (degr))rr3r4weakrefrefr7r8)rrwrs r&test_python_file_closingrosb )C s B RB 4<<zz> s BHHJ :::r-ch[SURS-5HnURURXS95n[ U5[ U5:Xde[ U5[ U5:XdeUR 5UR 5:XdeURUR:XaMe g)NrrOprotocol)rangeHIGHEST_PROTOCOLloadsdumpsr5rr is_mutable)r:picklerrr>s r&check_buffer_picklingrs!W559:w}}S}DE6{c#h&&&&!Z_444  "cnn&6666  CNN222 ;r-cSn[R"U5n[U[R5(deUR(aeUR (deUR 5nX1:Xde[X 5 gN some data)r3 py_bufferrBufferris_cpurr pickle_modulevalr:r>s r&test_buffer_bytesrsc C ,,s C c299 % %% %~~  ::: ^^ F ==#-r-c"[R"SSS9nUR5S:XdeURS:Xde[ U5nUR 5S:Xde[R "U5RS:wde[X5 g)Nr)addressrr-)r3foreign_bufferrrrrrr)r null_buffms r&test_buffer_null_datars!!!!4I    !S (( (    !! ! 9A 99;#   <<? " "a '' ')3r-cSn[R"U5n[U[R5(deUR(aeUR (de[ U5nX1:Xde[X 5 gr)r3rrrrrrrrs r&test_buffer_memoryviewrs` C ,,s C c299 % %% %~~  ::: _F ==#-r-c[S5n[R"U5n[U[R5(deUR (deUR (de[U5nX1:Xde[X 5 gr)rkr3rrrrrrrs r&test_buffer_bytearrayrsd L !C ,,s C c299 % %% % >>> ::: s^F ==#-r-c[R"[SS9 [R"S5 SSS5 g!,(df  g=f)Nz$(bytes-like object|buffer interface)r1)rr*r9r3rr,r-r&test_buffer_invalidrs3 yC E T E E Es : Ac[R"S5n[R"U5nU"5ceAU"5begr)r3rrr)r:rs r&test_buffer_weakrefrs; ,,| $C S B 4   4<>> >> s{{} ,, , ,,suu C ::: >>> >> s{{} ,, , z)9 :ll3551:& ; : :s 'E EcTSn[U5n[U5n[R"U5n[R"U5n[R"U5n[R"U5nURS:deURUR:XdeURUR:wdeURUR:wde[R "S5n[R"U5nURUR R:Xdeg)N some data!rr)rkr3rrrrctypesrJ) b1b2b3buf1rbuf3buf4rr:s r&test_buffer_addressrs B 2B 2B << D << D << D << D <.eqs)xx{{{v vF|Fr-cPURU5(aeX:XaeX:wdegr)rr s r&netest_buffer_equals..nes'88A;;F|v vr-rrrr)rkr3rrrint16) r rrrrrrrrbuf5s r&test_buffer_equalsr s  B 2B 2B BqE << D << D << D << D << b9 :DtNtNtNtNtNr-c[R"S5nUS:XdeU[S5:XdeUS:wde[R"[ 5 US:H SSS5 g!,(df  g=f)Nrs some dat1z some data)r3rrkrr*r9r:s r&test_buffer_eq_bytesr)s_ ,,| $C ,   )L) )) ) ,   y ! { " ! !s A!! A/c[S5n[R"U5n[U5n[ U*US- 5HnXX:XaMe [ R "[5 X SSS5 [ R "[5 X*S-  SSS5 g!,(df  N:=f!,(df  g=f)NrrO)rkr3rr5rrr* IndexError)rJr:r]ixs r&test_buffer_getitemr3s ] #D ,,t C D AQBAw$(""" z "  # z " BF  # " # " # "s*B# B4# B14 CcSn[R"U5nURS5n[R"S5nURU5(deURSS5n[R"S5nURU5(deURS5RU5(de[ UR[ U555S:Xde[ R "[5 URS5 SSS5 [ R "[5 UR[ U5S-5 SSS5 US SR5S :Xde[ R "[5 URS[ U55 SSS5 USS R5UR5SS:Xde[ R "[5 URSS5 SSS5 USSRURS55(deUSS RURSS 55(deUS SRUR[ U5S - 55(deUS SRUR[ U5S - S 55(de[ R "[5 USSS2 SSS5 [ R "[5 USSS2 SSS5 [ U5n[U*S-US-5HEn[U*S-US-5H+nXUR5UR5Xx:XaM+e MG g!,(df  GN=f!,(df  GNW=f!,(df  GN=f!,(df  GN=f!,(df  N=f!,(df  N=f)NrrTsme data!rEsme drrNrOrIr-rr`) r3rslicer r5rr*rrr) rJr:slicedr=sliced2 expected2r]r[stops r&test_buffer_slicingr$Bs D ,,t C YYq\F||K(H == " "" "ii1oG W%I >>) $ $$ $ 99Q<  s # ## # syyS" #q (( ( z " "  # z " #c(Q, # rs8   C '' ' z " !SX # q9   !S^^%5ab%9 99 9 z " !R # qr7>>#))A, ' '' ' q8??399Q? + ++ + rs8??399SX\2 3 33 3 r":  SYYs3x!|Q7 8 88 8 z " DbD  # z " CaC # CArAvq1u%1"q&!a%(DT?--/3>>3CE3OO OO)&9 # " # " # " # " # " " "sHN6N$N67O. O O+ N!$ N36 O O O(+ O9c[R"[SS9 [[R "S55 SSS5 g!,(df  g=f)N unhashabler1s123)rr*r9hashr3rr,r-r&test_buffer_hashingr(us- y 5 R\\& !" 6 5 5s A AcSn[R"U5n[R"U[RS9nUR R (aeg)Ns12345r)r3rrrrflags writeable)r  arrow_ref numpy_refs r&*test_buffer_protocol_respects_immutabilityr.{s@ A QI irxx8I((( ((r-c[R"SS/[RS9nURSSnURn[ R "XU5n[R"U5nA[R"U[RS9R5SS/:XdeU"5ceAU"5beg)NrOrTrrJr) rrint32__array_interface__rMr3rrrrtolist)objaddrrr:rs r&test_foreign_bufferr5s ((Aq6 *C  " "6 *1 -D ::D  D ,C S B ==BHH - 4 4 61a& @@ @ 4   4<>> ::   C  % %c *F LL >> BQ 3 && &r-c[R"SSS9n[U[R5(deUR S5 UR S:Xdeg)NrPT) resizable)r3r7rResizableBufferresizerrs r&test_allocate_buffer_resizablerAsH  SD 1C c2-- . .. .JJsO 88s??r-c [R"S5nURS5n[R"S/5nUR U5n[ RR[ R"S5SSU/5nUR5SnURUR:XdeURUR:XdeURUR:XdeUR(deSnSnU[U5;deU[U5;deUR!S5n UR"R%U 5n U R'5S :XdeUSS n UR"R%U 5n U R'5S :XdeU R)USS 5(deS n [R*"[,U S 9 UR)[ R."U55 SSS5 Sn [R"S /5n UR U 5n[R*"[0U S 9 U R)U5 SSS5 [ RR[ R"S5SSU/5n U R5Sn[R*"[0U S 9 U R)U5 SSS5 [R*"[0U S 9 UR35 SSS5 [R*"[0U S 9 UR35 SSS5 [R*"[0U S 9 US SSS5 [R*"[0U S 9 UR'5 SSS5 [R*"[0U S 9 UR5US S9 SSS5 [R*"[0U S 9 UR5US S9 SSS5 [R*"[0U S 9 [7U5 SSS5 g!,(df  GN8=f!,(df  GN=f!,(df  GN=f!,(df  GNb=f!,(df  GNB=f!,(df  GN-=f!,(df  GN =f!,(df  N=f!,(df  N=f!,(df  g=f)Nz pyarrow.cudarstestingrOzrTsstingrEsstz8Device on which the data resides differs between buffersr1z'Implemented only for data on CPU devicerr)r importorskipContextrrbuffer_from_datar3FixedSizeBinaryArray from_buffersbinarybuffersrrrrreprr CudaBuffer from_bufferrr r*rrNotImplementedErrorrrr)rcudactxrJcuda_bufr buf_on_gpurepr1repr2buf_on_gpu_sliced cuda_sliced msg_devicemsg arr_shortcuda_buf_shortbuf_on_gpu_shorts r&test_non_cpu_bufferr\s   ~ .D ,,q/C 88ZL !D##D)H ! ! . .ryy|Qx@P QCq!J ??hmm ++ +   !1!1 11 1    // /   &E 2E D$ $$ $ D$ $$ $"((+//--.?@K  ! ! #x // /"1Q//--.?@K  ! ! #u ,, ,  # #HQqM 2 22 2LJ z 4",,t,- 5 4C($I)))4N *# 6  0 7''44 ! a$/I!((*1- *# 6  !12 7 *# 6 7 *# 6  7 *# 61  7 *# 6 7 *# 6J3 7 *# 6Hq1 7 *# 6: 7 6E 5 4 7 6 7 6 7 6 7 6 7 6 7 6 7 6 7 6 7 6sx&P,P>Q6Q"(Q4RR3R*%R; S , P;> Q  Q" Q14 R R R'* R8; S  ScT[R"5n[R"SS9n[R"SSS9n[R"SSSS9n[R"SSSS 9n[RRS S S S S9nURS:XdeURS:XdeUR SLdeUR S:XdeURS:XdeURS:XdeUR SLdeUR S:XdeURS:XdeURS:XdeUR SLdeUR S:XdeURS:XdeURS:XdeUR SLdeUR S:XdeURS:XdeURS:XdeUR SLdeUR S:XdeUR SLdeX:XdeX:wdeX:wdeX#:wdeX4:wdeXP:wdeg)N)hole_size_limit )r_range_size_limitr)r_rbprefetch_limitF)r_rblazyrPr>g?@)time_to_first_byte_millistransfer_bandwidth_mib_per_sec ideal_bandwidth_utilization_fracmax_ideal_request_size_mibiTr)r3 CacheOptionsfrom_network_metricsr_rbrdrc)opts1opts2opts3opts4opts5opts6s r&test_cache_optionsrrsT OO E OOD 1E OOD4 HE OOD-1! EE OOD-1 ?E OO 0 03PSRULN 1 PE  D (( (  ! !%5 55 5 ::     1 $$ $  D (( (  ! !%5 55 5 ::     1 $$ $  D (( (  ! !T )) ) ::     1 $$ $  D (( (  ! !T )) ) ::     1 $$ $  D (( (  ! !T )) ) ::     1 $$ $ ::   >> >> >> >> >> >>r-c[R"5[R"SSSSS9/nUH)nURURU55U:XaM)e g)Nr`raTr)r_rbrdrc)r3rjrr)roptionsoptions r&test_cache_options_picklingrv!sX  t!! 5G ""=#6#6v#>?6IIIr- compressionbz2)r*)marksbrotligziplz4zstdsnappyc[R"U5(d[R"US35 Sn[R R SSUS9R[R5R5n[R"U5n[R"X0S9n[R"X SS9n[U[5(de[R"XAUS9n[R"XQUSS9n[U[5(deUR!U5(deXr:Xde[R""[$5 [R"XPS9 SSS5 g!,(df  g=f) N support is not built'rr)codecT)rasbytes)r is_availablerrrrandomrandintastyperrr3rcompressrbytes decompressr r*r)rw INPUT_SIZE test_datatest_bufcompressed_bufcompressed_bytesdecompressed_bufdecompressed_bytess r&test_compress_decompressr,s3   k * * {m#89:J""1c ";&"')||I&H[[=N{{9+/1 & . .. .}}^+68'7-8$H (% 0 00 0  " "8 , ,, ,  ** * z " &: # " "s E00 E>c[R"U5(d[R"US35 [U5nURS:XaUR beO![ UR [5(deS/nX;a[R"U5(ae[R"[5 [US5 SSS5 [R"[5 [R"U5 SSS5 [R"[5 [R"U5 SSS5 [R"[5 [R"U5 SSS5 gSn[RR!SSUS9R#[R$5R'5n[(R*"U5n[R"U5n[R"U5n[R"U5nXg:deX:deX::de[-XgS-5Hn [X 5nUR/U5n UR/USS 9n [ U [05(deUR3X5n UR3XSS 9n [ U [05(deU R5U5(deX:Xde[R"[5 UR3U 5 SSS5 M [7[RS 5(d[R"S 5 [RR9S S 9nUR;SSS5n[(R<"U5nUR?5Sn[X5nUR/U5n[X5nUR/U5n[AU5[AU5:deg!,(df  GN8=f!,(df  GN=f!,(df  GN=f!,(df  g=f!,(df  GM =f)Nrr~rrrrrOT)r default_rngzRequires newer version of numpyr)seedrPr)!r rrrnamecompression_levelrintsupports_compression_levelr*rminimum_compression_levelmaximum_compression_leveldefault_compression_levelrrrrrrr3rrrrrr hasattrrintegersrrJr5)rwrno_levelrrr min_level max_level default_levelrrrrrrngvaluesrhard_to_compress_buffer weak_codecweakly_compressed_buf strong_codecstrongly_compressed_bufs r&test_compression_levelrUsh   k * * {m#89: + E zzX&&...%1137777zH33K@@@@ ]]: & +q !' ]]: &  + +K 8' ]]: &  + +K 8' ]]: &  + +K 8'J""1c ";&"')||I&H// >)T>B*E2222 ++NG"--.>6:.<,e4444&&x0000!... ]]: &   - .' &;2 299m , , 56 ))  R  (C \\!S$ 'F ((6 C!kkmA.{.J&//0GH0L*334KL $ %,C(D DD D}' & & & & & & &<' &s< O>/P(P"!P4?Q> P  P" P14 Q Q cBSn[R"U5nUR(ae[U[R5(de[ U5nUR (de[R"[5nSUS'S[UR5;deSSS5 [U5n[R"[5nSUS'S[UR5;deSSS5 g!,(df  N^=f!,(df  g=f)Nrhrzcannot modify read-only) r3rrrrrreadonlyrr*r9rvaluer)rr:r>excr s r&#test_buffer_memoryview_is_immutablers C ,,s C~~  c299 % %% % _F ??? y !Sq (C N::: " c A y !S!(C N::: " ! " ! " !s!C?!D? D  Dc[R"[5 [R"5 SSS5 g!,(df  g=fr))rr*r9r3rr,r-r&test_uninitialized_bufferrs% y !  " ! !s : AcSn[R"5nSn[U5HnURU5 M UR 5n[ U5[ U5U-:XdeUR 5X-:Xdeg)N dataabcdefr)r3BufferOutputStreamrrr6r5r)rr%Kir:s r&test_memory_output_streamrsq C A A 1X   **,C s8s3x!| ## # >> sw && &r-cF[R"5nURS5 UR(aeUR 5 UR(de[ R "[5 URS5 SSS5 g!,(df  g=f)Noksnot ok)r3rrr7r6rr*rrs r& test_inmemory_write_after_closedrs_ AGGENxx<JJL 88O8 z "   # " "s 7B B cSnU"S5n[R"5 US:XdeSn[R"U5n[ S5H nU"U5 M [R"5 U[R"U5:Xdeg)Nc@[[R"U55$r))rkr3r) bytes_objs r& make_buffer6test_buffer_protocol_ref_counting..make_buffersi011r-foorj)rrr getrefcountr)rr:rrefcount_beforers r&!test_buffer_protocol_ref_countingrss2 f CJJL &== Cooc*O 2YCJJL cooc2 22 2r-c[R"5nSn[R"USS9nUR U5 UR [ U55 UR [R "U55 [R"[5 UR URS55 SSS5 UR5nUR5US-:Xdeg!,(df  N8=f)NrS1rutf8r`) r3rrrrrkrrr*r9decoder6r)r%rJrr:s r& test_nativefile_write_memoryviewrs A D --D )CGGCLGGIdOGGBLL  y !  F#$ " **,C >> tax '' ' " !s !C** C8cDSn[R"5n[R"5nSn[U5H%nUR U5 UR U5 M' UR 5[ UR55:Xde[RR[R"/SQ5/S/5n[R"5n[R"5n[R"XR5n[R"X%R5nURU5 URU5 UR5 UR5 UR 5[ UR55:Xdeg)Nrr)rOrTr`r )r3MockOutputStreamrrrrr5r6 RecordBatch from_arraysrRecordBatchStreamWriterschema write_batchr8)rf1f2rr record_batchstream_writer1stream_writer2s r&test_mock_output_streamr s0 C   B   B A 1X     779BKKM* ** *>>--rxx /B.CcUKL   B   B//4G4GHN//4G4GHN|,|, 779BKKM* ** *r-c^Sn[U5Vs/sHn[R"SS5PM nn[USU5n[R R [U5[55m[TS5nURU5 SSS5 U4SjnURU5 TU4$s snf!,(df  N.=f)Nr`rrrc>[T5 gr)) _try_deletersr&teardown"sample_disk_data..teardown;s Dr-) rrrrr rrrr rr addfinalizer) requestrSIZE_rrJr%rrs @r&sample_disk_datar0s D+0; 7;a6>>!S !;C 7 Ud D 77<<F TV ,D dD Q    " : 8  s!B4?B99 CcZUup4U"USS9nURS5USS:XdeURS5S:XdeUR5S:XdeUR5USS:XdeUR5[U5:XdeUR S5 UR5S:XdeU(aVUR [U5S-5 UR5[U5S-:XdeURS5S:XdeUR S5S:XdeUR S[ R 5S :XdeUR5S :Xde[U5S - nUR S [ R5U:XdeUR5U:Xdeg) NrBrCrjrr-rOrr`rSrTr)rrrr5rr SEEK_CURSEEK_END)FACTORY sample_dataallow_read_out_of_boundsrrJr% ex_lengths r&_check_native_file_readerrBsvJD3A 66":cr "" " 66!9   668r>> 668tBCy  668s4y  FF1I 668q==  s4y1}vvx3t9q=(((vvayC 66!9>> 66!R[[ !Q && & 668q==D A I 66"bkk "i // / 668y  r-c6[[RUSS9 g)NF)r)rr3 memory_maprs r&test_memory_map_readerrcsbmm-=7<>r-cUup/n[R"US5nURURS5USS45 URURS5USS45 URURS5USS45 SSS5 [R "5 UHupVUR 5U:XaMe g!,(df  NE=f)NrrPr>i,)r3rappendrrrr)rrrJcasesr%r:r=s r&'test_memory_map_retain_buffer_referencerhs!JD E tT "a ammC($t*56 ammC($s3-89 ammC($s3-89 # JJL ~~8+++ # "s A0C  Cc8[[RU5 gr))rr3OSFilers r&test_os_file_readerrxsbii)9:r-c6[[R5 gr))r'r3rr,r-r&test_os_file_large_seeksr|sbii r-cf[R"U5 g![Ra gf=fr))r removeerrorrs r&rrs(  $ 88   s 00c2[RS:Xa[R"S5 Sn[ U5Vs/sHn[ R "SS5PM nn[USU5n[RR[U5[55n[US5nURU5 SSS5 [R "USS9nUR#S 5 URS 5 UR%5S :XdeUR#S 5 UR'S 5S :Xde[R "USS9nUR#S 5 URS 5 UR#S 5 UR#S 5 UR'S 5S :Xde[R "USS9nURS5 [R "U5n U R)5U:XdeSSS5 [R*"[,5 UR'S5 SSS5 UR#S5 UR'S5S:Xdegs snf!,(df  GN=f!,(df  N=f!,(df  N_=f)Nrz:Multiple memory maps to same file don't work on emscriptenr`rrrr+brCrjspeekaboosbooapeakrdrrr`)rrrxfailrrrrr rrrr rrr3rrrrrr*IOError) rrrrrJrr%rf3f4s r&test_memory_map_writerrs |||# QR D+0; 7;a6>>!S !;C 7 Ud D 77<<F TV ,D dD Q    d'AFF2JGGK 668r>>FF2J 66!9 ## # t% (BGGBKHH[GGBKFF2J 66!9 ## # t# &BHHV t wwyD     w    FF1I 66!9  I 8  2   s)!I (I%#I7J% I47 J Jc`Sn[U5Vs/sHn[R"SS5PM nn[USUS-5n[X1S-S5n[R R [U5[55n[R"XaS- 5nURU5 URU5 URU5 UR5 [US5nUR5[USU5:XdeSSS5 gs snf!,(df  g=f)Nr`rrrTr)rrrrr rrrr r3create_memory_maprr@r8rr) rrrrdata1data2rmmapr%s r&test_memory_map_resizer s D+0; 7;a6>>!S !;C 7 #l # $E #qyl# $E 77<<F TV ,D  Qh /DJJuKKJJuJJL dD Qvvx5Ud,,,,   8  s!D-#D D-c*[RR[U5[ 55n[ US5nUR 5 [R"USS9nUR5S:XdeSSS5 g!,(df  g=f)NrrrCr) r rrrr rr8r3rr)rrr%rs r&test_memory_zero_lengthr sb 77<<F TV ,D T4AGGI t% (J A%%% ) ( (s #B Bc[RS:aSnO#[R"[R SS9n[ [RUS9 g)NlzARequested memory map length 4294967306 does not fit in a C size_tr1r#)rmaxsizerr*r3ArrowCapacityErrorr'rrs r&test_memory_map_large_seeksrs? {{e  ! !/0bmmNCr-c[RR[U5[ 55n[ R "US5nUR5 UR(de[R"U5 gNr`) r rrrr r3rr8r7r)rrr s r&test_memory_map_close_removersN 77<<F TV ,D  d +DJJL ;;;IIdOr-c[RR[U5[ 55n[ R "US5 [R"U5 gr)r rrrr r3rr)rrs r&test_memory_map_deref_removers7 77<<F TV ,Dt$IIdOr-cSn[U5Vs/sHn[R"SS5PM nn[USU5n[R R [U5[55n[US5nURU5 SSS5 [R"USS9nURS5 [R"U5nUR5S:XdeSSS5 [R"[ 5 UR#S 5 SSS5 UR%5 [R"US S9n U RS 5 SSS5 [R"U5n U R5S :XdeSSS5 gs snf!,(df  GN=f!,(df  N=f!,(df  N=f!,(df  N~=f!,(df  g=f) Nr`rrrrdrCrr`rabsbarrS)rrrrr rrrr rrr3rrrr*rrr8) rrrrrJrr%rrrf5s r&test_os_file_writerrsP D+0; 7;a6>>!S !;C 7 Ud D 77<<F TV ,D dD Q    4c "BHHV 4BwwyA~~  w    HHJ 4d #r  $ 4BwwyA~~ + 8     $ # sA!F>F#F5G G=G(# F25 G G G%( G6c[R"5n[R"[5 UR S5 SSS5 g!,(df  g=f)Nfoo)r3rrr*r9r)nfs r&%test_native_file_write_reject_unicoders3   B y !  " ! !s A  Ac [RR[U5[ 55n[ US5nUR S5 SSS5 [R"USS9nURS:XdeUR5(deUR5(aeUR5(deSSS5 [R"USS9nURS:XdeUR5(deUR5(aeUR5(deSSS5 [R"USS9nURS:XdeUR5(aeUR5(deUR5(aeSSS5 [R"USS9nURS:XdeUR5(aeUR5(deUR5(aeSSS5 [R"USS9nURS:XdeUR5(aeUR5(deUR5(aeSSS5 [R"USS9nURS:XdeUR5(aeUR5(deUR5(aeSSS5 [ US5nUR S5 SSS5 [R"US5nURS:XdeUR5(deUR5(aeUR5(deSSS5 [R"US 5nURS :XdeUR5(deUR5(deUR5(deSSS5 [R"US 5nURS :XdeUR5(deUR5(deUR5(deSSS5 g!,(df  GNb=f!,(df  GN=f!,(df  GN=f!,(df  GN6=f!,(df  GN=f!,(df  GNn=f!,(df  GN =f!,(df  GN=f!,(df  GN=f!,(df  GN*=f!,(df  g=f) NrfoooorBrCrrdrr zr+zrb+r)r rrrr rrr3rrDrrrUr)rrr%s r&test_native_file_modesr! s 77<<F TV ,D dD Q   4c "avv~~zz|||::<<zz||| # 4d #qvv~~zz|||::<<zz||| $ 4c "avv~~::<<zz|||::<<< # 4d #qvv~~::<<zz|||::<<< $ 4d #qvv~~::<<zz|||::<<< $ 4c "avv~~::<<zz|||::<<< # dD Q   tS !Qvv~~zz|||::<<zz||| " tT "avvzz|||zz|||zz||| # tU #qvvzz|||zz|||zz||| $ #m   # " $ # # " $ # $ # # "   " ! # " $ #sR+-AR=#ASAS!AS3AT;AT(T)AT;AU  AU+ R:= S  S! S03 T T T&) T8; U  U U-rz umask doesn't work on Emscripten)reasonc[R"S5n[R"U5 [RR[ U5[ 55n[ R"USS9 SSS5 [R"U5RS-SU)-:Xde[RR[ U5[ 55n[ R"US5 SSS5 [R"U5RS-SU)-:Xdeg!,(df  N=f!,(df  NM=f)NrTrdrCii) r umaskrrrr r3rstatst_moder)r cur_umaskrs r&test_native_file_permissionsr(Is IHHY 77<<F TV ,D 4c "  # 774= 5 (EYJ,> >> > 77<<F TV ,D tS !  " 774= 5 (EYJ,> >> > # " " !s3D*2D;* D8; E c[RR[U5[ 55n[ US5nUR S5 SSS5 [R"USS9nUR(aeSSS5 WR(de[R"USS9nUR(aeSSS5 WR(deUU/n/SQnUH?nUH6upx[R"[5 [X'5"U6 SSS5 M8 MA g!,(df  N=f!,(df  N=f!,(df  N=f!,(df  M=f)Nrr rrC))rr,)r)r)rr,)flushr,)rr,)rr,)rUr,)r rrrr rrr3rr7rrr*rgetattr) rrr%os_file mmap_filefilesmethodsmethodargss r&.test_native_file_raises_ValueError_after_closer2\s 77<<F TV ,D dD Q   4d #w>>!!> $ >>> t$ '9##### (       E!G#LFz*"D)+*$-   $ # ( '"+*s/D0-E2EE#0 D> E E # E2 cfSn[RR[U5[ 55n[ US5nUR URS55 SSS5 [[R"USS95nUR5(deUR5nXQ:XdeSSS5 WR(de[[R"USS95n[U5nSRU5U:XdeSSS5 [RR[U5[ 55n[[R"USS95nUR5(deUR U5 SSS5 [[R"USS95nUR5nXQ:XdeSSS5 g!,(df  GN=f!,(df  GN>=f!,(df  N=f!,(df  N=f!,(df  g=f)Nzfoooo barrr bazzz rutf-8rrC)r rrrr rrencoderr3rrrr7listr)rrJrr%filresrpath2s r&test_native_file_TextIOWrapperr;zs D 77<<F TV ,D dD Q  G$%  ryyD1 2c||~~~hhj{{ 3 ::: ryyD1 2cS wwu~%%% 3 GGLLVdf -E ryyT2 3s||~~~ $ 4 ryyT2 3shhj{{ 4 3)   3 2 3 2 4 3 4 3s<!G/G.0#H+)H:H" G+. G= H H" H0c Sn[US- 5n[US5nURUS-5 SSS5 [R"USS9n[ U5nUR 5S:XdeSnURU5n[U5[R"S U-[U5- 5:XdeXTR 5s=::a US -::de eSSS5 g!,(df  N=f!,(df  g=f) Ns foo quux largefile.txtrirrCri NrT) rrrr3rrr readlinesr5mathceil)rrJrr% binary_filerMrs r&#test_native_file_TextIOWrapper_perfrBs D v' (D dD Q w ))Dt,K { #q!Q&&& F#5zTYYq6zCI'=>>>>))+9vz99999 $ #   $ #sC$BC5$ C25 DcSS-n[US- 5n[US5nURU5 SSS5 /n[R"USS9nUR 5n[ U5[ U5:deURU5 UR S5n[ U5S::deURU5 U(dOMxSSS5 SRU5U:Xdeg!,(df  N=f!,(df  N7=f) Ns123 i@Br=rrrCi0ur-) rrrr3rread1r5rr)rrJrr%chunksr s r&test_native_file_read1rFs i D v' (D dD Q   F 4d #q Aq6CI% %% MM! Aq6V# ## MM!  $ 88F t ## #   $ #sC+A:C<+ C9< D cSSKnSSKJn SS-n[US- 5n[ US5nUR U5 SSS5 [ R"USS9nURUSS 9nURS /S-S /S-S .5nURXg5 UR5S ::deSSS5 g!,(df  N=f!,(df  g=f)Nrsa,b ir=rrrCrj)nrowsr r r i) pandaspandas.testingtestingrrrr3rread_csv DataFrameassert_frame_equalr)rpdtmrJrr%dfr=s r&#test_native_file_pandas_text_readerrRs j D v' (D dD Q    4d #q [["[ %< <<>>> 88A;' !! !HHQK 88A;' !! !r-c[R"[R"[R"S5SS9SS9nURS5S:XdeUR 5nUR (deUR (aeUR 5(aeURS5S:Xde[R"[5 URS5 SSS5 g!,(df  g=f)NrWrErXrTrZr_) r3r[rrr`r7rUrr*EnvironmentErrorrras r&.test_buffered_input_stream_detach_non_seekableres  r|||~~  88A;' !! ! ' (   ) ( (s C-- C;c2[R"S[RS9n[R"U5n[R "U5n[R "USS9nURS5 USSR5S:XdeUR5 USSR5S:XdeURS5 UR5 UR(deUR(deUSS R5S :Xdeg) NrPrrErXrZ12s3456789rjs 123456789) rzerosrr3rr8BufferedOutputStreamrrr*r8r7)np_bufr:r\r%s r&test_buffered_output_streamrls XXc )F ,,v C " "3 'C 3AGGEN "1:   ; .. .GGI "1:   9 ,, ,GGJGGI 88O8 ::: #2;   N 22 2r-c[R"S[RS9n[R"U5n[R "[R "U5SS9nURS5 USSR5S:XdeUR5nUR(deUR(aeUSSR5S:Xdeg)NrPrrErXrZrgrh) rrirr3rrjr8rrr`r7)rkr:r%r\s r&"test_buffered_output_stream_detachrns XXc )F ,,v C  8 8 =1MAGGEN "1:   ; .. . ((*C 88O8zz> "1:   9 ,, ,r-c[R"USS9n[R"X25nUR(aeUR 5(deUR 5(aeUR 5(aeUR5nXP:XdeSSS5 WR(deUR(de[R"USS9n[R"X25nUR5n[U[R5(deUR5U:XdeSSS5 g!,(df  N=f!,(df  g=fNrrC) r3rCompressedInputStreamr7rrrUrrrrr)rJfnrwr\ compressedgotr:s r&check_compressed_inputru's ))BT "C ! !# 3z$$$$""$$$$&&((((&&((((oo{{ 4     ::: ))BT "C ! !# 3z$$&#ryy))))~~4''' 4 3 4 3 4 3sA0E6AE E E'cSn[US- 5n[R"US5nURU5 SSS5 [ XS5 g!,(df  N=f)Nsome test data some test data some test data some test data some test data some test data some test data some test data some test data some test data eof zcompressed_input_test.gzrr{)rr{rrrurrJrrr%s r&test_compressed_input_gzipry;sJ .D V0 0 1B 2t    4V,  s A Ac.Sn[US- 5n[R"US5nURU5 SSS5 [ XS5 g!,(df  N=f![ a)n[ R"[U55 SnAgSnAff=f)Nrwzcompressed_input_test.bz2rdrx)rrxBZ2FilerrurNrr)rrJrrr%es r&test_compressed_input_bz2r}Dss .D V1 1 2B R    t/    CFs#A A! A! B+BBc[R"S5(d[R"S5 Sn[ US- 5n[ R "US5nURU5 SSS5 [R"US5nUR5nUR5U:XdeSSS5 WR(de[R"[R"U5S5nUR5nUR5U:XdeSSS5 UR(de[ US5n[R"US5nUR5nUR5U:XdeSSS5 UR(deg!,(df  GN>=f!,(df  GN =f!,(df  N=f!,(df  NW=f)Nr{gzip support is not builtrwz!test_compressed_input_openfile.gzrr)r rrrrr{rrr3rqrrr7pathlibPath)rrJrrr%rsr:s r&test_compressed_input_openfilerOsl   f % % /0 .D V9 9 :B 2t     ! !"f -$$&~~4''' .     ! !',,r"2F ;z$$&~~4''' <     RA ! !!V , $$&~~4''' - 88O8#   . - < ; - ,s0F" 'F48'G'G" F14 G G G%c[R"USS9n[R"X25nUR5nXP:XdeSSS5 g!,(df  g=frp)r3rrqr)rJrrrwr\rsrts r&check_compressed_concatenatedrjsD ))BT "C ! !# 3zoo{{ 4 3 3s A AcPSn[US- 5n[R"US5nURUSS5 SSS5 [R"US5nURUSS5 SSS5 [ XS5 g!,(df  NO=f!,(df  N,=f)Nrwzcompressed_input_test2.gzrrGrr{)rr{rrrrxs r&!test_compressed_concatenated_gziprqs .D V1 1 2B 2t  Sb   2t  RS  !$F3    sBB B B%cHSn[R"U5n[R"[5 [R "US5 SSS5 [R"[ 5 [R "US5 SSS5 [R "US5n[R"[SS9 UR5 SSS5 SSS5 g!,(df  N=f!,(df  Nr=f!,(df  N9=f!,(df  g=f)Nsfoofoofoofoofoofoofoofoofoofoounknown_compressionr{zzlib inflate failedr1) r3rrr*rrqr9rr)rJr\rss r&test_compressed_input_invalidr|s D //$ C z "   &;< # y !   d+ " ! !#v .* ]]7*? @ OO A / . # " ! !A @ / .s;C -C1$D>DD C.1 C? D D D!c6[R"5n[R"X25nUR(aeUR 5(aeUR 5(deUR 5(aeURU5 SSS5 WR(deUR(de[US5nURUR55 SSS5 g!,(df  Ni=f!,(df  g=f)Nr) r3rCompressedOutputStreamr7rrrUrrr6)rJrrrwr\rsr%s r&make_compressed_outputrs   !C " "3 4 $$$$&&((((""$$$$&&(((( 5     ::: b$1    5 4 sA*C9 D 9 D DcSn[US- 5n[XS5 [R"US5nUR 5nXA:XdeSSS5 g!,(df  g=f)Nrwzcompressed_output_test.gzr{r)rrr{rr)rrJrrr%rts r&test_compressed_output_gziprsR .D V1 1 2B4V, 2t ffh{{   s A A$c<Sn[US- 5n[XS5 [ R "US5nUR5nXQ:XdeSSS5 g![a)n[R"[U55 SnANgSnAff=f!,(df  g=f)Nrwzcompressed_output_test.bz2rxrB)rrrNrrrxr{r)rrJrrr|r%rts r&test_compressed_output_bz2rs .D V2 2 3Bt/ R ffh{{    CF  s" AB  B !BB  Bc[R"S5(d[R"S5 [R "US- S5nUR S5 SSS5 US- RS5n[R "US5nUR S5 SSS5 SSS5 g!,(df  N]=f!,(df  N(=f!,(df  g=f)Nr{rzctor.gzstestzctor2.gzr)r rrrr3rrr)rrZr%s r&test_output_stream_constructorrs   f % % /0 " "6I#5v >& W ? :  # #D )Q  & &q& 1V LL !2 * ) ? >2 1 * )s0 B5:CC$C5 C C C C%)rexpected_compression)zfile.bz2rx)zfile.lz4r|zfile.gzzpath/to/file.zstcv[R"U5(dN[R"[R R 5 [R"U5 SSS5 g[R"U5n[U[5(deURU:Xdeg!,(df  g=fr)) r rrr*r3libArrowNotImplementedErrordetectrr)rrrs r&test_compression_detectionrs   2 3 3 ]]266:: ; LL < ; T"%''''zz1111 < ;s B** B8c[R"[5 [R"S5 SSS5 [R"[ 5 [S5 SSS5 [R"[5 [S5 SSS5 g!,(df  Nk=f!,(df  NN=f!,(df  g=f)Nunknown)rr*rr rr9r,r-r&test_unknown_compression_raisesrsl z " 9% # y ! d  " z " i # " # " ! ! " "s#B B( B9 B%( B69 Cc,[R"U5(d[R"US35 Sn[R "5n[R "X 5nURU5 SSS5 UR5n[U5[U5:de[R"U5n[R"X 5nUR5nXQ:XdeSSS5 g!,(df  N=f!,(df  g=f)Nrrw) r rrrr3rrrr6r5rrqr)rwrJr\rscdatarts r&test_compressed_roundtriprs   k * * {m#89: .D   !C " "3 4  5 LLNE u:D !! ! //% C ! !# 3zoo{{ 4 3 5 4 4 3s"C4D4 D D)rxrzr{r|r}c[R"U5(d[R"US35 [R R [R"/SQ5/S/5n[R"5n[R"X 5n[R"X1R5nURUSS9 UR5 UR5 UR5n[R"[R "U5U5n[R""U5R%5nXa:Xdeg)Nr)rOrTr`rErr r`) max_chunksize)r rrrr3Tablerrrrrr write_tabler8r6rqrRecordBatchStreamReaderread_all)rwtabler\rZr:r: got_tables r&"test_compressed_recordbatch_streamrs   k * * {m#89: HH "((?";!1"ool35r-)r4r4)r4UTF8ch[R"S5n[R"X U5ULdeg)Nsabc123)r3rrrrrZs r&test_transcoding_no_opsr+s7 __Y 'F & &m -06 77 7r-)r4ascii)r4zlatin-1c[R"[R"SRU55UU5n[R "[ 5 URS5 SSS5 g!,(df  g=f)NuĀrO)r3rrr6rr*UnicodeEncodeErrorrrs r&test_transcoding_encoding_errorr5sU  ( (  56F ) * A + * *s A11 A?rrc[R"[R"S5UU5n[R"[ 5 UR S5 SSS5 g!,(df  g=f)NsrO)r3rrrr* UnicodeErrorrrs r&test_transcoding_decoding_errorrCsL  ( ( +,F | $ A % $ $s A"" A0cSn[R"U5[U54H/n[R"U5nUR 5U:XaM/e [ R "U5n[R"[U55nUR 5U:Xde[R"[U5SS9nUR 5U:XdegNrwr{rw)r3rr input_streamrr{r)rJargrZgz_datas r&test_input_stream_bufferrTs .D T"Jt$45%{{}$$$6mmD!G __Z0 1F ;;=G ## # __Z0f EF ;;=D  r-c|"SS5n[R"U"55nURS5S:Xdeg)Nc4\rSrSrSr\S5rSSjrSrg)1test_input_stream_duck_typing..DuckReaderidcgr)r,rvs r&r87test_input_stream_duck_typing..DuckReader.closefryr-cgr{r,rvs r&r78test_input_stream_duck_typing..DuckReader.closedir}r-Ncg)Nhellor,)rwrMs r&r6test_input_stream_duck_typing..DuckReader.readmsr-r,r)) rrrrr8rr7rrr,r-r&rrds       r-rrr)r3rr)rrZs r&test_input_stream_duck_typingrbs4  __Z\ *F ;;q>X %% %r-cSnUS- n[[U5S5nURU5 SSS5 [R"U5nUR 5U:Xde[R"[U55nUR 5U:Xde[R"[ R"[U555nUR 5U:Xdeg!,(df  N=f)Nrwrr)rrrr3rrrr)rrJ file_pathr%rZs r&test_input_stream_file_pathrts .D'I c)nd #q   $__Y 'F ;;=D  __S^ ,F ;;=D  __W\\#i.9 :F ;;=D   $ #s C"" C0cSn[R"U5nUS- n[[U5S5nUR U5 SSS5 [ R "U5nUR5U:Xde[ R "[U55nUR5U:Xde[ R "[R"[U555nUR5U:Xde[ R "USS9nUR5U:Xde[ R "USS9nUR5U:Xdeg!,(df  GN=f)Nrwzinput_stream.gzrr{r r{rrrrr3rrrrrrJrrr%rZs r&&test_input_stream_file_path_compressedrs  .DmmD!G**I c)nd #q  $__Y 'F ;;=D  __S^ ,F ;;=D  __W\\#i.9 :F ;;=D  __YF ;F ;;=D  __YD 9F ;;=G ## # $ #s E Ec:SnUS- n[[U5S5nURU5 SSS5 [R"USS9n[ U[R 5(deUR5U:Xde[R"[U5SS9n[ U[R 5(deUR5U:Xde[R"[R"[U55SS9n[ U[R 5(deUR5U:Xde[R"USS9n[ U[R5(deS n[R"[US 9 [R"US S9 SSS5 [R"[5 [R"US S9 SSS5 g!,(df  GN=f!,(df  NY=f!,(df  g=f) Nrwzinput_stream.bufferedr rXrer^r$Buffer size must be larger than zeror1rNmillion)rrrr3rrr[rrrrrr*rr9)rrJrr%rZunbuffered_streamrXs r&$test_input_stream_file_path_bufferedrs .D00I c)nd #q   $__YB 7F fb44 5 55 5 ;;=D  __S^ [5 [R "S5 SSS5 [[US- 5S5n[R"[SS9 [R "U5 SSS5 SSS5 g!,(df  N=f!,(df  M=f!,(df  N=f!,(df  NK=f!,(df  g=f) Nr-rrrTnew_filerzreadable file expectedr1) rrr*rr3rrkrr9r.rr)rr:rr%s r&test_input_stream_errorsrs S/C z " / # XZ( ]]9 % OOC & %)   +, ! c&:%& - ]]9,D E OOA F . - # "& % ! F E . -sGD5D,"D>E 3E E  D), D; > E  E E  E.cJSn[[U55n[R"[R"U55nUR U5 X:Xde[[U55n[R"[ U55nUR U5 X:Xdeg)Nrw)rkr5r3 output_streamrrr)rJr:rZs r&test_output_stream_bufferrs| .D CI C   bll3/ 0F LL ;; CI C   jo .F LL ;;r-c"SS5nU"5n[R"U5nURS5(deURR 5R 5S:Xdeg)Nc6\rSrSrSrSr\S5rSrSr g)2test_output_stream_duck_typing..DuckWriteric8[R"5Ulgr))r3rr:rvs r&__init__;test_output_stream_duck_typing..DuckWriter.__init__s,,.DHr-cgr)r,rvs r&r88test_output_stream_duck_typing..DuckWriter.close ryr-cgr{r,rvs r&r79test_output_stream_duck_typing..DuckWriter.closed r}r-c:URRU5 gr))r:r)rwrJs r&r8test_output_stream_duck_typing..DuckWriter.writes HHNN4 r-rN) rrrrrr8rr7rrr,r-r& DuckWriterrs% /      !r-rr)r3rrr:r6r)r duck_writerrZs r&test_output_stream_duck_typingrs^ ! !,K   k *F << ! !! ! ?? # # % 0 0 2h >> >r-cSnUS- nSnU"X!5 U"[U5U5 U"[R"[U55U5 g)Nrwrc[R"U5nURU5 SSS5 [[ U5S5nUR 5U:XdeSSS5 g!,(df  ND=f!,(df  g=frr3rrrrr)rrJrZr%s r& check_data0test_output_stream_file_path..check_datas_   i (F LL ) #i.$ '1668t# ##( ') ( ' 'sA'A8' A58 B)rrrrrJrrs r&test_output_stream_file_pathrsE .D(I$ ys9~t$w||C N+T2r-c SnUS- nSn[R"U"X!55U:Xde[R"U"[U5U55U:Xde[R"U"[R"[U55U55U:Xde[R"U"X!SS95U:XdeU"X!SS9U:Xde[ R "[SS9 U"X!SS9U:XdeSSS5 g!,(df  g=f) Nrwzoutput_stream.gzc[R"U40UD6nURU5 SSS5 [[ U5S5nUR 5sSSS5 $!,(df  N==f!,(df  g=frrrrJkwargsrZr%s r&r;test_output_stream_file_path_compressed..check_data-Y   i 26 2f LL 3 #i.$ '1668( '3 2 ' 'A!A2! A/2 Br{rzInvalid value for compressionr1rabbit)r{rrrrrr*rrs r&'test_output_stream_file_path_compressedr(s .D++I ??:i6 74 ?? ? ??:c)nd; < DD D ??7<<I/6 8;? @@ @ ??97 9<@ AA A i4 8D @@ @ z)H I)x@DHHH J I Is C88 DcSnUS- nSn[R"USS9n[U[R5(deSn[R "[ US9 U"X!SS9U:XdeSSS5 U"X!S S9U:XdeU"X!S S9U:XdeU"[U5US S9U:XdeU"[R"[U55US S9nXa:Xdeg!,(df  Nl=f) Nrwoutput_stream.bufferedct[R"U40UD6nURSS5S:a![U[R5(deUR U5 SSS5 [ [U5S5nUR5sSSS5 $!,(df  N==f!,(df  g=f)NrYrr) r3rgetrrjrrrrr s r&r9test_output_stream_file_path_buffered..check_dataDs   i 26 2fzz-+a/!&"*A*ABBBB LL 3#i.$ '1668( ' 3 2( 'sA B>B) B&) B7rrXrr1irr^) r3rrrrr*rrrr)rrJrrrrXr>s r&%test_output_stream_file_path_bufferedr@s .D11I((B ' 3 33 3 0C z -)t<DDD . i2 6$ >> > i4 8D @@ @ c)nd ;t CC C  S^4d KF >> . -s C CcSnUS- nSnU"X!SS9n[R"U5U:XdeU"X!SS9n[R"U5U:XdeU"X!SSS9n[R"U5U:Xdeg) Nrz(output_stream_compressed_and_buffered.gzc[R"U40UD6nURU5 SSS5 [[ U5S5nUR 5sSSS5 $!,(df  N==f!,(df  g=frrr s r&rHtest_output_stream_file_path_compressed_and_buffered..check_data`r r rrXr^r{rr{r)rrJrrr>s r&4test_output_stream_file_path_compressed_and_bufferedr[s /DCCI  R 8F ??6 "d ** *  T :F ??6 "d ** *  Tv NF ??6 "d ** *r-cLSnUS- nSnU"X!SS9U:XdeU"X!SS9U:Xdeg)Nssome test data rc"U40UD6nURU5 A[R"5 [ [ U5S5nUR5sSSS5 $!,(df  g=fr)r3rrrrrrrr s r&r1test_output_stream_destructor..check_datawsT!!)6v6 T  #i.$ '1668( ' 's A.. A<rrXr^r,rs r&test_output_stream_destructorrpsE D11I i1 5 == = i4 8D @@ @r-ct^SnU4SjnU"U5U:Xde[R"U"USS95U:Xdeg)Nrwc^>[TS- 5n[US5n[R"U40UD6nUR U5 SSS5 SSS5 [US5nUR 5sSSS5 $!,(df  N<=f!,(df  NE=f!,(df  g=f)Noutput_stream_filerr)rrr3rrr)rJr rrr%rZrs r&r2test_output_stream_python_file..check_datas.. / "d^q!!!.v.& T"/"d^q668^/.^^s.B A<B "B< B B  B B,r{rr)rrJrs` r&test_output_stream_python_filer#s@ .D  d t ## # ??:d? @D HH Hr-c[[55n[R"[5 [ R "USS9 SSS5 [5[54H<n[R"[5 [ R "U5 SSS5 M> [US- 5n[US5nSSS5 [US5n[R"[SS9 [ R "U5 SSS5 SSS5 g!,(df  N=f!,(df  M=f!,(df  N=f!,(df  NK=f!,(df  g=f)Nrrrrrzwritable file expectedr1) rrkrr*rr3rrr9rr)rr:rrrr%s r&test_output_stream_errorsr%s Y[ !C z " %0 # XZ( ]]9 %   S !& %) Vj !B b$1   b$1 ]]9,D E   Q F  # "& % F E sGD=D#:D5E*EE D # D2 5 E E E E%r))T)rx contextlibriorrrrrrrr{r?r rrrrrrnumpyr ImportError pyarrow.utilr pyarrowr r3r'r.r?rLmark parametrizer^rerhrprrrrrrrrrrrrrrrrrrrrrrrrr$r(r.r5r;rAr\rrrvparamrrrrrrrrrrrrfixturerrrrrrrrr r rrrrrr!rr(r2r;rBrFrIrRrUr]rbrerlrnruryr}rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr#r%r,r-r&r0s@$ %II  ."8,B#568'97'T"# &'8% $6, " )2(  3 . 4 . . 3&', ',   ''"**(: 0Pf# ))   'CCL-`J LL V[[&&bff.M.M&N      ) ; ;< LL V[[&&bff.M.M&N      ) LE LE^;( '3"((*+L$8<!B> , ;! (V-(&D 6<~LLL )K ? ? *<>:"$.&&$1 " 33" - - ((--444     "9 \\)f% \\$%v. < 2  2      LLkkrvv'F'FG )  ", ,V -6 5  56,+-.7.76,. 6--  ! !&$ !$$(:4 ! !%%.!!" ?, 3II.6++(A&II$ gC Bs[..[:9[: