+ LV-j"^RIt^RIt^RIt^RIt^RIt^RIHt^RIHtH t ^RI H t ^RI H t ^RIHtHtHtHtRtRs!RR ] 4t]!R .RO4!R R ]P,44t!R R]4tR#)N)suppress)cached_propertywraps)parse_qs)AbstractFileSystem)"get_package_version_without_importinfer_storage_options mirror_fromtokenizec0a\S4V3Rl4pV#)c<S!V/VB# \d_pTP'ghTPvr0\T\4'd#RT9d\ \ P T4ThhRp?ii;i)zdoes not existN)OSErrorargs isinstancestrFileNotFoundErrorerrnoENOENT)rkwargs exceptionmessagefuncs*, m/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/fsspec/implementations/arrow.pywrapper wrap_exceptions..wrappersj (( ( >>>&^^NG'3'',<,G' g>IM s A4AA//A4)r)rrsf rwrap_exceptionsrs  4[   NcBaa]tRt^(toRtRtV3Rlt]R4t] R4t ] R4t RRlt RtR tR t]R 4t]R 4t]R 4t]RRl4t]RRl4t]RRl4t]RRl4t]R4t]R4tRV3RlltV3RltRtVtV;t#)ArrowFSWrapperzgFSSpec-compatible wrapper of pyarrow.fs.FileSystem. Parameters ---------- fs : pyarrow.fs.FileSystem /c J<\R4sWn\SV`!R/VBR#)pyarrowN)rPYARROW_VERSIONfssuper__init__)selfr%r __class__s&&,rr'ArrowFSWrapper.__init__3s">8 &  &  ## ""&&II,6611!!11F11rrrcFa]tRt^toRRltRt]R4tRtRt Vt R#)rNc ^W0nW@nWnW nV;VnVnW`nR#r,)r8rr%r blocksizerr)r(r%rr8rrrs&&&&&&,rr'ArrowFile.__init__s)   +55 rcV#r,r#r.s&r __enter__ArrowFile.__enter__s rczVPP4'dVPP4#R#r,)rrrWr.s&rrWArrowFile.sizes+ ;;   ! !;;##% %rc"VP4#r,)close)r(rs&*r__exit__ArrowFile.__exit__szz|r)rrr%rrr8rr,) rrrrr'rrrWrrr)rs@rrrs- rrcNaa]tRt^toRtRtRV3Rllt]R4tRt Vt V;t #)HadoopFileSystemzYA wrapper on top of the pyarrow.fs.HadoopFileSystem to connect it's interface with fsspechdfsc T<^RIHpV!VVVVVVR7p \S V` !RRV /VBR#)a Parameters ---------- host: str Hostname, IP or "default" to try to read from Hadoop config port: int Port to connect on, or default from Hadoop config if 0 user: str or None If given, connect as this username kerb_ticket: str or None If given, use this ticket for authentication replication: int set replication factor of file for write operations. default value is 3. extra_conf: None or dict Passed on to HadoopFileSystem )r)r3r4user kerb_ticket replication extra_confr%Nr#)rBrr&r') r(r3r4rrrrrrr%r)s &&&&&&&, rr'HadoopFileSystem.__init__s;6 0 ##!   )B)&)rc\V4p/pVPRR4'd VR,VR&VPRR4'd VR,VR&VPRR4'd VR,VR&VPRR4'dG\VR,4pVPRR4'd\VR,^,4VR&V#)r3Nusernamerr4 url_queryr)r getrr)r8r<outqueriess& r_get_kwargs_from_urls&HadoopFileSystem._get_kwargs_from_urls*s#D) 7764 f+CK 77:t $ $j/CK 7764 f+CK 77; % %s;/0G{{=$//%()?)B%CM" rr#)defaultrNNN) rrrrrr/r' staticmethodrrrrrs@@rrrs0-H%*N   rr)readseektellwritereadablewritablerr)rior]rfri contextlibr functoolsrr urllib.parser fsspec.specr fsspec.utilsrr r r rr$rIOBaserrr#rrrs~  ,!*$m1'm1`      0;~;r