fpstreams/__init__.py,sha256=Ws_VwT_w2L8Ljhu9yOplG8Je4p_6ZCQu6tKrp335JcM,2356
fpstreams/_native.pyd,sha256=aT34JX_jmC7Ct-fNyAcIujuuFeaAGgNdR1SoXHiFXS0,1585152
fpstreams/_native.pyi,sha256=LnnW4ll52admM3pr_H_mPBbvSW3KcQ44mXmpkcrLT7s,23371
fpstreams/_provenance.py,sha256=RAJzfJ9FTTb7BwuH39QkLXhQbtLDc3xnqfb4p1YPquM,7734
fpstreams/aggregate.py,sha256=OPKJO88arwjyVrbYoIyjdtWMeJU1A0xf0jmYgE1stDs,882
fpstreams/async_flow.py,sha256=OUzNsq6i0hqh3085YnpENwRde-TLK5jZpAB9HLL8xuw,214
fpstreams/collecting/__init__.py,sha256=kwnJnoGhmkg1NMVJUvaYQJenH12YbQe39aTa5InNgnc,738
fpstreams/collecting/_collector_base.py,sha256=V5yXjGIOvJoWEu530LoEwDh9Rt9j_8viGxnMphrNjmY,5222
fpstreams/collecting/aggregate_program.py,sha256=ujqdzqrfzggtWOij6qVnOmFv1s-3ZSaXC21Us9Y2unw,5929
fpstreams/collecting/aggregation.py,sha256=5Roj8XnZmQVEM8dH8AtZ6QENh3emoe0wSzhFS3tCMRE,53009
fpstreams/collecting/collector.py,sha256=lS3Cg9ko0YigjCvG4NEFtUMB5C1GtDQtVydwwVeQisM,49297
fpstreams/collecting/program.py,sha256=Za2vKo8njwZzAK8QMZccrQD5EoxpOudQghbwxOt0r74,11445
fpstreams/collecting/reducer.py,sha256=lB_R9ZsYGg1EBEZfZlFSefSc2IzvSMdqrkT6-i712qw,9543
fpstreams/collecting/sketches.py,sha256=EBlJxAL9XsZx3a1NjBWeOgp19THiVwM7iWC6EKQETgk,4817
fpstreams/collecting/statistics.py,sha256=hd3YgNG_eXzQv1sTnBDyZ8lBSq3AO1ELaoF8UhZYeX8,14831
fpstreams/collectors.py,sha256=1lEb3Exx3Dfpa-0cNKVEI7h-uMA9W9o0StDMWbLayuA,608
fpstreams/column.py,sha256=EDmVHd7mEKf7hyDEhhjyAnZxVj1Db5IEhWN_ALUcI_Q,218
fpstreams/errors.py,sha256=02LHfHZlmWuRFJE3bRXx3CCZMiD2gm0u8mzHQ2un8IM,2571
fpstreams/exceptions.py,sha256=ni86PLY57AAPnkK26bLwmvpAd4ZD3sVbW0xRsLLTFds,418
fpstreams/execution/__init__.py,sha256=_bpbQcuKO1PQwtTeSlhrfV-3W1O7jgAkf6kbykSi9Gw,12666
fpstreams/execution/_rows_fusion.py,sha256=zEchr4_qYk1cth6r-PVXUDU8vRWSWEaA70zm9iaOyMU,41967
fpstreams/execution/_scalar_fusion.py,sha256=ABI86o2vRAz83qakP9eAZp4od6WocSq4_UohZ0J3DaE,9075
fpstreams/execution/arrow/__init__.py,sha256=RPsihcCPOE5JjxEqiUOuk3KZrjC_jmVciFDl0YYiLHU,65114
fpstreams/execution/arrow/numeric.py,sha256=Ggcj6J29HynE2INJNca7cfuGk4YEdjBRNneJr1aXe6I,11983
fpstreams/execution/arrow/sort.py,sha256=ogCaSHWH8BKVJovQzxIkLZuyRipciq8S6B5x0ULeT9c,5108
fpstreams/execution/asynchronous/__init__.py,sha256=jgfxbyq1amzoAI7DkeWzMRBv1SP_mwDpbl7Re290Wic,10336
fpstreams/execution/asynchronous/concurrent.py,sha256=WUL_6IsvNEPTjAtgs6zVV2DlOrGgAbhk6gYCXEh3k4I,10930
fpstreams/execution/asynchronous/merge.py,sha256=G0Lai11C9Ia2e7-8VcZCB7aA0baKLMDcRKRlrb0xWPg,16453
fpstreams/execution/asynchronous/operators.py,sha256=ky2mrjKdsyh3TjJcbWIBAjgb1vMNdgn_iHR6x9iQJGI,26985
fpstreams/execution/asynchronous/timers.py,sha256=4cDnhJzvOe6QopnGJrJHFCINE8R3Rb1MT3asTYnGumM,10525
fpstreams/execution/native.py,sha256=0SFplttnNR-RhBWQddCC0ucC7d-WY6ZCs1332a5QO5g,22875
fpstreams/execution/numpy_group.py,sha256=oL-GRKuvThoPOLMELLAyQf4tZ9Z1OJcBkp4Vp8n-pBQ,51118
fpstreams/execution/numpy_prefix.py,sha256=9wBmsHESWoJDYwJ-xiLU6EMp9RHnMm1MFqVO2kUCd_U,25840
fpstreams/execution/pairs/__init__.py,sha256=Agqeli1CdbkabiJ8Jn03ftw-symy709LIq57WCnlnvA,2276
fpstreams/execution/pairs/dictionary.py,sha256=J1TSxigPcllJ_vhZfHxA6iqefKJD5nbL094N4heK8pA,52180
fpstreams/execution/pairs/row_filter.py,sha256=ODnyxL_htqCTXiaQBp3Qf-FJcic9M_LfyfyAjKtDeJ0,12642
fpstreams/execution/physical.py,sha256=GXXtPm3SfnVe22W0IKf26b4J5l7RFKT0EegFX2tKvus,13832
fpstreams/execution/relational/__init__.py,sha256=2xF0sglmHb1jRYZqGga3YZBS3P76G6FAW8lsjIdrIC0,59194
fpstreams/execution/relational/arrow_global.py,sha256=ZKX5FrvE-jYLj_A_gqQXGbw3aE1ntp6LQAw9onSrofQ,36105
fpstreams/execution/relational/arrow_group.py,sha256=ZikYlz6wIHeJvCTzel7SSzM-Rlm7DWuIX_Jf_JHw2Ow,38053
fpstreams/execution/relational/arrow_group_rows.py,sha256=PRMuYuDxX5L29O49UqrEdlqs9Wh1gHYFOmII9Zn9ME8,6034
fpstreams/execution/relational/collector_group.py,sha256=PK2e3Ha5f_clSPottCqY7YdNg6yS-FUhjrisu36ZnUM,8381
fpstreams/execution/relational/join.py,sha256=VTTULA2Dpmsuzcr9hZP0Wpl6vf_E0vB9n3Oh3GeWG5w,20102
fpstreams/execution/relational/native_group.py,sha256=BFjjSRtarjoH6KZBUf6kYfGfxAQWIhnokpTFX4nN-bs,16270
fpstreams/execution/sorted_streams.py,sha256=ElC7DHz-Ii2JZtGKh5RUjNO2ZCABFOk0wPau5juS0-g,15824
fpstreams/execution/sorting.py,sha256=3TF6wNbUA8YaKNOg7-QpRFJ7YNB0S92TEBOH4Ow94NI,27559
fpstreams/execution/sync.py,sha256=--ILVd9K4p_Tezks69NCQl96KwY3CTl4vFZnYgIm0l4,14695
fpstreams/execution/sync_ops.py,sha256=9RAJzm5azz-4-9GTiz5xZCDI95RjGfIfKtTkazCxIYw,25898
fpstreams/execution/window_reduce.py,sha256=mgziwt7eR1-qKuCrtLsN2Ws6Ob8x2YHWXZofO7apc_Y,4903
fpstreams/expr.py,sha256=t4uGaUM8Hw7JsZoAHcNO4wpXKdVneosbWWAiP0YYIUQ,197
fpstreams/expressions/__init__.py,sha256=hBjrmCHmufeFmypPhRnGKGjtwseMMsA0kU80fndVuSw,324
fpstreams/expressions/_codegen.py,sha256=D2AqVNb_mmBS4l4aQNhBp90xBwe8A_NIu5LzyJC5xb8,1598
fpstreams/expressions/_row_codegen.py,sha256=h78TvLmaJ6lmr3oaoY3tvhCgw0Z2apo_vfTczGMu77s,9090
fpstreams/expressions/program.py,sha256=Zo0NVmktALzE4MHN01vGsrONQap3VKPomG_HP_ee52U,7689
fpstreams/expressions/row.py,sha256=PExC2-oz9z5hIfIS6tBAZGy0nENT7qfznNZS14gUCLg,16183
fpstreams/expressions/row_eval.py,sha256=WAqAd6kJClwfpw5FTcJvxPwB98U80zo2lAz26750D3g,16615
fpstreams/expressions/row_ir.py,sha256=LEfq6rzklfevteYiXomdX33PJeQMEmDQqi5H8HjNTnU,8769
fpstreams/expressions/scalar.py,sha256=IcrzG5mHzsb59Y9wgKNlEZrFd0-9EHBJXT2Kz5q-rQY,32211
fpstreams/expressions/selectors.py,sha256=sd8zTwqiPvcfh5T_9dT11G49bb_TACMAl7XevcRE0j4,6715
fpstreams/expressions/typed_ir.py,sha256=qwNmyN-HXvLPwcvvnVJTlTtpqZKy2uRdz8eWc9kMqPg,3258
fpstreams/functional.py,sha256=7v4MP3TfoBvh_PiFmjz22opCLRyvhpgZz8NsSmrSAmw,4806
fpstreams/gather.py,sha256=RmFf4LHeh0jGdFPesfnSnMXDFOW2Hfb4w1vfmMwm3vo,177
fpstreams/io_safety.py,sha256=D8IZQHT8MbUizF4FBH3je4CTsMIxRfJ4XdIFsn7qbOg,3928
fpstreams/option.py,sha256=Umf_A3u2Qf-NaJ70Y42YUJOieDwyYN7SivdvEY1loQQ,143
fpstreams/physical/__init__.py,sha256=8hWvNDoZbRiIo-vN-HnrYlmymJODmpj0ztFqK2Cnd1Q,350
fpstreams/physical/async_plan.py,sha256=XF8Ra9ReHFNv18Ey_BHocwr1CDkYmSQ3IeUymuDPc8w,5423
fpstreams/physical/compiled.py,sha256=eHaqxVhj5UuT2m25Hyy5iEXwAH6zb0yFX3BhCUR8j_c,7633
fpstreams/physical/kernel_cache.py,sha256=T88hFTzmQp10zjj8uujRTO9cfNenYMn4nYQCh8fzAjs,1741
fpstreams/physical/plan.py,sha256=5lOWguS49sS2sTogWgiqNQiIu67E0botS4XCnSbzP_A,2868
fpstreams/physical/relational.py,sha256=HRtHPr1dsB7ZN1vvVPkBbBwZUIlv_ZvEq6wRY4zd3I8,11289
fpstreams/planning/__init__.py,sha256=gH6CY45G4k041ZHUVoVlQ2J29BIGXF3-4vlh3SNAEag,87
fpstreams/planning/arrow/__init__.py,sha256=enMcS63UIwXBw5lZf6TwsxYUY84taUbbWYWUGoW3E1Q,16882
fpstreams/planning/arrow/source.py,sha256=LvaCvH8RBytmwsli4vfFejHLE1E7K76ZKGOMKwr-cX4,2875
fpstreams/planning/async_.py,sha256=E2GJ8oNLpfFcMq6pd70gfYwLrgYQWTzagmg9456N-4k,18198
fpstreams/planning/async_utils.py,sha256=TzN1UMsjImXhrxfQxOaam4rM2EDGzOkAYLUGTJs4FD0,2953
fpstreams/planning/compiler.py,sha256=xVHVIP3r2-cQwLejXkFxD8XSfDoZTAnyUPD7BMQcXQE,16431
fpstreams/planning/explain.py,sha256=JYDQZl3IX1lcxlNuv33U7y0ozNQezu0ByBAEnAQVzNY,19112
fpstreams/planning/gather.py,sha256=uS0G9DzfZ5ur2nM627Ud2O271U2lCmEmFvoPVRdTxOM,13942
fpstreams/planning/lineage.py,sha256=rCWW3VYH4INGALWvMk7S27OuDkCOgCjnyin8w3A8zhA,12217
fpstreams/planning/logical.py,sha256=0VENtDtEWM7YC_NAp_NsLLrgwcf7f0mXWCYURpPCwjc,7914
fpstreams/planning/native.py,sha256=PpJ2MkdvEw4O47Q7JjJ23EaIIfjWegBC1-4QT0ESZkM,40906
fpstreams/planning/numpy.py,sha256=Pe5Dugf4Yju2o9LRFI2ibwMY6OJSNuAfy5L0U2yd270,17314
fpstreams/planning/pairs/__init__.py,sha256=qh2dQ-Hpw-Ofq2qaDzn0gSy5J-oxco4LbrQVmujnztE,1942
fpstreams/planning/pairs/i64_expression.py,sha256=LNSDHQvGtjgZfFEv-ZwwspakSDt0XcrYdOw3nlm9QNY,23315
fpstreams/planning/plan_cache.py,sha256=swusKtnau3ZKUN2Lf5zex-ZY3RvrIsmAi4SxFWzFQy0,2177
fpstreams/planning/relational/__init__.py,sha256=JDOx1VT1zXdcwiTyrF7EODzmMbrle7ZqR9TxW7kHCEQ,12667
fpstreams/planning/relational/specs.py,sha256=vZn0H7c_VNMFHMOXcygD9kUYALmTdW9eB1M-DMcEh5o,39127
fpstreams/planning/semantics/__init__.py,sha256=2KC9YcoCBqMFnH0mgc9VwID0TXl_CkkQDkTzOg3h75w,10928
fpstreams/planning/semantics/analysis.py,sha256=nhA5hBn4E_RMhGLVl8Zu7Fnec6mRT1mH_0iwEFTWQCo,37392
fpstreams/planning/source.py,sha256=XG_cBAlbCAlAd3GG6XWAt42em6w433zLfKNgRmADajU,14976
fpstreams/planning/sync.py,sha256=a9KhjlSJJEPvp4GyOCOPzWoCnmG9TebD0a-yEV6R_h0,8857
fpstreams/primitives/__init__.py,sha256=RFIL6GbVeIGhn5p4OVsKFMXypGXHWDln2EvjQpQP5Y4,187
fpstreams/primitives/option.py,sha256=n9HGKYVyPtA8PFpVuFQdDxlNxNZdA8bKwYigy2Ye86A,6430
fpstreams/primitives/result.py,sha256=Mx26tUtpWPsk-XEeCTwyf_fkKMl04M2bAFFJiEmBXfc,10130
fpstreams/py.typed,sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU,0
fpstreams/result.py,sha256=7-NaYEy85oxS0ihyuQr6LqQV5cTaBHyRpgnR2wqcwdE,173
fpstreams/runtime/__init__.py,sha256=xElimhde9ru3ji4kw4p1Dm0L4xTP2Yit9NqoC0pxxh8,746
fpstreams/runtime/_distinct.py,sha256=dNlkBo74ChziegJ_iRj8mBcuqPQVlLaCMD4th_HGFG4,4726
fpstreams/runtime/executor.py,sha256=XmzGqeXxJGiRXsnTx4-N2eXuIV-t63jFLnh-H6z5H2w,4693
fpstreams/runtime/failpoints.py,sha256=PfLxoqturtcOfIIYigqB2LpVnp1n8MRb4SsgC7bS3Wc,1412
fpstreams/runtime/files.py,sha256=jpJq_FeBWzK3jKlOg5-0NLSHFwh7Szj0fqbToMj7siA,5259
fpstreams/runtime/iterators.py,sha256=zmw3Kuf9ykHEJdNSiZpYXqx4yEKdU9S5340pBjJlcII,3728
fpstreams/runtime/limits.py,sha256=Q-va4j1SgVUT5L5xGEbspK49E2FzZK4zgg2FhKLIAa8,818
fpstreams/runtime/metrics.py,sha256=6VFk8X57sCQFvmoBRoowBJxAJW2n5rqXryMd94rTqIU,422
fpstreams/runtime/query.py,sha256=ych62yDkmKg_wkpbuMN_Lyx4GHBIxV6X9MClbP2Rego,4133
fpstreams/runtime/report.py,sha256=amF6gIscMxXy7VQXIYKksfrIDBBIs7iOrJfzfeLYzs8,12948
fpstreams/runtime/resources.py,sha256=MLfXLC5XQhKKzaSpDwAfiL6d7qsXylG7og0RDqArAMk,9652
fpstreams/runtime/spill.py,sha256=6lnleYtn8BsVzngkIqdkgGRYfT7sTAMRMwx1XNxAJfk,2020
fpstreams/runtime/tasks.py,sha256=fsEes0Ea9xJrBWse75mW-NJoGBJe3EvT1wqhb4QaaGA,14204
fpstreams/storage/__init__.py,sha256=NtsBYwlhQdJPdvilbVNFiGUQiHuLm32E2XRZDu11NBk,466
fpstreams/storage/checkpoint.py,sha256=MvDMt7Vy_rsKRTHWjxanlMM3_bwDagVNt2c_ZjupF0Q,7877
fpstreams/storage/codec.py,sha256=aMZpR07WPIRpV1buuRUHEh6Yt3XJO4qAHel2xb9Tb_E,4877
fpstreams/storage/spill_store.py,sha256=wI57_qJsIPyRgDP_IXe64u-IZZJbzDr8K1XHLFfxjdQ,11990
fpstreams/streams/__init__.py,sha256=KO3U3QHK9InYKCOheHCNCPeSTo1RrpapMmKYziaukx0,394
fpstreams/streams/_async_identity.py,sha256=QxG9k0Vp6TzUfHAQVqEAvPAy84QQKguxMl_cv9LxFJA,3501
fpstreams/streams/_terminals/__init__.py,sha256=AxlsheFYN6yCyywhCqPWOD3DCxzxiWiiloHYI2lYyc4,16110
fpstreams/streams/_terminals/reductions.py,sha256=9BD39GupA3w1a1_byejcfIkLlg5CDQYNZJXKq17UF50,20283
fpstreams/streams/_terminals/structural.py,sha256=2M_CMItnCMFuIZxHo8WsQvjDqlezzhmSVBqbkpoD8GM,44741
fpstreams/streams/_terminals/unique.py,sha256=elD4sq4cLTdBMfjTsHLt-7Xhj85KQBSbNVo0Hd7-g-g,23033
fpstreams/streams/async_flow.py,sha256=jpGUGkuhaaKGQUnFW5RNMsI4ArpGMGDA5HeyT0ynudk,67183
fpstreams/streams/async_terminals.py,sha256=RPvRyTdqx5dXWt1Nvra2zesQj6M9OjEXO5ubC3a5VBo,31038
fpstreams/streams/flow.py,sha256=ApX9prRcEX9gmdPuwxXUYWZIzPXWu1FLSr6k7V74OLI,71390
fpstreams/streams/flow_terminals.py,sha256=2jCZ3qAfHVRNZL0Y4jesPxcX4SZSOlspCXijmI7qDNQ,94210
fpstreams/streams/pairs.py,sha256=BKNcVIVt1XpItOJ5nH_yMA2sxrayyWV04_asbnV7dlw,21317
fpstreams/tabular/__init__.py,sha256=OOULy0Z4DB4l6uAeSE8glDSdpdlI6yMJei987oh2gG0,290
fpstreams/tabular/arrow.py,sha256=-10DaQzaNPukipP9u5D55g7iOI0XlNIZnVZ6cXTo8I4,43355
fpstreams/tabular/dataframe.py,sha256=8-kfHkO-SbfrDulTcUJ4W8svnDBPERXE7gNAJ7vd6zc,3987
fpstreams/tabular/factory.py,sha256=IaACjd_L9hVHkpvYv-_2TCOvITqApmufqrYhbCxk868,12253
fpstreams/tabular/grouped.py,sha256=FGxWfEvmqHkL1Ce4WdIVtu74cYE9KGtOndjapAUvf4U,4035
fpstreams/tabular/io/__init__.py,sha256=9t8rzVr21zjYLadwluyEXrXZcXLfrksd05n9F29eCys,31210
fpstreams/tabular/io/database.py,sha256=2Ap29wi1LZ28qWFWRfTidzuvnXPtLyM5Ky_NIQnnYyc,20887
fpstreams/tabular/io/text.py,sha256=ohTBjxyCwBTxlCzX7xBtse45V_FSdtuaXsY1Q6F8Y5E,17420
fpstreams/tabular/join.py,sha256=Lj0xtYaJBgzNFZKd70ttL0cN_3xYup393Jto5OtHzEM,36503
fpstreams/tabular/numpy.py,sha256=I4zgeqdNC15vVpxK87em8aHpUAfCt7YRdcHKjxiVmAU,25904
fpstreams/tabular/polars.py,sha256=duCvNN5vq0XO7cjgNCjlzJF5bGRLhhp5wDNfYycuG38,4636
fpstreams/tabular/records.py,sha256=wFgglWeSGmtruv8CGdJH_ceQkddDcFoV7JanFsWaXbk,4242
fpstreams/tabular/rows.py,sha256=UUkjWNM1X-PD0b9hau69MmE1kXq2FfXnISArY58FvTs,113083
fpstreams/tabular/spill.py,sha256=QfmLS_3u6rZSMrZENcJX36rCoyWm3vYxz2GIj9xSUpE,39092
fpstreams/tabular/spill_io.py,sha256=nZ9l9VyXlkmyEv38ila0LLS8MJPda3ytiBDjMQN5i74,16707
fpstreams/tabular/spill_limits.py,sha256=zmV1cz0NeZ3_NV4ZsUxsKfVQAbEt6wIBe_enNTR2CO0,4043
fpstreams/testing.py,sha256=tVkJIjal3dnsXIBZoeQg8WPkaGdz7OynHLW364PKQos,5104
fpstreams-2.5.0.dist-info/METADATA,sha256=0nuJywxOwAqfa4as8QKWKtKxKEiVzxo9e_5TIX9wq88,24849
fpstreams-2.5.0.dist-info/WHEEL,sha256=nv5WBZ27cxxDjIIqxBMqK2cOF025DwkFmqJGqL3SpXU,96
fpstreams-2.5.0.dist-info/licenses/LICENSE,sha256=L_GbSJLwGGPi9NAxsNhvNnnJQmBZRDiCiC7T5CnJND8,1089
fpstreams-2.5.0.dist-info/sboms/fpstreams-native.cyclonedx.json,sha256=8TLQCBZBCoAimCC158RP1uBcevB0o1IAHaWCR1aBxKs,16471
fpstreams-2.5.0.dist-info/RECORD,,
