<>i2SSKJr SSKJr SSKrSSKrSSKrSSK r SSK r SSK J r SSKJr SSKJr SrSrSrS r\ R.R S 5rS rS r\ R.R S 5rSrSrSr\ R.R?S/SQ\ R@"54/SQ\ RB"54/SQ\ RD"54/SQ\ RF"54/\ RH"\ RJ"554SS/S//\ RH"\ RB"554S/SSS//\ RH"\ RF"554/SQ\ RL"\ RN"S\ RB"55\ RN"S\ RF"55/54/5S5r(\ R.RRS5r*\ R.RRS5r+\ R.RRS 5r,\ R.RRS!5r-\ R.RRS"5r.\ R.RR\ R.R^S#55r0S$r1S%r2S&r3S'r4S(r5"S)S*5r6"S+S,5r7\ R.R?S-\6\7/5S.5r8S/r9\ R.R?S-\6\7/5S05r:S1r;S2rS5r?S6r@S7rAS8rBS9rCS:rDS;rES<rFS=rGS>rHS?rIS@rJSArKSBrLSCrMSDrNSErOSFrPSGrQSHrR\ R.R \ R.R?SI/SJQ5SK55rS\ R.R SL5rT\ R.R SM5rU\ R.R SN5rV\ R.R SO5rW\ R.R SP5rX\ R.R SQ5rYSRrZSSr[STr\SUr]\ R.RRSV5r^\ R.R SW5r_SXr`SYraSZrb\ R.RRS[5rc\ R.R?S\\ R\ R/5S]5rfS^rgS_rhS`riSarjSbrkScrlSdrmSern\ R.R?S\\ R\ R/5Sf5ro\ R.R?S\\ R\ R/5Sg5rp\ R.R?S\\ R\ R/5Sh5rqSirr\ R.R?S\\ R\ R/5Sj5rs\ R.R?S\\ R\ R/5Sk5rtSlruSmrv\ R.R?S\\ R\ R/5Sn5rw\ R.R?S\\ R\ R/5So5rxSprySqrzSrr{Ssr|Str}Sur~SvrSwr\ R.RRSx5rSyrSzrS{rS|rS}rS~rSr\ R.R?S\\ R\ R/5S5r\ R.R?S\\ R\ R/5S5r\ R.R?S\\ R\ R/5S5r\ R.R S5r\ R.R?S/SQ/SQ4\4/SQ/SQ4\ GR4S/SS//S/SS//4\ GR4/5S5r\ R.R?S\\ R\ R/5S5r\ R.R?S/SQ/SQ4\ GR4S/SS//S/SS//4\ GR4/5S5r\ R.R?S/SQ/SQ4\4/SQ/SQ4\ GR4S/SS//S/SS//4\ GR4/5S5r\ R.R?S\\ R\ R/5S5r\ R.RRS5r\ R.RRS5rSr\ R.RRS5rSrSrSrSrSrSrSrSrSrSr\ R.GRFS5r\ R.GRFS5r\ R.GRFS5rSr\ R.GRFS5r\ R.GRFS5r\ R.GRFS5r\ R.GRF\ R.R?S\\ R\ R/5S55r\ R.GRFS5r\ R.GRFS5r\ R.GR\S5r\ R.GR\S5r\ R.GR\S5r\ R.GR\S5r\ R.GR\S5r\ R.GR\S5r\ R.GR\S5r\ R.R?S\\ R\ R/5S5r\ R.R?S\\ R\ R/5S5r\ R.R \ R.R?S\ GRp\ GRr/5S55r\ R.R \ R.R?S\ GRp\ GRr/5S55r\ R.GRFS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5r\ GRzS5rSrSrSrSrSrg!\a SrG N{f=f)) OrderedDict)IterableN)from_dataframe)Versionc[R"/[R"5S9nUR[R"5:XdeUR 5/:XdeUR 5 [R"/SS9nUR[R "5:Xde[R"[5 [R"/5 SSS5 [R"/SQ/SQ/SQ/5n[UR[5(de[SUR55(de[SUR555(de[UR5S:XdeUR!5[#S UR555:Xde[$R&"U5[(R+U5UR!5-:deUR,S :XdeUR 5 [.R0"U5nU"5ceAU"5beg!,(df  GNv=f) Ntypebinary c3j# UH)n[U[RR5v M+ g7fN isinstancepalib Int64Array.0cs W/var/www/html/land-tabula/venv/lib/python3.13/site-packages/pyarrow/tests/test_table.py ,test_chunked_array_basics..4s$EAz!RVV..//13c3j# UH)n[U[RR5v M+ g7frrrs r!r"r#5s&K9JAz!RVV..//9Jr$rc3B# UHnUR5v M g7fr)get_total_buffer_sizers r!r"r#7s$/K8I101/F/F/H/H8IsH)r chunked_arraystringr to_pylistvalidater pytestraises ValueErrorrchunkslistall iterchunkslenr'sumsys getsizeofobject __sizeof__nbytesweakrefref)datadata2wrs r!test_chunked_array_basicsr@"s  BRYY[ 1D 99 ## # >> r !! !MMO   Rh /E :: $$ $ z "  #    D dkk4 ( (( ( EE E EE E K9JK K KK K t{{ q   % % '3/K8<8I/K,K KK K == &"3"3 #**,#- -- - ;;) ## #MMO T B 4   4<<- # "s I Ic[R"/SQ/SQ/SQ/5nUR[R"5:Xde[ U5S:Xde[ UR 5S:Xde[R"/SQ/SQ/SQ/5nUR[R"5:Xde[ U5S:Xde[ UR 5S:Xde[R"/SQ/SQ/SQ/[R "5S9nUR[R "5:Xde[ U5S:Xde[ UR 5S:Xde[R"/SQ//5nUR[R"5:Xde[ U5S:Xde[ UR 5S:XdeS n[R"[US 9 [R"/5(deSSS5 [R"/[R"5S9R[R"5:Xde[R"//5R[R"5:Xde[R"//[R"5S9R[R"5:Xdeg!,(df  N=f) Nr rrrr@@g@rr z@cannot construct ChunkedArray from empty vector and omitted typematch) rr)r int64r4r0int8r-r.r/r*null)arrmsgs r!test_chunked_array_constructionrLDs?   C 88rxxz !! ! s8q== szz?a     C 88rxxz !! ! s8q== szz?a     GGI  C 88rwwy  s8q== szz?a      C 88rxxz !! ! s8q== szz?a   LC z -#### .   BRYY[ 1 6 6"))+ EE E  RD ! & &"'') 33 3  RDryy{ 3 8 8BIIK GG G . -s )K"" K0c[R"SS/5n[R"X/5nUR5n[R"/SQ5nUR U5(deg)Nr r r r r r )rarrayr)combine_chunksequals)rJ chunked_arrresexpecteds r!test_combine_chunksrUqsW ((Aq6 C""C:.K  $ $ &Cxx %H ::h   c[R"/[R"5S9R5[R"/[R"5S9:Xde[R"[R"/[R"5S9/[R"5S9R5[R"/[R"5S9:Xdeg)Nr)rr)bool_rPrOrVr!4test_chunked_array_can_combine_chunks_with_no_chunksrZzs  BRXXZ 0 ? ? ARXX F      "288: &'bhhj n"((2BHHJ7 88 8rVc*[R"/SQ/SQ//5n[R"U5nUR 5n[ U[R 5(deURS:Xde[R"X5(deg)Nr r)r) rr)npasarrayto_numpyrndarrayshape array_equal)r=arr1arr2s r!test_chunked_array_to_numpyrdsy    D ::d D ==?D dBJJ ' '' ' ::   >>$ % %% %rVcSn[R"[US9 [R"[R "/SQ5[R "/SQ5/5 SSS5 [R"[US9 [R"[R "/SQ5/[R "5S9 SSS5 g!,(df  Np=f!,(df  g=f)Nzchunks must all be same typerEr ?@@r)r-r. TypeErrorrr)rOfloat64)rKs r!!test_chunked_array_mismatch_typesrls (C y ,  HHY  HH\ "   - y , "((9-.RZZ\B - , - , - ,sAC AC C C*c[R"/SQ5[R"/SQ5/n[R"U5n[U5S:Xdeg)Nr rz<[ [ 1, 2, 3 ], [ 4, 5, 6 ] ])rrOr)strr=s r!test_chunked_array_strrpsN   D   D !D t9    rVcD[R"/SQ5[R"/SQ5/n[R"U5nUSR5S:XdeUSR5S:XdeUSR5S:Xde[R "[ 5 US SSS5 [R "[ 5 US SSS5 U[R"S5R5S:XdeUSS nUR5S S /:XdeUS SnUR5S /:XdeUS S nURUR:XdeUR5/:Xdeg!,(df  N=f!,(df  N=f) Nr rr r riirrrc) rrOr)as_pyr-r. IndexErrorr\int32r+r )r= data_slices r!test_chunked_array_getitemrxsg   D   D !D 7==?a   8>> q  8>> q  z " Q # z " R #   " " $ )) )aJ    !aV ++ +aJ    !aS (( (bJ ??dii '' '    !R '' ' # " " "s,FF F Fc[R"/SQ5[R"/SQ5/n[R"U5nUR[ U55nUR UR :XdeUR 5/:XdeUR[ U5S-5nUR UR :XdeUR 5/:Xde[RRU/S/S9nUR[ U55n[ U5S:Xde[RRU/S/S9nUR[ U5S-5n[ U5S:Xdeg)Nr r anamesr) rrOr)slicer4r r+Table from_arrays)r=rwtable table_slices r!test_chunked_array_slicers=   D   D !DCI&J ??dii '' '    !R '' 'CIN+J ??dii '' '    !R '' ' HH $u 5E++c%j)K { q  HH $u 5E++c%j2o.K { q  rVc~[R"S/5[R"/SQ5[R"/SQ5[R"/SQ5/n[R"U5n[[ S5U5Hup#X#R 5:XaMe [ U[5(deg)Nrr rrrz)rrOr)ziprangertrr)r=rJijs r!test_chunked_array_iterrs !      D  4 CE"Is#GGI~~$ c8 $ $$ $rVcSnSnU"[R"/[R"5S9[R"/[R"5S95 U"[R"/[R"5S9[R"/[R"5S95 [R"SS/[R"5S9n[R"SS/[R"5S9n[R"SS/[R"5S9n[R"/SQ[R"5S9nU"U/U/5 U"U/U/5 U"X$/X$/5 U"X$/U/5 U"XB/X$/5 [R"/[R"5S9R S5(aeg)Nct[U[R5(aUnO[R"U5n[U[R5(aUnO[R"U5nUR U5(deUR U5(deX#:XdeU[ U5:wdegr)rr ChunkedArrayr)rQrnxarrsyarrsxys r!eq%test_chunked_array_equals..eqs eR__ - -A  'A eR__ - -A  'Axx{{{xx{{{v vCF{{rVcR[U[R5(aUnO[R"U5n[U[R5(aUnO[R"U5nUR U5(aeUR U5(aeX#:wdegr)rrrr)rQrs r!ne%test_chunked_array_equals..nes{ eR__ - -A  'A eR__ - -A  'A88A;;88A;;v vrVrrr r)rr rr)rr)rvrGrOrQ)rrr{br ds r!test_chunked_array_equalsrsL  r, ,.r, ,. !Qbhhj)A !Qbhhj)A !Qbhhj)A BHHJ/AsQCLsQCLvvvsOvv4;;DAAA AArV)r=typ)TFTT)r r rr)rg@N)r{Nrr r rr{rr ))r r{)r r NcX/nU(a5UR[R"USSUS95 USSnU(aM5[R"X1S9nUR 5 UR UR U55nUR 5 URU5(deg)Nr r)appendrrOr)r,loadsdumpsrQ)r=r pickle_modulearraysrOresults r!test_chunked_array_pickler(sF  bhhtBQxc23ABx $   V .E NN  !4!4U!; >R   ::  <<7 "" " <<  tzz * ** * <>Q   ::   <<6 !! ! <<  tzz * ** *rVcSSKnURURSSS5S9n[RR U5nUR 5nURS:XdeURS:XdeURS:XdeURRUR5(deURURSSS5S9n[RR U5nUR 5nURS:XdeURS:XdeURS:XdeURRUR5(degr) rrrr RecordBatch from_pandasrrr`rrQ)rr=batchrs r!4test_recordbatch_roundtrip_to_pandas_empty_dataframers+  <>R   ::  <<7 "" " <<  tzz * ** * <>Q   ::   <<6 !! ! <<  tzz * ** *rVc$SSKnSSKJn URSS/SS/S.5n[R "U5nUR R5R5nURS:XdeURXBRSS5 g)Nrr r g?g?r{rrr ) rrrrrrschema empty_tablerr`assert_frame_equaliloc)rrdfrrs r!test_to_pandas_empty_tablersw QF#s4 5B HHRLE \\ % % ' 1 1 3F <<6 !! !&''"1+.rVc[R"S/5[R"/SQ5/n[R"U5n[R"U5nUR 5/SQ:XdeUR [R "S5:Xde[R"USS9nUR 5/SQ:Xde[R"SS/5[R"/SQ5/n[R"U5n[R"U5nUR 5nUSS :Xde[R"US5(deUS S/S Q:XdeUR [R "S 5:Xde[RR[R"/S Q5[R"/SQ55n[R"XD/5n[R"U5nUR [R "S5:XdeUR 5/SQS -:Xdeg)Nrr )rr r rrGrndtype)0123r rgr rfrk)rr r rr r{rr r8)r{rr r{r) rrOr)r\r]tolistrisnanDictionaryArrayr)r=rRnp_arrelementsrJs r!test_chunked_array_asarrayrs !   D""4(K ZZ $F ==?l ** * <<288G, ,, ,ZZ 5 1F ==?2 22 2 !T  D""4(K ZZ $F}}H A;"   88HQK  AB<< '' ' <<288I. .. .   ( ( !288O#< >C""C:.K ZZ $F <<288H- -- - ==?7!; ;; ;rVc d[R"[R"S[R"55[R"S[R"55/5n[R "/SQUS9n[R "U5nUR5up4UR[R "[R "/SQ[R"5S955(deUR[R "[R "/SQ[R"5S955(de[R "/US9n[R "U5nUR5up4UR[R "[R "/[R"5S955(deUR[R "[R "/[R"5S955(deg)Nrr)r rr@)r@r)r rr)rrr) rstructfieldint16float32rOr)flattenrQ)tyr{carrrrs r!test_chunked_array_flattenrsp BHHS"((*-HHS"**,/1 2B /b9A  A D <<>DA 88B$$RXXibhhj%IJ K KK K 88B$$RXXo35::<&AB C CC C "A  A D <<>DA 88B$$RXXbrxxz%BC D DD D 88B$$RXXbrzz|%DE F FF FrVc$[R"[R"/SQ5R5[R"/SQ5R5/5nUR S5R R [R"SS/55(deUR S5R R [R"SS/55(deUR5n[R"/SQ5nUR S5R R U5(deUR S5R R U5(deUR5/S Q:Xdeg) NfoobarNr)quuxNrrrrr rrrr)rrNrrNr) rr)rOdictionary_encodechunk dictionaryrQunify_dictionariesr+)rJ expected_dicts r!%test_chunked_array_unify_dictionariesrs%   ,-??A &'99; C 99Q< " " ) )"((E5>*B C CC C 99Q< " " ) )"((FE?*C D DD D "CHH34M 99Q< " " ) )- 8 88 8 99Q< " " ) )- 8 88 8 ==?N NN NrVc[R"[SS9 [R"5 SSS5 g!,(df  g=f)NrrE)r-r.rjrrrYrVr!test_recordbatch_dunder_initrs& y 6  7 6 6 9 Ac"SS5n[R"/SQ[R"55n[R"U/5nU"U5n[R"U5nXB:Xde[R"U[R"5S9nXBR [R"55:Xdeg)Nc$\rSrSrSrSSjrSrg):test_chunked_array_c_array_interface..ArrayWrappericXlgrrO)selfrOs r!__init__Ctest_chunked_array_c_array_interface..ArrayWrapper.__init__sJrVNc8URRU5$r)rO__arrow_c_array__rrequested_schemas r!rLtest_chunked_array_c_array_interface..ArrayWrapper.__arrow_c_array__s:://0@A ArVrr__name__ __module__ __qualname____firstlineno__rr__static_attributes__rYrVr! ArrayWrapperrs   BrVrr r)rrOrGr)rcast)rr=chunkedwrapperrs r!$test_chunked_array_c_array_interfacersBB 88Irxxz *Dv&G4 G  g &F     gBHHJ 7F \\"((*- -- -rVc<"SS5n[R"/SQ/SQ/5nU"U5n[R"U5nX1:Xde[R"U[R"5S9nX1R[R"55:Xdeg)Nc$\rSrSrSrSSjrSrg)Btest_chunked_array_c_stream_interface..ChunkedArrayWrapperi cXlgrr)rrs r!rKtest_chunked_array_c_stream_interface..ChunkedArrayWrapper.__init__"LrVNc8URRU5$r)r__arrow_c_stream__rs r!rUtest_chunked_array_c_stream_interface..ChunkedArrayWrapper.__arrow_c_stream__s<<223CD DrVrrr r rrrrrrYrVr!ChunkedArrayWrapperr s  # ErVr!r )rNrr)rr)rr)r!r=rrs r!%test_chunked_array_c_stream_interfacer" sEE   Y 5 6D!$'G  g &F >>  gBHHJ 7F YYrxxz* ** *rVc$\rSrSrSrSSjrSrg) BatchWrapperi cXlgrrrrs r!rBatchWrapper.__init__! rVNc8URRU5$r)rrrs r!rBatchWrapper.__arrow_c_array__$szz++,<==rVr&rr rYrVr!r$r$ s >rVr$c$\rSrSrSrSSjrSrg)BatchDeviceWrapperi(cXlgrr&r's r!rBatchDeviceWrapper.__init__)r)rVNc <URR"U40UD6$r)r__arrow_c_device_array__)rr kwargss r!r1+BatchDeviceWrapper.__arrow_c_device_array__,szz223CNvNNrVr&r)r r rrrr1rrYrVr!r-r-(s OrVr- wrapper_classc[R"[R"/SQ[R"5S9/S/S9nU"U5n[R"U5nX1:Xde[R"[R "S[R "55/5n[R"X$S9n[R"[R"/SQ[R "5S9/S/S9nX5:XdegNr rr{r|r)r record_batchrOrGrrrv)r4r=rrcastable_schemarTs r!"test_recordbatch_c_array_interfacer:0s ?? ,U DD!G__W %F >>ii bhhj!!O__W =F , UH   rVc$[R"[R"/SQ[R"5S9/S/S9n[R "[ SS9 URSS9 SSS5 URSS9ng!,(df  N=f) Nr rr{r|z7Received unsupported keyword argument\(s\): \['other'\]rEznot-none)other)rr8rOrGr-r.NotImplementedErrorr1)r=_s r!=test_recordbatch_c_array_interface_device_unsupported_keywordr?Fsw ?? )"((* -.se D H  %%J%7   %%D%1A  s B Bc@[R"[R"/SQ[R"5S9/S/S9nU"U5n[R"U5n[R R U/5nX4:Xde[R"[R"S[R"55/5n[R"X%S9n[R"S[R"/SQ[R"5S905nX4:Xdegr6) rr8rOrGrr from_batchesrrrv)r4r=rrrTr9s r!test_table_c_array_interfacerBVs ?? ,U DD!GXXg Fxx$$dV,H   ii bhhj!!OXXg 6Fxx RXXibhhj 1H   rVc "SS5n[R"[R"/SQ[R"5S9/S/S9[R"[R"/SQ[R"5S9/S/S9/nU"U5n[R"U5n[R R U5nX4:Xde[R"X!SRS 9nX4:Xde[R"[R"S[R"55/5n[R"X%S 9nX4RU5:Xde[R"[RRS S 9 [R"U[R"[R"S[R"[R"555/5S 9 SSS5 g!,(df  g=f) Nc$\rSrSrSrSSjrSrg)4test_table_c_stream_interface..StreamWrapperincXlgrbatches)rrHs r!r=test_table_c_stream_interface..StreamWrapper.__init__orrVNc[RRURSRUR5nUR U5$Nr)rRecordBatchReaderrArHrr)rr readers r!rGtest_table_c_stream_interface..StreamWrapper.__arrow_c_stream__rsA))66 Q&& 6F,,-=> >rVrGrr rYrVr! StreamWrapperrEns  # ?rVrOr rr{r|rrr7zField 0 cannot be castrE)rr8rOrGrrrArrrvrr-r.rArrowTypeErrorlist_)rOr=rrrT good_schemas r!test_table_c_stream_interfacerSmsk?? )"((*=>seL )"((*=>seL DD!GXXg Fxx$$T*H   XXg1gnn 5F   ))RXXc288:678K XXg 2F ]];/ // /  %=   BIIrxxRXXbhhj5I'J&KL    s A'G;; H c[R"[S5SS9[R"/SQSS9/n[R"USS/5n/nUR 5HnUR U5 M UR U:XdeU[R"X!RS9:XdeU[R"US SURS SS9:wdeX:wdeg) NrrrrrrNrzrvc0c1r|r )rrOrr8 itercolumnsrcolumns column_names)r=rrYrs r!test_recordbatch_itercolumnsr[s q( 'g6 D OOD4, /EG  "s# ==G ## # BOOG3E3EF FF F BOOGABKu7I7I!"7MN NN N   rVc[R"[S5SS9[R"/SQSS9/n[R"/SQ5[R"S/S/S //5/nS S /n[R"X5nU[R"X5:XdeUR [R"X55(deU[R"X5:wdeUR [R"X55(ae[R"XS S 0S9nUR U5(deUR USS9(aeUR S5(aeUS:wdeg)NrrrrUrvrrefrVrWkeyvaluer}metadataTcheck_metadatar)rrOrr8rQ)data1r>rZr batch_metas r!test_recordbatch_equalsrgsF q( 'g6 E ! 3%#&' E$>rVc 0[R"[R"/SQ5[R"/SQ5/SS/5nUR[R"SS/55R UR SS55(deUR[R"SS/55R [R"[R"SS/5[R"SS/5/SS/55(deg)Nr r rNrr{rr rr]f1f2r rr )rr8rOtakerQr~r&s r!test_recordbatch_takerns OO $ % + , . t  E ::bhh1v& ' . .u{{1a/@ A AA A ::bhh4y) * 1 1 1d),bhhT{.CDt  & ' '' 'rVc[R"[R"/SQ5/S/S9nUSRS:XdegNr r rra0r|r)rr8rO_name)rbs r!)test_recordbatch_column_sets_private_namerus6 "((<01$ @B a5;;$  rVc n[R"SS/5n[R"[R"S[R"[R "555/5n[ R"[5 [R"U/US9 SSS5 g!,(df  g=f)Nr r f0r7) rrOrrrQutf8r-r.r=r8)rJrs r!,test_recordbatch_from_arrays_validate_schemarysh ((Aq6 C YYrxx ':;< =F * + f- , + +s B&& B4c([R"S/5[R"/SQ5[R"S/5/n[R"[5 [R "U/SQ5 SSS5 g!,(df  g=f)Nr )tokyolikehappyderek)idtagsr)rrOr-r.r/r8ros r!-test_recordbatch_from_arrays_validate_lengthsrsY HHaSM288$>? HHgY  !D z " 45 # " "s B Bc[R"//5n[U5S:XdeURS:XdeURS:XdegrK)rr8r4r num_columnsr&s r!test_recordbatch_no_fieldsrsH OOB #E u:?? >>Q      !! !rVc[R"[S55[R"/SQ5/n[R"[ 5 [R "U/SQS9 SSS5 [R"[ 5 [R "US/S9 SSS5 g!,(df  NH=f!,(df  g=fNrrrr|r{)rrOrr-r.r/r8ros r!*test_recordbatch_from_arrays_invalid_namesrs q $% D z " O4 # z " SE* # " # " # "sB, B=, B:= C c[R"[S55[R"/SQ5/n[R"USS/5nURR beg)NrrrVrW)rrOrr8rrbr=rs r!test_recordbatch_empty_metadatarsR q $% D OOD4, /E << (( (rVc[R"[S5SS9[R"/SQSS9/n[R"S[R"55[R"S[R "55/n[R "USS 0S 9n[R"XS 9nURURU55nURU5(deUR U:Xdeg) NrrHrrrintsfloatsfoobarrbr7) rrOrrrHrrr8rrrQ)rr=fieldsrrrs r!test_recordbatch_picklers q' $95 D # 2::<(FYYv(8 9F OOD 0E  !4!4U!; !3!3C!8 9 99 9 x  C ! y ! D " z " A # " !  " ! # "$FF#7F4 F # F14 Gc[R"[S55[R"/SQ5[R"[SS55/n[RR USS9nUR S5R UR S55(de[R"[SS 9 UR S 5 SSS5 [R"[5 UR S5 SSS5 [R"[5 UR S 5 SSS5 g!,(df  Nw=f!,(df  NT=f!,(df  g=f Nrrrzrr|r{rz"Field "d" does not exist in schemarErr) rrOrrrrrQr-r.rrjrurs r!test_recordbatch_select_columnr's q $% q" D NN & &t? & CE <<  # #ELLO 4 44 4  @ B S B y ! T " z " Q # " B B " ! # "$E8E,E) E E&) E7cj[R"/SQ5n[R"/SQ5n[R"SS/SS/SS/SS S //5n[R"XU//S Q5nURS /5n[R"U/S /5nUR U5(deURS S/5n[R"X!/S S/5nUR U5(deURS/5n[R"U/S /5nUR U5(deURSS/5n[R"X!/S S/5nUR U5(deUR SS05nURS S/5nSUR R;de[R"[SS9 URS/5 SSS5 [R"[SS9 URS/5 SSS5 URSS/5n[R"X/SS/5nUR U5(de[R"XU//SQ5n[R"[SS9 URS /5 SSS5 URS/5n[R"U/S/5nUR U5(deg!,(df  GN=f!,(df  N=f!,(df  Nu=fNrirjr r rrrrrrz)rkrlf3rkrrlrr{testazField "f5" does not existrEf5zindex out of bounds)rkrlrkzField "f1" exists 2 times) rrOr8selectrQreplace_schema_metadatarrbr-r.rru)a1a2a3rrrTbatch2s r!test_recordbatch_selectr<s $ %B + ,B Aq6Aq6Aq64!R9 :B OORRL*< =E\\4& !FtdV,H == " "" " \\4, 'Fx$6H == " "" "\\1# FtdV,H == " "" " \\1a& !Fx$6H == " "" " * *C= 9F ]]D$< (F 6==)) )) ) x'B C dV D z)> ? aS @\\4, 'Fx$6H == " "" " OORRL*< =E x'B C dV D\\4& !FtdV,H == " "" "% D C @ ? D C$LL"L$ L L!$ L2c[R"[5 [RR [R "[S555 SSS5 g!,(df  g=f)Nr)r-r.rjrrfrom_struct_arrayrOrrYrVr!*test_recordbatch_from_struct_array_invalidros9 y ! ((%();< " ! !s =A!! A/c  [R"SS0SS0/[R"S[R"54S[R"54/5S9n[R R U5nUR[R R[R"SS/[R"5S9[R"SS/[R"5S9/SS/55(degNrr rrgr) rrOrrvrrrrQr struct_arrayrs r!"test_recordbatch_from_struct_arrayrts88 !xo& YY,x.FG HL^^ - -l ;F ==33 HHaYRXXZ 0 HHdC[rzz| 4  H     rVc [RR[R"SS/[R"5S9[R"SS/[R "5S9/SS/5nUR 5nUR[R"SS0SS0/[R"S[R"54S[R "54/5S95(degNr rrgrr) rrrrOrvrto_struct_arrayrQr)rrs r! test_recordbatch_to_struct_arrayrs NN & & HHaYRXXZ 0 HHdC[rzz| 4  H   E  " " $F == !xo& YY,x.FG H   rVc[R"[SS9 [RR [R "[S555 SSS5 g!,(df  g=f)Nz*Argument 'struct_array' has incorrect typerEr)r-r.rjrrrrOrrYrVr!$test_table_from_struct_array_invalidrs= y(T U ""288E!H#56 V U Us =A  A.c  [R"SS0SS0/[R"S[R"54S[R"54/5S9n[R R U5nUR[R R[R"SS/[R"5S9[R"SS/[R"5S9/SS/55(degr) rrOrrvrrrrQrrs r!test_table_from_struct_arrayrs88 !xo& YY,x.FG HLXX ' ' 5F ==-- HHaYRXXZ 0 HHdC[rzz| 4  H     rVc [R"SS0SS0//[R"S[R"54S[R"54/5S9n[R R U5nUR[R R[R"SS/[R"5S9[R"SS/[R"5S9/SS/55(degr) rr)rrvrrrrQrrO)chunked_struct_arrayrs r!*test_table_from_struct_array_chunked_arrayrs++ 1+# '( YY,x.FG HXX ' '(< =F ==-- HHaYRXXZ 0 HHdC[rzz| 4  H     rVc [RR[R"SS/[R"5S9[R"SS/[R "5S9/SS/5nUR 5nUR[R"SS0SS0//[R"S[R"54S[R "54/5S95(degr rrrrOrvrrrQr)rrrs r!test_table_to_struct_arrayrs HH HHaYRXXZ 0 HHdC[rzz| 4  H   E  " " $F ==)) 1+# '( YY,x.FG H   rVc [RR[R"SS/[R"5S9[R"SS/[R "5S9/SS/5nUR SS9nUR[R"SS0/SS0//[R"S[R"54S[R "54/5S95(deg)Nr rrgrr max_chunksizerrs r!-test_table_to_struct_array_with_max_chunksizers HH HHaYRXXZ 0 HHdC[rzz| 4  H   E  " " " 3F ==)) 1+(C)* YY,x.FG H   rVc [RR[R"/[R"5S9[R"/[R "5S9/SS/5nUR 5nUR[R"/[R"[R"5[R "5S.5S95(deg)Nrrr)rrrrs r!*test_table_to_struct_array_for_empty_tablers HH HHRbhhj ) HHRbjjl +  H   E  " " $F ==  BHHJ"**,GH    rVcURU5(deURU:XdeURU:XdeURUR:XdeURUR:Xdegr)rQsizer r`strides)tensorexpected_tensorr rs r! check_tensorsrsk == ) )) ) ;;$   ;;$   <>_44 44 4rVtyp_str) uint8uint16uint32uint64rHrrvrGrrkc t[R"U5n/SQn/SQn/SQn[RR [R "U[R "U5S9[R "U[R "U5S9[R "U[R "U5S9//SQ5nURSS9n[R"X#U/5RUSS 9n[RRU5n[Xh[R "U5S 5 UR5n[R"X#U/5RUS S 9n[RRU5n[Xh[R "U5S 5 URS 5n /S Qn/SQn/SQnU RSS9n[R"X#U/5RUSS 9n[RRU5n[Xh[R "U5S5 U R5n[R"X#U/5RUS S 9n[RRU5n[Xh[R "U5S5 URS S5n /SQn/SQn/SQnU RSS9n[R"X#U/5RUSS 9n[RRU5n[Xh[R "U5S5 U R5n[R"X#U/5RUS S 9n[RRU5n[Xh[R "U5S5 g)N r r rrrrrrr rz(2<FPZ drrrrrrrrrrF row_majorForderCr )r rrrrrrr)rrrrrrrr)rrrrrrrrr)r rrrr)rrrrr)rrrrr)r\rrrrrOfrom_numpy_dtype to_tensor column_stackastypeTensor from_numpyrr~) rrrbrcarr3rrrrTbatch1rs r!'test_recordbatch_to_tensor_uniform_typers ((7 C &D /D 8D NN & & HHT 3 3C 8 9 HHT 3 3C 8 9 HHT 3 3C 8 9    E__u_ -F T*+223c2BAyy##A&H&B$7$7$> )) ) >>X-- -- - __ F T*+222::S2IAyy##A&HJJFOO-q1 ;;"   ;;"**, && & <<8>> )) ) >>X-- -- -rVc /SQn/SQn/SQn[RR[R"U[R"5S9[R"[ R"U[ R S9[R "5S9[R"U[R"5S9//SQ5n[R"[SS9 UR5 SSS5 g!,(df  g=f) Nrr) rrrirrrrrrrrz.Casting from or to halffloat is not supported.rE) rrrrOrr\rrr-r.r=r)rbrcrrs r!>test_recordbatch_to_tensor_unsupported_mixed_type_with_float16rns &D /D 8D NN & & HHT , HHRXXd"**5BJJL I HHT -    E >      s C88 Dc DSSSS[RSSSS/ nS S S S S SS[RS/ n[RR [R "U[R "5S9[R "U[R "5S9/SS/5nURSS9n[R"X/5R[R SS9n[RRU5n[RRUR5U5 URS:XdeUR [R "5:XdeUR"UR":XdeUR$UR$:Xdeg)Nr r rrrrrrrzrrrrrrrrr{rFrrrr)r\rrrrrOrrrrrrrrr^rr r`rrbrcrrrrTs r!test_recordbatch_to_tensor_nanrsA q!Q1a +D BBB 3D NN & & HHT - HHT -  :  E __u_ -F  %,,RZZs,CAyy##A&HJJFOO-q1 ;;"   ;;"**, && & <<8>> )) ) >>X-- -- -rVc/SQn/SQn[RR[R"U[R"5S9[R"U[R "5S9/SS/5n[ R"[RSS9 UR5 SSS5 URSS S 9n[R"X/5R[RS S 9n[RRU5n[R R#UR%5U5 UR&S :XdeUR([R"5:XdeUR*UR*:XdeUR,UR,:Xde[RR[R"U[R"5S9[R"U[R"5S9/SS/5nURSS S 9n[R R#UR%5U5 UR&S :XdeUR([R"5:XdeUR*UR*:XdeUR,UR,:Xde[RR[R"U[R."5S9[R"U[R."5S9/SS/5nURSS S 9n[R"X/5R[R S S 9n[RRU5n[R R#UR%5U5 UR&S :XdeUR([R "5:XdeUR*UR*:XdeUR,UR,:Xdeg!,(df  GN=f)N) r r rrNrrrr) rzrrrrrrNrrr{rz-Can only convert a RecordBatch with no nulls.rETF) null_to_nanrrrr)rrrrOrvrr-r.rPrr\rrrkrrrrr^rr r`rrHrs r!test_recordbatch_to_tensor_nullrs* )D 1D NN & & HHT + HHT -  :  E  =     ___ ?F  %,,RZZs,CAyy##A&HJJFOO-q1 ;;"   ;;"**, && & <<8>> )) ) >>X-- -- - NN & & HHT + HHT +  :  E___ ?FJJFOO-q1 ;;"   ;;"**, && & <<8>> )) ) >>X-- -- - NN & & HHT * HHT *  :  E___ ?F  %,,RZZs,CAyy##A&HJJFOO-q1 ;;"   ;;"**, && & <<8>> )) ) >>X-- -- -a  s Q Qc[RR[R"/[R"5S9[R"/[R"5S9/SS/5nUR 5n[ R"///5R[ RSS9n[RRU5nURUR:XdeUR[R"5:XdeURUR:XdeURS:Xdeg)Nrr{rrr)rr)rrrrOrrr\rrrrrr r`r)rrrrTs r! test_recordbatch_to_tensor_emptyr s NN & & HHRbjjl + HHRbjjl +  :  E __ F R!((3(?Ayy##A&H ;;(-- '' ' ;;"**, && & <<8>> )) ) >>V ## #rVc/SQn/SQn[RR[R"U[R"5S9[R"U[R "5S9/SS/5n[ R"[RSS9 UR5 SSS5 g!,(df  g=f)Nr) r{rr r{rr r{rr rr{rzDataType is not supportedrE) rrrrOrvrxr-r.rPr)rbrcrs r!&test_recordbatch_to_tensor_unsupportedr s &D 8D NN & & HHT + HHT *  :  E  )      s B66 Cc v[R"[S55[R"/SQ5/nSS/nU"XS9nURS5nURS:XdeU"UVs/sHoURS5PM snUS9nUR U5(deURSS5nU"UVs/sHoURSS5PM snUS9nUR U5(deURS5R U5(de[ UR[ U555S:Xde[R"[5 URS 5 SSS5 URSS5R USS5(deURSS5R USS5(deURSS5R USS 5(deURS[ U5S- 5R USS5(deUR[ U5S- S5R US S5(deUR[ U5S - S5R US S 5(degs snfs snf!,(df  GN@=f) NrrrVrWr|r rrrrr) rrOrr~rrQr4r-r.ru) factoryr=r}objslicedrrTsliced2 expected2s r!_table_like_slice_testsrsP q $% D4LE $ $C YYq\F ??a  D1Dq D1?H == " "" "ii1oG51A5UCI >>) $ $$ $ 99Q<  s # ## # syyS" #q (( ( z " "  # 99Q? ! !#bq' * ** * 99Q? ! !#bq' * ** * 99Q? ! !#a( + ++ + 99QC1 % , ,SW 5 55 5 99SX\1 % , ,SX 6 66 6 99SX\1 % , ,SBZ 8 88 8-26 # "s+J;J$J)) J8cH[[RR5$r)rrrrrYrVr!test_recordbatch_slice_getitemrs "2>>#=#= >>rVc4[[R5$r)rrrrYrVr!test_table_slice_getitemr!s "288 ,,rVc b[R"S[R"/[R"S5S905nUR SS5nUR 5 [R"S[R "/[R"5S905nUR 5 g)Nr{usrr)rrrOrr~rr)r*)rrs r!test_slice_zero_length_tabler%sw HHc288BR\\$-?@A BE++a#K HHc2++BRYY[AB CE OOrVc[R"S/SS9n[R"SS/SS9n[R"[R"U5/S/5n[R"[R"U5/S/5n[R "[R 5 [RRX#/5 SSS5 g!,(df  g=f)Nr rrrCrDrkrW) r\rOrr8r-r. ArrowInvalidrrA)rrrrs r!"test_recordbatchlist_schema_equalsr0s 1#X &B 3*I .B __bhhrl^dV 4F __bhhrl^dV 4F r ' v./ ( ' 's ,!C C$c[R"[R"/SQ5/S/S9nUSRS:Xdegrp)rrrOrsts r!#test_table_column_sets_private_namer#;s6 "((<()$8A Q4::  rVc@[RR//S9nURU5(deURS5(ae[RR//SS0S9nURUSS9(aeURU5(deg)Nr|r_r`raTrc)rrrrQ)rr<s r!test_table_equalsr%As HH 2 .E <<   ||D!!! ! HH 28H IE||E$|77 7 <<   rVc[R"[R"S[R"55[R"S[R"55/5n[R "[R "S/5[R "S/5/SS/S9n[RRU/U5nURRU5(deURS5[R"S//5:XdeURS5[R"S//5:Xde[R"[R"S[R"55/5n[R"[R5 [RRU/U5 SSS5 [R "[R "S/5/S/5n[R"[R5 [RRU/U5 SSS5 g!,(df  N=f!,(df  g=f)Nr{rr gQ @r|r)rrrrGrkr8rOrrArQrr)r-r.r)rrrincompatible_schemaincompatible_batchs r!"test_table_from_batches_and_schemar)Ms YY bhhj! bjjl#F OORXXqc]BHHdV,<=#&* .E HH ! !5'6 2E <<  v & && & <<?b..u5 55 5 <<?b..x8 88 8))RXXc288:%>$?@ r ' ug':; ("((A3-3%@ r ' 12F; ( ' ( ' ( 's,"I("I$ I!$ I2c 6SSKJn SSKnURS[ [ S5505nURS[ [ SS5505n[ RRUSS9n[ RRUSS9n[ RRXEU/5nURX#U/SS 9nUR5n[U5S :XdeU"[ RRU5R5U5 URS S 9n[ [[U55/S Q:XdeU"UR5U5 U"[ RRU5R5U5 [ RR[!XEU/55n UR#U 5(de[$R&"[(5 URSS 9 SSS5 g!,(df  g=f)Nr)rr{rzrF)preserve_indexT) ignore_indexrrr)rzrrrz)rrrrr1rrrrrrAconcat to_batchesr4rmapiterrQr-r.r/) rrdf1df2rrr expected_dfrHtable_from_iters r!test_table_to_batchesr5bs1 ,,T%)_- .C ,,T%B-01 2C ^^ ' 'E ' BF ^^ ' 'E ' BF HH ! !66": ;E))SsO$)?K G w<1  rxx,,W5??A"$R0G C! "o 55 5u(+6rxx,,W5??A"$hh++D&&1I,JKO << ( (( ( z " q) # " "s 1H  Hclsc"[R"[S5SS9[R"/SQSS9/nURUSS9nUR 5 UR R (ae[U5S:XdeURS:XdeUR[U5:XdeURS:XdeUR5S :XdeURS :Xde[R"U5[R!U5UR5-:deUR#5nU[%S /S Q4S /SQ4/5:Xde['U[(5(deX R+X2R S 9:Xde[,R."[05 US SSS5 /nUR35HnU[R4La[7U5[R8LdeUR;5HnUbMe [,R."[05 UR=S5 SSS5 [,R."[05 UR=UR>5 SSS5 O*[A[7U5[RB5(deUREU5 GM URFU:XdeX RXBRHS9:XdeX RUSSURHSSS9:wdeX$:wde[R "[RJ"S[RL"5SS0S9[RJ"S[RN"55/SS0S9nURXS 9nUR U:Xde[PRR"U5nU"5ceAU"5beg!,(df  GN7=f!,(df  GN=f!,(df  GN\=f)NrrrrUrvrr|rr r{)rr r rrrr7r rrr rVr_r`rrWrr)*rrOrrr,rrbr4rrr`r'r:r6r7r8r9 to_pydictrrdict from_pydictr-r.rurXrr rr3r num_chunks issubclassArrayrrYrZrrrvr;r<) r6r=rpydictrYrrrr?s r!test_table_basicsrAs~ q( 'g6 D OOD O 3E NN||$$$ $ u:?? >>Q     D )) ) ;;&   & & (,A AA A <<0 00 0 == 6#4#4 $,,.$/ // /__ F [ o $%"   fd # ## # OOF<** ** * ;;q> " "e ++ +rVc[R"[S55[R"/SQ5/n[R"[ 5 [R RU/SQS9 SSS5 [R"[ 5 [R RUS/S9 SSS5 g!,(df  NQ=f!,(df  g=fr)rrOrr-r.r/rrros r!$test_table_from_arrays_invalid_namesrOs q $% D z " T9 # z " T#/ # " # " # "s!B> C> C  Cc4[[S55/SQ/n[R"USS/S9n[RR USS/S9nUR U5(de[R"[R"S[R"55[R"S[R"55/5n[R"XS9n[RR XS9nUR U5(deg)Nrrr{rr|r7) r1rrrrrrQrrrrG)r=rrTrs r!test_table_from_listsrQs U1X D XXd3* -Fxx##Dc #;H == " "" " YY biik" bhhj!FXXd *Fxx##D#8H == " "" "rVcR[R"SS/SS//[R"5S9[R"/SQ/[R"5S9/n[R"[R "S[R"55[R "S[R"55/S S 0S 9n[R RXS 9nURURU55nUR5 URU5(deg) Nr r rrr)somestringsNrstrsrrrr7) rr)rr*rrrrrrr,rQ)rr=rrrs r!test_table_picklerWs 1a&1a&) < 78ryy{K DYY557!' 02F HH  5E  !4!4U!; !3!3C!8 9 99 9 x  C ! y ! D " z " A # " !  " ! # "rc[R"[S55[R"/SQ5[R"[SS55/n[RR USS9nUR S5R UR S55(de[R"[SS 9 UR S 5 SSS5 [R"[5 UR S5 SSS5 [R"[5 UR S 5 SSS5 g!,(df  Nw=f!,(df  NT=f!,(df  g=fr) rrOrrrrrQr-r.rrjrurYs r!test_table_select_columnr\&s q $% q" D HH _ =E <<  # #ELLO 4 44 4 xA C S C y ! T " z " Q # " C C " ! # "rcD[R"[R"/SQ5[R"/SQ5[R"/SQ5//SQS9n[R"[ SS9 UR S5 SSS5 g!,(df  g=f) Nr rrrr|z"Field "a" exists 2 times in schemarEr{)rrrOr-r.rrrs r!!test_table_column_with_duplicatesr_;so HHbhhy)hhy)hhy)+2A CE xA C S C C Cs 6B Bc~[R"[S55[R"/SQ5[R"[SS55/nURUSS9n[R"SUSR 5nUR SX1S5nURX1S5nURXS/-S S9nURU5(deURU5(deUR S X1S5nURUS/U-S S9nURU5(deg) Nrrrzrr|rr r)r{rr rr)rr{rr ) rrOrrrr add_column append_columnrQ)r6r=r new_fieldt2t3rTt4s r!test_table_add_columnrgFs) q $% q" D OODO 8Ed1gll+I   !YQ 0B   YQ 0BtAwi/%9;H 99X    99X      !YQ 0BQy4/%9;H 99X   rVc[R"[S55[R"/SQ5[R"[SS55/nURUSS9n[R"SUSR 5nUR SX1S5n[U5nUSUS'URUS S9nURU5(deg) Nrrrzrr|rr r)rrr ) rrOrrrr set_columnr1rQ)r6r=rrcrd expected_datarTs r!test_table_set_columnrkds q $% q" D OODO 8Ed1gll+I   !YQ 0BJMAwM!}%46H 99X   rVcL[R"[S55n[R"/SQ5n[R"[SS55nURXU/SS9nUR SS/5nUR S5nURU/SS9nUR U5(deURX#/S S9nUR U5(de[ R"[S S 9 UR S /5 S S S 5 g !,(df  g =f)z%drop one or more columns given labelsrrrzrr|r{rr rr Column 'd' not foundrErN) rrOrr drop_columnsrQr-r.r) r6r{rr rrdreexp_t2exp_t3s r!test_table_drop_columnsrs}s qA $%A q"A OOQ1I_O =E   S#J 'B   C B __aS_ /F ==    __aV;_ 7F ==    x'= > C5! ? > >s 9D D#c[R"[S55n[R"/SQ5n[R"[SS55n[RR XU/SS9nUR SS/5nUR S5n[RR U/SS9nUR U5(de[RR X/S S9nUR U5(de[R"[S S 9 UR S /5 S S S 5 g !,(df  g =f)z+verify the alias of drop_columns is workingrrrzrr|r{rrmrnrorErN) rrOrrrdroprQr-r.r)r{rr rrdrerqrrs r!test_table_droprvs qA $%A q"A HH !/ BE S#J B CB XX ! !1#V ! 4F ==    XX ! !1& !  C5 ? > >s #D?? E ch[R"[S55[R"/SQ5[R"[SS55/nURUSS9nUR S5nUR 5 URUSSSS9nUR U5(deg) Nrrrzrr|rr rn)rrOrr remove_columnr,rQ)r6r=rrdrTs r!test_table_remove_columnrys q $% q" D OODO 8E   Q BKKMtABxz:H 99X   rVcv[R"[S55/nURUS/S9nUR S5nUR 5 [ U5[ U5:XdeURSURS5US5nUR 5 URU5(deg)Nrr{r|r) rrOrrrxr,r4rarrQ)r6r=rrdres r!test_table_remove_column_emptyr{s q D OODO .E   Q BKKM r7c%j  q%++a.%( 3BKKM 99U   rVc/nSS/nSn[R"[US9 [RR XS9 SSS5 g!,(df  g=f)Nr{rz?Length of names [(]2[)] does not match length of arrays [(]0[)]rEr|)r-r.r/rrr)r=r}messages r!test_empty_table_with_namesr~sG D #JEI z 1 T/ 2 1 1s A  Ac[R"/5nUR/:XdeUR[RR //55(degr)rrrZrQrrr^s r!test_empty_tablersI HHRLE    ## # <<,,R4 5 55 5rVc[R"[S55[R"/SQ5[R"[SS55/nURU/SQS9nUR/SQ:XdeURU/SQS9nUR /SQ5nUR 5 UR/SQ:XdeURU5(deUR S5nUR 5 UR/SQ:XdeURU5(deSn[R"[US9 UR S 5 SSS5 g!,(df  g=f) Nrrrzrr|)ehbeeseaz.names must be a list or dict not rEz not a list) rrOrrrZrename_columnsr,rQr-r.rj)r6r=rrTrdrer}s r!test_table_rename_columnsrs* q $% q" D OODO 8E    00 0t+?@H   2 3BKKM ??2 22 2 99X      2 3BKKM ??2 22 2 99X   >G y 0 \* 1 0 0s E!! E/c[R"[S55[R"/SQ5[R"[SS55/nURU/SQS9nUR/SQ:XdeURU/SQS9nUR SSS .5nUR 5 XC:XdeURU/S QS9nURU/S QS9nUR SSS .5nUR 5 XS:Xde[R"[S S 9 UR SSS.5 SSS5 g!,(df  g=f)Nrrrzrr|)rrrrr)r{r )r{r{r )rrrrorE)r{r) rrOrrrZrr,r-r.r)r6r=rrTt1rds r!!test_table_rename_columns_mappingr s q $% q" D OODO 8E    00 0t+=>H   Du5 6BKKM >> OODO 8Et+>?H   Du5 6BKKM >> x'> ? 4e45 @ ? ?s "E Ec [R"[R"S[R"55[R"S[R"55/5n[R"[R"SU5/5n[R "SS/US9n[R "SS/US9n[R "S S /[R "5S9n[RRX#U//S QS 9nUR5nUR5 [RR[R "S S/[R"5S9[R "SS/[R"5S9[R "SS/US9U//SQS 9nURU5(deg)Nrrnestrrr) g)@) g-@FTrr|r rrrrr)za.xza.yzb.nestr ) rrrrrrOrXrrrr,rQ)ty1ty2r{rr rrdrTs r!test_table_flattenr-sM ))RXXc288:.XXc2::<02 3C ))RXXfc*+ ,C (H%C0A -/c:A %RXXZ0A HH !/ BE BKKMxx## !Qbhhj) #s"**,/ *j)4 % , $-H 99X   rVc [R"[R"S/5[R"S/5/SS/S9n[R"[R"S/5[R"S/5/SS/S9n[RR X/5nUR 5nUR 5 URU5(deURHnURS:XaMe g)Nr r{rkrlr|r r) rr8rOrrArPr,rQrYr=)rrrcombinedr s r!test_table_combine_chunksrAs __bhhsmRXXse_=$($<1F __bhhsmRXXse_=$($<1F HH ! !6"2 3E##%H  ??5 ! !! !   ||q   rVc[R"[R"/SQ5R5[R"/SQ5R5[R"/SQ5//SQS9n[R"[R"/SQ5R5[R"/SQ5R5[R"/SQ5//SQS9n[RR X/5nUR S S 05nURS 5RS 5RR[R"S S /55(deURS 5RS5RR[R"SS /55(deURS5RS 5RR[R"/SQ55(deURS5RS5RR[R"SS/55(deUR[R"55n[R"/SQ5n[R"/SQ5nURS 5RS 5RRU5(deURS 5RS5RRU5(deURS5RS 5RRU5(deURS5RS5RRU5(deUR5/SQ/SQ/SQS.:XdeURRS S 0:Xdeg)Nr){r)TFNNrr|)rrNr)rrrN)FNNTskey1svalue1rrrr r)rrrrrr)rrNrrrNr)rrrrrrrN)TFNNFNNT)rr8rOrrrArrrrrQrdefault_memory_poolr:rrb)rrrexpected_dict_0expected_dict_1s r!test_table_unify_dictionariesrNs* __ ,-??A %&88: *+-5DEF__ ./AAC &'99; *+-5DEF HH ! !6"2 3E  ) )7I*> ?E <<?  # . . 5 5 %  " "" " <<?  # . . 5 5 &%! # ## # <<?  # . . 5 5 ! # ## # <<?  # . . 5 5 #s     $ $R%;%;%= >Ehh56Ohh/O <<?  # . . 5 5o F FF F <<?  # . . 5 5o F FF F <<?  # . . 5 5o F FF F <<?  # . . 5 5o F FF F ??  E 6 ?!   << Wi$8 88 8rVc[R"SSS.SS0/[R"[R"5[R"55S9/n[R R US/S9nURS S 9nSU;deUSn[U5S:XdeUSSS.SS0/:XdeURS S 9n[U5S:XdeUSSSS.0SSS00/:Xdeg) Nr r )rrzrrr{r|strict)maps_as_pydicts) rrOmap_r*rvrrr:r4r+)rr table_dict column_list table_lists r!test_table_maps_as_pydictsrss 1 Qx (bhhj1 F HH u 5E:J *  S/K { q  +c1X6 66 6:J z?a   3aa 01C#q?C CC CrVc [[S55/SQ/n[[SS55/SQ/n[RR UVs/sHn[R "U5PM snSS9n[RR UVs/sHn[R "U5PM snSS9n[R "X4/5nUR5 [U5S:Xde[RR [X5VVs/sHup&[R "X&-5PM snnSS9nURU5(degs snfs snfs snnfNr)g$ggrDg$@rzrgrhrirCrDrr|) r1rrrrrO concat_tablesr,r4rrQr=r>rrrdrrrTs r!test_concat_tablesrs< U1X  D U1b\ E   D9Dqrxx{D9$.  0B   E:Eqrxx{E:$.  0B  rh 'F OO v;"  xx##14T1A%C1A&(XXae_1A%C*4$6H == " "" "::%C E E $E% c\[RR[[ S55/SS9n[RR[S5/SS9n[ R "[RSS9 [R"X/SS9nSSS5 g!,(df  g=f) Nrzr{r|rz@Unable to merge: Field a has incompatible types: int64 vs stringrE permissivepromote_options) rrrr1rr-r.rPr)rrdr>s r!test_concat_tables_permissivers   tE"I/v  >B   tO45V  DB    T V   bX| D V V Vs =B B+c[RR[[ S55/SS9n[ R "[SS9 [R"X/SS9 SSS5 g!,(df  g=f)Nrzrr|z Invalid promote_options: invalidrEinvalidr) rrrr1rr-r.r/rr!s r!!test_concat_tables_invalid_optionrsT d59o.f=A z)K L !; M L Ls A++ A9c[R"[5 [R"S/5 SSS5 g!,(df  g=fr)r-r.AttributeErrorrrrYrVr!test_concat_tables_none_tablers* ~ & $  ' & & < A cfSSKn[R"[R"S[R"55[R"S[R"55/5n[ S5nUR X"S.5nUR [R/S-US.5n[RRX1SS9n[RRXASS9nURRUR5(deURRURS S 9(ae[R"XV/5nURRURS S 9(deURRUR5(deg) Nrr{rabcdefghrrF)rr+Trc) rrrrr*r1rr\rrrrQr)rrvaluesr1r2table1table2table3s r!1test_concat_tables_with_different_schema_metadatars? YY biik" biik"F * F ,,V1 2C ,,bffX\7 8C XX ! !#U ! KF XX ! !#U ! KF ==   . .. .}}##FMM$#GG G   v. /F ==   d  CC C ==   . .. .rVc  [RR[R"SS/[R"5S9/S/5n[RR[R"SS/[R "5S9/S/5n[ R"[5 [R"X/SS 9nSSS5 WR[RR[R"/S Q[R"5S9[R"/S Q[R "5S9/SS/55(de[RR[R"SS/[R"5S9/S /5n[RR[R"SS/[R "5S9/S /5n[ R"[RS S9 [ R"[5 [R"X/SS 9 SSS5 SSS5 g!,(df  GN=f!,(df  N)=f!,(df  g=f)Nr r r int64_fieldrgrh float_fieldT)promoter r NNNNrgrhr^z Schema at index 1 was different:rEF) rrrrOrGrr-warns FutureWarningrrQr.rrrdrs r!&test_concat_tables_with_promote_optionrs    1a&rxxz *+m_ >B    3*2::< 01M? DB m $!!2(D9 % ==-- #"((*5 'bjjl;/ }%' ( (( (    1a&rxxz *+cU 4B    1a&rzz| ,-u 6B r.P Q \\- (   bXu 5) R Q % $) ( R Qs0/II5*I$I5 I!$ I2 .I55 Jc [RR[R"SS/[R"5S9/S/5n[RR[R"SS/[R "5S9/S/5n[R "X/SS 9nUR[RR[R"/S Q[R"5S9[R"/S Q[R "5S9/SS/55(de[RR[R"SS/[R"5S9/S/5n[R "X/S S 9nUR[RR[R"/S Q[R"5S9/S/55(deg)Nr r rrrgrhrdefaultrrrrrN) rrrrOrGrrrQrv)rrdrres r!!test_concat_tables_with_promotionrsz    1a&rxxz *+m_ >B    3*2::< 01M? DB  rh BF ==-- #"((*5 'bjjl;/ }%' ( (( (    1a&rxxz *+m_ >B    ,0F ==-- BHHJ//   rVc[RR[R"SS/[R"5S9/S/5n[RR[R"SS/[R "5S9/S/5n[ R"[RSS9 [R"X/SS9 SSS5 g!,(df  g=f) Nr r rr^zUnable to merge:rErr) rrrrOrGrr-r.rPrrrds r!'test_concat_tables_with_promotion_errorrs    1a&rxxz *+cU 4B    1a&rzz| ,-u 6B r((0B C "9= D C Cs 8C C&c[R"[S55[R"/SQ5[R"/SQ5[R"/SQ5/n[RR U[ S5S9nUSR US5(deUS R US 5(deUS R US 5(deUS R US5(de[R"[5 US SSS5 [R"[5 US SSS5 g!,(df  N7=f!,(df  g=f)Nrrrabbccddeefabcdr|rrrrr r rrrr) rrOrrrtuplerQr-r.rurYs r!test_table_negative_indexingrs" q $% *+ /0  D HH U6] ;E 9  E!H % %% % 9  E!H % %% % 9  E!H % %% % 9  E!H % %% % z " b  # z " a # " # " # "sEE' E$' E5c [[S55/SQ/n[[SS55/SQ/n[RR UVs/sHn[R "U5PM snSS9n[RR UVs/sHn[R "U5PM snSS9n[R "X4/5nUR5 [U5S:Xde[RR [X5VVs/sHup&[R "X&-5PM snnSS9nURU5(degs snfs snfs snnfr) r1rrrrrOconcat_batchesr,r4rrQrs r!test_concat_batchesrs= U1X  D U1b\ E  # #$$?$QRXXa[$$?*4 $ 6B  # #%$@%QRXXa[%$@*4 $ 6B  x (F OO v;"  ~~))7:47G+I7Gtq,.88AE?7G+I0:*[R"[S55[R"/SQ5/nURU[ S5S9n[R "[R "S[R"55[R "S[R"55/5n[R "[R "S[R"55/5nU[RLaSnOS nS US 3n[R"[US 9 URU5 SSS5 [R"[US 9 URU5 SSS5 g!,(df  NB=f!,(df  g=f) Nrrrr|rFrr{rz record batchz1Target schema's field names are not matching the z's field names:.*rE)rrOrrrrrrvrrr-r.r/r)r6r=rtarget_schema1target_schema2cls_namer}s r!&test_table_cast_to_incompatible_schemarGs  q $% D OODd O 4EYY bhhj! bhhj! NYY bhhj! N bhh!B,.G z 1 >" 2 z 1 >" 2 1 2 1 1 1s/E="F= F  Fc [R"[S5[R"5S9[R"/SQ[R"5S9[R"/SQ[R "5S9[R"/SQ[R "5S9/nURU[S5S9n[R"[S5[R"5S9[R"/SQ[R"5S9[R"/SQ[R"5S9[R"/SQ[R "5S9/nURU[S5S9n[R"[R"S [R"55[R"S [R"55[R"S [R"55[R"S [R "55/5nURU5nURU5(deg) Nrrrrrrr|r r rrrr{rr r)rrOrrGrvrkr*rrrrrrrQr6r=rrjexpected_table target_schema casted_tables r!test_table_safe_castingrjs{ q + $288:6 *> /biikB  D OODf O 6E q + $288:6 rxxz2 /biikB M __]%-_HNII bhhj! bhhj! bhhj! biik" M ::m,L   ~ . .. .rVc |[R"[S5[R"5S9[R"/SQ[R"5S9[R"/SQ[R "5S9[R"/SQ[R "5S9/nURU[S5S9n[R"[S5[R"5S9[R"/SQ[R"5S9[R"/SQ[R"5S9[R"/SQ[R "5S9/nURU[S5S9n[R"[R"S [R"55[R"S [R"55[R"S [R"55[R"S [R "55/5n[R"[RS S9 URU5 SSS5 URUSS9nUR!U5(deg!,(df  N7=f)Nrrr)g?g@gffffff @g@g@rrr|rr{rr r truncatedrEF)safe)rrOrrGrvrkr*rrrrrr-r.rrrQrs r!test_table_unsafe_castingrs q + $288:6 *> /biikB  D OODf O 6E q + $288:6 rxxz2 /biikB M __]%-_HNII bhhj! bhhj! bhhj! biik" M rk : =! ;::m%:8L   ~ . .. . ; :s *J-- J;c[R"SS/[RS9n[R"5n[R"XS9[R"USSUS9/n[R "[R R5 [RRUSS/S9 SSS5 g!,(df  g=f)Nrr rrrrr|) r\rOrrr-r.rrrr)rOu8rs r!test_invalid_table_constructrs HHaV288 ,E Bhhu&qr(D EF rvv** + VD$<8 , + +s !B?? C z data, klassrUrrrrNrUrrrrDcU"US5U"US5/n[R"S[R"54S[R"54/5n[RR XS9nUR S:XdeURS:XdeURU:Xde[R"S[R"54/5n[R"[5 [RR XS9 SSS5 [R"S[R"54S[R"54/5n[RR XS9n[RRURS5R5(deUR S:XdeURS:XdeURU:Xde[R"S[R"54S[R"S54/5n[R"[ ["45 [RR%XS9 SSS5 [R"[5 [RR XSS/S 9 SSS5 [R"[5 [RR XS S 0S 9 SSS5 g!,(df  GN=f!,(df  N=f!,(df  Nu=f!,(df  g=f) Nrr rVrr7r rs)rr}rrrrb)rrrxrrrrrr-r.r/types is_float32rr rr=rjr<r=klassrrs r!test_from_arrays_schemars] $q'NE$q'N +D YY+h -EF GF HH  5E    !! ! >>Q   <<6 !! !YY+, -F z " T1 #YY+h -EF GF HH  5E 88  u||H5:: ; ;; ;    !! ! >>Q   <<6 !! !YY+h S8I-JK LF +Y7 8 T1 9 z " T8JK # z " TFF;KL # ") # " 9 8 # " # "s02K<L!L!L0< L  L L-0 L>c UR05nURS:XdeURS:XdeUR[R"/5:XdeUR 50:Xde[R"S[R "54S[R"54/5n[S/SQ4S/SQ4/5nURU5nURS:XdeURS:XdeURU:XdeUR 5U:XdeSS 0nURU5nURX4S 9nURU:XdeURRU:XdeUR 5U:XdeURX2S 9nURU:XdeURRU:XdeUR 5U:Xde[R"[5 URX2US 9 SSS5 [R"[5 URS /SQ0[R"S [R"54/5S 9 SSS5 [R"[ SS9 UR/SQ/SQS.[R"S[R""54S[R$"54S[R&"54/5S 9 SSS5 [R"[5 URS/SQ00S 9 SSS5 g!,(df  GN7=f!,(df  N=f!,(df  Ni=f!,(df  g=f)NrrVrrrr rrrrr7rrV)rr r zdoesn't contain.* c, drEr )rrrrr{r r)r<rrrrr:rxrkr with_metadatarbr-r.r/rjr*rrGrvr)r6rrr=rbs r!test_table_from_pydictrs OOB E    !! ! >>Q   <<299R= (( ( ??  "" " YY+h -EF GF !34!>24 5D OOD !E    !! ! >>Q   <<6 !! ! ??  $$ $H  ! !( +F OODO 4E <<6 !! ! << H ,, , ??  $$ $ OODO 0E <<6 !! ! << H ,, , ??  $$ $ z " h? # y ! y)!yy4*=)>?  A " x'@ A ) ,99bhhj!bhhj!bhhj!   B y ! i(4 " !) # " " ! B A " !s1;L<.?MA.MM0< M  M M-0 M>c[SU"US54SU"US54/5n[R"S[R"54S[R"54/5n[R R U5nURS:XdeURS:XdeURU:Xde[R R XS9nURS:XdeURS:XdeURU:Xde[R"S[R"54S[R"54/5n[R R XS9n[RRURS5R5(deURS:XdeURS:XdeURU:Xde[R"S[R"54S[R"S54/5n[R "["[$45 [R R XS9 SSS5 g!,(df  g=f) NrVrrr r rr7r)rrrrxrkrr<rrrrrrr rr-r.r=rjrs r!#test_table_from_pydict_arrow_arraysr% s tAw08U47^2LM ND YY+h -EF GF HH  &E    !! ! >>Q   <<6 !! ! HH  5E    !! ! >>Q   <<6 !! !YY+h -EF GF HH  5E 88  u||H5:: ; ;; ;    !! ! >>Q   <<6 !! !YY+h S8I-JK LF +Y7 8 T1 9 8 8s I,, I:c[SU"US54SU"US54/5n[R"S[R"54S[R"54S[R "54/5n[ R"[SS9 [RRXS9 SSS5 [R"S[R"54/5n[RRXS9nURS:XdeURU:XdeURS/:Xdeg!,(df  N=f)NrVrrr rrEr7) rrrrxrkrGr-r.rrr<rrZrs r!test_table_from_pydict_schemarG s  tAw08U47^2LM NDYY+h -E,./F xv . T1 /YY+, -F HH  5E    !! ! <<6 !! !   & )) ) / .s D<< E c UR/5nURS:XdeURS:XdeUR[R"/5:XdeUR 5/:Xde[R"S[R "54S[R"54/5nSSS.SSS.S SS./nURU5nURS :XdeURS :XdeURU:XdeUR 5U:XdeS S 0nURU5nURX4S9nURU:XdeURRU:XdeUR 5U:XdeURX2S9nURU:XdeURRU:XdeUR 5U:Xde[R"[5 URX2US9 SSS5 [R"[5 URSS0SS0SS 0/[R"S[R"54/5S9 SSS5 [R"S[R"54S[R "54S[R""54/5nURSS S.S SS.S SS./US9nSSSS.S SSS.S SSS./nURU:XdeUR 5U:Xde[R"[5 URSS0SS 0SS 0/0S9 SSS5 SSS.SS0SS 0/nSSS.SSS.S SS./nURU5nURS :XdeURS :XdeUR 5U:XdeSS0SSS.SS0/nSS0SS0SS0/nURU5nURS:XdeURS :XdeUR 5U:Xdeg!,(df  GN&=f!,(df  GN=f!,(df  N=f)NrrVrrUr)rVrrrrr rrrrr7rrVr r{r rrr)r{r r) from_pylistrrrrr+rxrkrrbr-r.r/rjr*rGrvr)r6rrr=rbr>s r!test_table_from_pylistr _ sd OOB E    !! ! >>Q   <<299R= (( ( ??  "" " YY+h -EF GF3 'a (d + -D OOD !E    !! ! >>Q   <<6 !! ! ??  $$ $H  ! !( +F OODO 4E <<6 !! ! << H ,, , ??  $$ $ OODO 0E <<6 !! ! << H ,, , ??  $$ $ z " h? # y ! $T1Iay9!yy4*=)>?  A " YYbhhj)bhhj)bhhj)F OOq +11-=>  E$T *$T *$T * ,D <<6 !! ! ??  $$ $ y ! #qC8c1X6rB "3 ' qM UO DC (a (t , .E OOD !E    !! ! >>Q   ??  %% % RLa ( t  Db\e_d^ E OOD !E    !! ! >>Q   ??  %% %a # " " !( " !s%4P$'AP6:Q$ P36 Q QcrSSKnUR[S/SQ4S/SQ4/55n[R"S[R "54S[R "54/5n[RRXS9n[RRURS5R5(deURR5U:Xde[R"S[R "54S[R"S54/5n[R "["[$45 [RRXS9 SSS5 [R"S[R "54S[R&"54S[R("54/5n[R "[*SS 9 [RRXS9 SSS5 [R"S[R "54/5n[RRXS9nUR,S :XdeURR5U:XdeUR.S/:Xdeg!,(df  GN5=f!,(df  N=f) NrrVrrrr7rrrEr )rrrrrrxrrrrrrr remove_metadatarr-r.r=rjrkrGrrrZ)rrrrs r!test_table_from_pandas_schemar  s kF,>#?$,n#=#?@ ABYY+h -EF GF HH  3E 88  u||H5:: ; ;; ; << ' ' )V 33 3YY+h S8I-JK LF +Y7 8 R/ 9YY+h -E,./F xv . R/ /YY+, -F HH  3E    !! ! << ' ' )V 33 3   & )) ) 9 8 / .s J!J( J%( J6cSSKn[S/SQ4S/SQ4/5n[R"/SQSS9[R"/SQSS9S .n[R"S[R "54S[R "54/5nURU5n[R"U5n[RRU5nURU5(de[R"XCS 9n[RRXCS 9nURU5(de[R"U5n[RRU5nURU5(de[R"XS 9n[RRXS 9nURU5(deg) Nrrrr{r r*rrv)rr{r7) rrrrOrrvr*rrrrrQr<)rr d_explicitrrrrs r!test_table_factory_functionr s^ c?+c9-=>?Axxh?xx 8:JYYbhhj)C+=> ?F aB XXb\F XX ! !" %F ==  XXb (F XX ! !" ! 4F ==  XXj !F XX ! !* -F ==  XXa 'F XX ! !! ! 3F ==  rVc[R"[5 [R"S/SQ0S/S9 SSS5 [R "S[R "54/5n[R"S[R"/SQ[R"5S90U5nURS5R[R "5:Xde[R"/SQSS9/nS/n[R"X#5nURU:Xde[R "S[R"54/5n[R"X 5nURU:Xdeg!,(df  GNH=f)Nr{r r|rrG) r-r.r/rrrrvrOrGrr rZ)rrr=r}s r! test_table_factory_function_argsr s z " #y!#/ #YYbhhj)* +F HHc288IBHHJ?@& IE <<  ! !RXXZ // / HHYW - .D EE HHT !E    && & YYbhhj)* +F HHT "E    && & # "s E77 FcSSKn[R"[5 [R "UR S/SQ05S/S9 SSS5 [R"[5 [R "UR S/SQ05SS0S9 SSS5 [R"S[R"54/5n[R "UR S/SQ05U5nURS5R[R"5:Xdeg!,(df  N=f!,(df  N=f)Nrr{r r|rrr) rr-r.r/rrrrrvrr )rrrs r!'test_table_factory_function_args_pandasr s z " sI./u= # z " sI./66:JK #YYbhhj)* +F HHR\\3 "23V FL NC s8   ==t= ,1   ==a= (-   ==a= (-  rVc[R"[R"S[R"5SS0S9[R"S[R"55/SS0S9n[R "[R "/SQS -S S 9[R "/S QS -S S 9/US9n[U5S:Xdeg)NrVr_r`rrWrrrqrzrrrrvr7zppyarrow.Table c0: int16 c1: int32 ---- c0: [[1,2,3,4,1,...,4,1,2,3,4]] c1: [[10,20,30,40,10,...,40,10,20,30,40]])rrrrrvrrOrnrs r!"test_table_repr_to_string_ellipsisr"Q s YYrxxz+0'*:<rxxz24"( 02F ((BHH\"_7;HH-b0w?A  "C s8- -- -rVc[R"[R"S[R"5SS0S9[R"S[R"55/SS0S9n[R "[R "/SQS S 9[R "/S QS S 9/US 9n[U5S:XdeURSS9S:XdeURSS9S:XdeURSS9S:Xdeg)NrVr_r`rrWrrrqrrrrvr7zLpyarrow.RecordBatch c0: int16 c1: int32 ---- c0: [1,2,3,4] c1: [10,20,30,40]Trznpyarrow.RecordBatch c0: int16 -- field metadata -- key: 'value' c1: int32 -- schema metadata -- foo: 'bar'rrr z>pyarrow.RecordBatch c0: int16 c1: int32 ---- c0: [1,2,3,4] ...) rrrrrvr8rOrnrrrs r! test_record_batch_repr_to_stringr%c s YYrxxz+0'*:<rxxz24"( 02F OORXXlAXX&6WEG#) +E u:   ??? .3   ??? */   ??? */  rVc[R"[R"S[R"5SS0S9[R"S[R"55/SS0S9n[R "[R "/SQS -S S 9[R "/S QS -S S 9/US9n[U5S:Xdeg)NrVr_r`rrWrrrqrzrrrrvr7zpyarrow.RecordBatch c0: int16 c1: int32 ---- c0: [1,2,3,4,1,2,3,4,1,2,...,3,4,1,2,3,4,1,2,3,4] c1: [10,20,30,40,10,20,30,40,10,20,...,30,40,10,20,30,40,10,20,30,40])rrrrrvr8rOrnr$s r!)test_record_batch_repr_to_string_ellipsisr' s YYrxxz+0'*:<rxxz24"( 02F OORXXl2oGDXX&6r&9HJ#) +E u:I II IrVcSnSn[U/SQ4U/SQ4/5n[R"U[R"54U[R"54/5n[R "X#S9nUSR S5R[R"/SQSS95(deUS R S5R[R"/SQS S95(deg) Nuääähuöööfrr r7rrvrr r*) rrrrvr*rrrQrO)col_acol_brrrs r!"test_table_function_unicode_schemar+ s E E e_-y/ABCA YY +eRYY[-AB CF XXa 'F !9??1  $ $RXXig%F G GG G !9??1  $ $RXXoH%M N NN NrVc,[R"[R"/SQ5[R"/SQ5/SS/5nUR[R"SS/55R UR SS55(deg)Nrirjrkrlr r)rrrOrmrQr~r^s r!%test_table_take_vanilla_functionalityr- sp HH $ % + , . t  E ::bhh1v& ' . .u{{1a/@ A AA ArVc[R"[R"/SQ5[R"/SQ5/SS/5n[R"[R"SS/5[R"SS/5/SS/5nUR[R"SS/55R U5(deg)Nrirjrkrlr r{rrrrOrmrQ)rresult_with_null_indexs r!test_table_take_null_indexr1 s HH $ % + , . t  E  XX 1d)  3+  t  ::bhh4y) * 1 12H I II IrVc[R"[R"/SQ5[R"/SQ5/SS/5n[R"[R"SS/5[R"SS/5/SS/5nUR[R"SS /55R U5(deg) Nrirjrkrlr rrr rr/)rresult_non_consecutives r!test_table_take_non_consecutiver4 s HH $ % + , . t  E  XX 1d)  3*   t  ::bhh1v& ' . ./E F FF FrVcj[R"/SQ5n[R"/SQ5n[R"SS/SS/SS/SS S //5n[R"XU//S Q5nURS /5n[R"U/S /5nUR U5(deURS S/5n[R"X!/S S/5nUR U5(deURS/5n[R"U/S /5nUR U5(deURSS/5n[R"X!/S S/5nUR U5(deUR SS05nURS S/5nSUR R;de[R"[SS9 URS/5 SSS5 [R"[SS9 URS/5 SSS5 URSS/5n[R"X/SS/5nUR U5(de[R"XU//SQ5n[R"[SS9 URS /5 SSS5 URS/5n[R"U/S/5nUR U5(deg!,(df  GN=f!,(df  N=f!,(df  Nu=fr) rrOrrrQrrrbr-r.rru)rrrrrrTrs r!test_table_selectr6 s $ %B + ,B Aq6Aq6Aq64!R9 :B HHbb\#5 6E\\4& !Fxxtf%H == " "" " \\4, 'Fxx4,/H == " "" "\\1# Fxxtf%H == " "" " \\1a& !Fxx4,/H == " "" " * *C= 9F ]]D$< (F 6==)) )) ) x'B C dV D z)> ? aS @\\4, 'Fxx4,/H == " "" " HHbb\#5 6E x'B C dV D\\4& !Fxxtf%H == " "" "% D C @ ? D Crc  Sn[R"[R"/SQ5[R"/SQ5[R"/SQ5[R"/SQ5//SQS9nURS5R S /5nU"UR 55/S Q/S QS .:XdeURS5R S S /5nU"UR 55/S Q/S Q/SQS.:XdeURS5R S/5nU"UR 55/S Q/S QS .:XdeURS5R SS/5nU"UR 55/S Q/SQ/SQS.:XdeURS5R SS/5nU"UR 55/S Q/S Q/SQS.:XdeURSS/5R S/5nU"UR 55/SQ/SQ/SQS.:XdeURS5R SSS/S4S/5nU"UR 55/S Q/SQ/SQ/SQ/SQ/S QS.:Xde[R"[R"/S Q5[R"/S!Q5/SS"/S9nURS/5R S"S#[ R"S$S%94/5nUR 5S&/S'/S(.:XdeURS/5R S"S#[ R"S)S%94/5nUR 5S&/S*/S(.:XdeURS/5R S"S#[ R"S+S%94/5nUR 5S&/S,/S(.:XdeURS/5R /S4S"S#[ R"S+S%94/5nUR 5S&/S'/S,/S-.:XdeURS/5R /S4/5nUR 5S&/S'/S..:Xde[R"/S/Q[S05S1.5n[RRURS'S295nURS5R S/5nU"UR 55S&S3/S0S4/S .:Xdeg)5Nc2SU;a[[USUS55nOUSn[U5nS[US50nUHNnUS:XaM [[XU55nUH&nUR U/5R XV5 M( MP U$)Nkeys2keys)rrsortedr; setdefaultr)rr: sorted_keyssorted_dentryrks r!sorted_by_keys+test_table_group_by..sorted_by_keys s a<QvY' 34DV9DTl F1V9-.E#deH-.F ##E2.55fi@!  rVr{r{rrr )XrDYZrFr)rzrrrr)r:r9r bigvaluesr|r:)rhash_sumr)rrr)r: values_sum)r hash_count)r r r )r:rI values_count)rr5)rmax)rGr5)r rr)rrr)r: values_max bigvalues_sum)rGrL)rrr)r:rI bigvalues_maxr9)r{rrr )rDrErFrF)rrrr)r:r9rI count_all)r:rMrNrOrPrI)r{r{r{)r NNrcountr2)moder{r)r:rK only_nullr only_validr )r:rPrK)r:rP)r{rr{rr{rrr:rrrr) rrrOgroup_by aggregater:pc CountOptionsrrrAr.)rArrtable_with_nullstable_with_chunkss r!test_table_group_byr] sV HH *+ *+ ! %&  6  7E v((* A !++- (-   v(( * A !++- (!-   v((* A !++- (-   v((* A !++- (%-   v((* A !++- (%-   ()335 A !++- ($%"-   v(( [ * A !++- (%% -  xx ! !!h ! !!6(+55 7BOO787 A ;;=   !!6(+55 7BOO=>7 A ;;=   !!6(+55 7BOO>?7 A ;;=   !!6(+55 [ 7BOO>?7 A ;;=S   !!6(+55 [7 A ;;=S   HH.( E-- q)+""6*446G5HIA !++- (c !f-  rVc[R"/SQSS/S-S.5n[R"/SQSS/S-S.5n[R"X/5n[R"[ 5 UR S5RS/5 SSS5 UR SSS9RS/5n[R"SS/S S/S .5nURU5(deg!,(df  Nd=f) Nrqr{rr r)r{firstF) use_threadsr )ra_first) rrrr-r.r=rVrWrQ)rrrrrTs r!test_table_group_by_firstrb sXXLSzA~> ?F XXLSzA~> ?F   f- .E * + s%%~&67 ,^^CU^ 3 = =~>N OFxxsCjaV<=H == " "" " , +s 2"C22 Dc[R"/SQ/SQ/SQS.5n[R"[SS9 UR S5R S/5 SSS5 UR S5R S /5n[R"/S Q000/S .5nURU5(de[R"S S 9nUR S5R SSU4/5n[R"/S QSSS .SSS .SSS ./S .5nURU5(deg!,(df  N=f)N)r r rr r r)hrdrdwrere)rzrrrrr)groupr_r`z accepts 3 arguments but 2 passedrErf)r_ pivot_wider)r_r`rgr )rfkey_value_pivot_wider)rdre) key_namesrhrgrzrrrrr) rrr-r.r/rVrWrQrXPivotWiderOptions)rrrToptionss r!test_table_group_by_pivot_widerrm s/ HH1;79 :E z)K L w))+A*BC M ^^G $ . .0Q/R SFxx)35r2,@AH == " "" """Z8G ^^G $ . . M7 346FxxB r!32B5G#I JKH == " "" "# M Ls "D33 Ecj[RRS/SQ05nUR5nURUR:XdeXR 5:XdeURSS9nUR 5RS:XdeUR 5RS:Xdeg)Nrr r rr )rrr< to_readerrread_allread_next_batchr)rrMs r!test_table_to_recordbatchreaderrr s HH #y!1 2E __ F <<6== (( ( OO% %% % __1_ -F  ! ! # , , 11 1  ! ! # , , 11 1rVc[R"/SQ/SQS.5n[R"/SQ/SQS.5nURUSS5nUR5[R"/SQ/SQ/S QS .5:XdeURUSSS S 9nUR5R S5[R"/S Q/SQ/SQS .5:Xdeg)Nr r rr{rr^colAcol2rsr r rFrGrF)colBcol3rwr{rFrGNrwrxr| full outer join_typer r rrsr{rr^NrFrGNrFrrjoinrPsort_byrs r!test_table_joinr s  B  B WWR (F  "bhh 0'   WWR>& !RXX$ /&  rVc[R"S/SQ05n[R"/SQ/SQS.5nURUS/SS9nU[R"/SQ/SQS .5:Xdeg) Nrr rzr)rrr r)rFrFrG)rr)rrrrs r!test_table_join_asof_empty_byr s}  i B " B \\ taF RXX"  rVc 0[R"/SQ/SQ/SQ/SQS.5n[R"/SQ/SQ/SQ/S Q/S QS .5nS n[R"[US 9 UR USSS/SSSS/S9 SSS5 g!,(df  g=f)Nrtrr rurrrzrrrryr)r{rcolUniqrwrzXColumns {'colVals'} present in both tables. AsofJoin does not support column collisions.rErrwr{r r)rrr-r.r/rrrdrKs r!test_table_join_asof_collisionsr s "  B ""  B 7 z - 4VV,VV$4   . - -s %B Bc J[R"/SQ/SQ/SQS.5n[R"/SQ/SQ/SQ/SQS .5nS n[R"[RR US 9 UR US S S/SS S /S9 SSS5 g!,(df  g=f)Nrtrr rrzrryrrrrwrz)inconsistent size of by-key across inputsrErrwr{r rrrr-r.rrrrs r!'test_table_join_asof_by_length_mismatchr s  B ""  B 6C rvv**# 6 4VV,VH   7 6 6s 3B B"c B[R"/SQ/SQS.5n[R"/SQ/SQ/SQ/SQS.5nS n[R"[RR US 9 UR US S /S S S /S9 SSS5 g!,(df  g=f)Nrtr rwrrzr)gX@rhrgrrzCExpected by-key type int64 but got double for field colA in input 1rErrwr rrrs r!%test_table_join_asof_by_type_mismatchr s  B ""  B PC rvv**# 6 4VHVH   7 6 6 0B Bc B[R"/SQ/SQS.5n[R"/SQ/SQ/SQ/SQS.5nS n[R"[RR US 9 UR US S /S S S /S9 SSS5 g!,(df  g=f)Nrtr rrzrry)rhrirCrzAExpected on-key type int64 but got double for field on in input 1rErrwr rrrs r!%test_table_join_asof_on_type_mismatchr s  B ""  B NC rvv**# 6 4VHVH   7 6 6rc URSS/SS/S.5n[R"[R"SSSS9[R"SSS S9/5n[R "[ 5 URU5 SSS5 URSS/S S/S.5nURU5RU:Xdeg!,(df  NH=f) Nr Trr{rGrIrboolF)r<rrrr-r.r/r)r6r new_schemas r!test_table_cast_invalidr s OO4)4,? @EBHHS'DAHHS&5ACDJ z " : # OO4)5$-@ AE ::j ! ( (J 66 6 # "s 3C CcUR[R"/SQ5[R"/SQ5/SS/S9nURS5R 5/SQ/SQS.:XdeURS /5R 5/S Q/S QS.:XdeUR[R"/S Q[R "5S 9[R"/SQ5/SS/S9nURS/5nUR 5nUS/SQ:XdeUS/SQ:XdeURS/5nUR 5nUS/S Q:XdeUS/SQ:Xdeg)N)rr rr r)rr{rr{r rr:r|rCrrU)r descending)r rrr{r{)rrrr r )rrr#r)rcarrfoobarr{r)r{r)rrrr)rrrr)r{ ascending)rrrOrr:rG)r6rr sorted_tabsorted_tab_dicts r!test_table_sort_byr, sz OO ! *+   !E == " , , .)!3   ==23 4 > > @)!E   // RXXZ0 013Z  C 123J **,O 3 = 00 0 3 #B BB B012J **,O 3 = 00 0 3 #B BB BrV constructorc&U"/SQ/SQ/SS/S9n[R"U5n[R"SS/SS /S S //S S 9n[RR X#5 [R"USS 9n[RR X#5 UR S:XdeUR /5n[R"U5n[R"S5n[RR X#5 UR S :Xde[R"USS 9n[RR X#5 UR S:XdeURSS5n[R"U5n[R"S5n[RR X#5 UR S :Xde[R"USS 9n[RR X#5 UR S:Xdeg)Nr rBr{rr|r rr rrrrkrrv)rrrr) r\r]rOrassert_allcloserremptyr~)rrrrTrrs r!test_numpy_asarrayrS s O4S#J GE ZZ Fxx!Q!Q!Q0 BHJJv0 ZZW -FJJv0 <<7 "" "\\" F ZZ FxxHJJv0 <<9 $$ $ ZZg .FJJv0 <<7 "" "[[A F ZZ FxxHJJv0 <<9 $$ $ ZZg .FJJv0 <<7 "" "rVcU"/SQ/SQ/SS/S9n[R"SS/SS /S S //S S 9n[[R5[S5:a5[R"USS9n[RR X25 g[ R"[SS9 [R"USS9 SSS5 g!,(df  g=f)Nr rBr{rr|r rr rrrrkrz 2.0.0.dev0F)copyzUnable to avoid a copyrE) r\rOr __version__rassert_array_equalr-r.r/)rrrTrs r!test_numpy_array_protocolrt s O4S#J GExx!Q!Q!Q0 BHr~~!66%e, %%f7]]:-E F HHU 'G F Fs "C Cc DSn[RR[U5[U5VVs/sHn[S5Vs/sHo"PM snPM snnS.5n[RR[U5[U5Vs/sHoPM snS.5n[R "[R R5nURUSSS9 SSS5 SnU[WR5;de[R "[R R5nURUSSS9 SSS5 U[UR5;degs snfs snnfs snf!,(df  N=f!,(df  NK=f) Nrr)r array_column)rr`rinnerrzOData type list is not supported in join non-key field array_column) rrr<rr-r.rrrrnr`) NUM_ITEMSrrrrdexcinfo exp_error_msgs r!test_invalid_non_join_columnr sFI   I8=i8HI8H1U1X.X!X.8HI B   I"9-.-!-. B rvv** +w DG, ,/M C . .. . rvv** +w DG, , C . .. .#/I/ , + , +s5E5  E0E5  E; F:F0E5 F FcP[R"S5nURS5$)Nz pyarrow.cudar)r- importorskipContext)cudas r! cuda_contextr s   ~ .D <<?rVc[R"[R"S[R"55[R"S[R"55/5$)NrVrW)rrrrvrYrVr!rr s8 99bhhtRXXZ0"((42LM NNrVc[R"/SQURS5R5[R"/SQURS5R5/$)NrrrUr )rrOrr r7s r! cpu_arraysr sG HH_fll1o&:&: ; HH+V\\!_-A-A B DDrVcbUVs/sHo"RUR5PM sn$s snfrcopy_tomemory_manager)rrrJs r! cuda_arraysr s'@J K KK 33 4 KK Ks$,cT[R"U5nURSLdeU$)NTrr)is_cpu)rr)s r!cpu_chunked_arrayr s,$$Z0M   4 '' ' rVcT[R"U5nURSLdeU$NFr)rr)s r!cuda_chunked_arrayr s,$$[1M   5 (( ( rVcX[R"X-5nURSLdeU$rr)rrr)s r!cpu_and_cuda_chunked_arrayr s/$$Z%=>M   5 (( ( rVc*[R"XS9$Nr7)rr8)rrs r!cpu_recordbatchr s ??: 55rVc8URUR5$rr)rrs r!cuda_recordbatchr s  " "<#>#> ??rVc.[R"X/US9$rrr)rrs r! cpu_tabler s 88&:6 JJrVc.[R"X/US9$rr)rrs r! cuda_tabler s 88'UR>:Xde[AURB5[AURB5:XdeURES5nURF[HRJRL:Xde[ R "[5 URO5 SSS5 [ R "[5 URQ5 SSS5 [ R "[5 URS5 SSS5 g!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN^=f!,(df  GN==f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GNa=f!,(df  GN@=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GNv=f!,(df  GNA=f!,(df  GN =f!,(df  GN=f!,(df  GN=f!,(df  GN8=f!,(df  GN=f!,(df  g=f)NTfullrTFTFTrr r )*r lengthrnreprr,r-r.r= null_countr:r'is_nullis_nanis_valid fill_nullrr^ __array__rrrrPunique value_countsrrr~rm drop_nullsortrr=r4r0r device_typerDeviceAllocationTypeCUDAr+r __reduce__)rrrrrs r!test_chunked_array_non_cpur s  " "&7&<&< << <  $ $ &*;*B*B*D DD D ! "c*;&< << < ! "d+=&> >> >! * +###. , * +%% , * +!! , * +002 , * +1 , * +""$ , * +!!# , * +##% , * +$$Q' , * +0 , * +$$& , * +##% , * +$$& , * +! , * +,,. , * +""$ , * +))+ , * +!!# , * +'') , * +!!"BC , * +  # ,Q" * +$ , * +$$& , * +! , * +--/ ,  ( (,=,H,H HH H !(( )S1B1I1I-J JJ J  $ $Q 'E    7 7 < < << < * +$$& , * +--/ , * +%%' , +s , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , + , +sPZ Z* Z</["[  [2=\0\#\(\:>] 1]$]0^ ^=^&0^8#_ _ _.?``:`$-`6 aa a,>a> Z'* Z9< [  [ [/2 \ \ \%( \7: ]  ] ]-0 ]? ^ ^#& ^58 _ _ _+. _= ` `!$ `36 a a a), a;> b cUR5 UR[RR:XdeUR SLdeUR [UR5:XdeURUR:Xde[U5[U5;deURH-nUR[RR:XaM-e URU:Xdegr)r,rrrrrrr4r}rZrnrrYr)rexpected_schemar s r!verify_cuda_recordbatchrns NN    7 7 < < << < <<5    O$9$9 : :: :   !6!6 66 6 u:e $$ $ ]]}} 7 7 < <<<< <, but expected .rEr rWrVrrmaskTrVrWrrkeyvaluecol0col1r)   R::< = D D_ U UU U**+a. TU+WXII>   R::< = D D_ U UU U(-S->'? @'?!ll1o'?F @>>--k-IL * + ((6 , * +&&&& , * +557777 , * +""$ , * +""$ , * +""$ , * +""$ , * +((* , * +""$ ,!&&q!,II>    "" "!!""?"?"ABI --a3 33 3!88&(9KLII>    $ $(: :: :!//0@AIii &&,,q/.. / &&,,q/.. / 12OIG * +!!t!, , * +""$ , * +**, , * +++- , * +'5578 , +Q5 4( , + , + , + , + , + , +A + + , + , + , + , + , + , + , + , +0 , + , + , + , + , +sf+:f>5g(g" g4h0hh* h/i ii%:i7-j  jj-j?=k/k#"k5ll+ f; > g  g" g14 h h h'/ h> i i"% i47 j j j*- j<? k k # k25 l l l'c UR5 URSLdeUR[UR5:XdeUR UR:Xde[ U5[U5;deURHfnURSLdeUR5H>nURSLdeUR[RR:XaM>e Mh URU:Xdegr)r,rrr4r}rZrnrrYr3rrrrr)rrr rs r!verify_cuda_tabler2s NN <<5    O$9$9 : :: :   !6!6 66 6 u:e $$ $ ]]xx5   \\^E<<5( (($$(?(?(D(DD DD$ <RAUS S /5n [XS9 [R>RCUSUSS .5n [XS9 [E[URF55Vs/sHoRU5PM nn[RHRAX?S 9n[,R."[05 [R>RKU5 SSS5 [R>RMXD/U5n [XS9 [,R."[05 URN(deSSS5 [,R."[05 URQ5(deSSS5 [,R."[05 URS5 SSS5 [,R."[05 URU5 SSS5 [,R."[05 URW5 SSS5 [,R."[05 URY5 SSS5 UR[SS9nUH0n[,R."[\5 [_UUS9 SSS5 M2 URaSS9nUH0n[,R."[\5 [_UUS9 SSS5 M2 URcSS5n [XS9 U RS:XdeUReSS05n [XS9 U R(RfSS0:XdeURiSS/5n [R("[R"SURS5Rj5[R"SURS5Rj5/5n[U US9 URm5 [,R."[05 URmSS9 SSS5 [,R."[05 URo5 SSS5 [,R."[05 URo5 SSS5 [,R."[05 URq5 SSS5 [,R."[05 URsS 5 SSS5 [,R."[05 URuUS 5 SSS5 [,R."[05 URwUS S S5 SSS5 [,R."[05 URy5 SSS5 [,R."[05 UR{5 SSS5 [,R."[05 [}UR55 SSS5 [,R."[05 UR5 SSS5 g!,(df  GN=f!,(df  GN|=f!,(df  GNV=f!,(df  GN3=f!,(df  GN=f!,(df  GN=fs snf!,(df  GN=f!,(df  GNl=f!,(df  GNC=f!,(df  GN"=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GM=f!,(df  GM=f!,(df  GN3=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GN=f!,(df  GNf=f!,(df  GNE=f!,(df  GN$=f!,(df  GN=f!,(df  g=f)Nr)rzr r r rFrTrWrVrrrrrrrr r!r"r)Ar2rr`r4rYrarirrOrHrrrrrrrxr#rprrrGr-r.r=rrrrmrrQrrr<rr}r%rrAr:r'r:r+rrr.AssertionErrorrror~rrbrr r,rrrVrrr rrr'r)rrrrrrr(r)cpu_colcuda_col new_tablerr-cuda_table_with_nullsrrrrHrrMrs r!test_table_non_cpur9(sj9A   w && & z!! "a '' '$$j&;&;<((A37BGGI.??<#>#>?q$) )]] HHT2779 %6' (q$( 5((("))U222"))U222"))T111=((+Iiq1AB''/Iiq1AB''t 5I y  !Q && &    !!4&)Iiq1ABBHHT288:6rxxz8RSTJ * + # ,xxatfqj199,:U:UVH&11!T8D * +'') , * +4&1*% , * + , * +4  ,   A &,,q/ 11 1   A &,,q/ 11 1 * +  ++++ ,$$[4,?Ii8$$KN+a.%QRIi8(-S->'? @'?!ll1o'?F @>>--k-IL * + ""<0 ,%%'7&JFSIi8 * +     , * +//1111 , * + , * + , * + , * +""$ ,##!#4G ]]> * #E6 B+ *  ! ! ! 2F ]]> * #E6 B+ *   A&Ii8    "" "22FH3EFIi8    $ $(: :: :))66*:;Iii &&,,q/.. / &&,,q/.. / 12OiA * +& , * + , * + , * +%%' , * +D! , * + D) , * +ZtQ7 , * + , * +%%' , * +z//12 , * + , +a , + , + , + , + , + , +A + + , + , + , + , + , + , ++ *+ *, , + , + , + , + , + , + , + , + , + , + , +s>2j#/j5"kkk+k=-l l,l&#l8m mm.7n> n n%<n8.o !oo.p;p0p$'p6q q q,# j25 k k k(+ k:= l  l#& l58 m m m+. m= n n" % n5 8 o o o+. o= p p!$ p36 q q q), q:) collectionsrcollections.abcrr6r;numpyr\ ImportErrorr-pyarrowrpyarrow.computecomputerXpyarrow.interchangerpyarrow.vendored.versionrr@rLrUrZmarkrdrlrprxrrr parametrizerXrGrkr*rQrrrrrrrrrrnopandasrrrrrr"r$r-r:r?rBrSr[rgrnruryrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrrr#r%r)r5rrrArCrMrOrQrWrZr\r_rgrkrsrvryr{r~rrrrrrrrrrrrrrrrrrrrrrrr1rOr)rrrrr r rrrrr r"r%r'r+r-r1r4r6aceror]rbrmrrrrrrrrdatasetrrrrrrrrrrr8rrrfixturerrrrrrrrrrrrrrr0r2r9rYrVr!rIs$$$ .,D*HZ 8 & & C(((6!0 %-B` "BHHJ/ rxxz" 2::<( 299;' RXXbhhj !" a&1#,- %Sz "BHHRYY[$9: # IIrxxRXXZ0"((3 2LM N P          11&++2++2 / /%<%>OO<9K*LMN* 2 <9K*LMN,$ N"8' .6" +)#"**0#f=  7      5% 4B  4Bn66.0.0.f&..(9.9.x$$$""9J?-00 <***D  CCL , 0#&  **  .  $  ""((         06  ++8  664( !"9JD(#4E<! //,60,>*#4$"   ##8  //8  //>99.)40.)2884 teU^ur4j12B4D4DE) M  MF  6565r.)2884 teU^ur4j12B4D4DE)2 2<.)40.)2884 teU^ur4j12B4D4DE) *  *&  R&R&j**@!!:'( 0 0 )'T-$(VI$ OB J G0#fYYx # ###2244==."((bnn >? @ ,##L.2&  6  ,  *  *   7 7  CC@2??(CD#E#>2??(CD (E (//0 OODD LL   66@@KKMMLLJ(Z +]9@ +z _x Bsv vv