ch!<SrSSKJrJr SSKJrJrJrJrJ r J r J r J r J r JrJr \r/rSSKJr SSKJr SSKJr SS KJrJrJrJrJrJ r J!r!J"r"J#r#J$r$ SS K%r%\%RL"\"5 S r'SS.Sjr(SSS.Sjjr)SSSS.Sjjr*"SS\ 5r+g !\a \R+S5 Nf=f!\a \R+S5 Nf=f!\a \R+S 5 Nf=f!\a \R+S 5 Nf=f)zO FileSystem abstraction to interact with various local and remote filesystems. ) _is_path_like_stringify_path) FileSelectorFileTypeFileInfo FileSystemLocalFileSystemSubTreeFileSystem_MockFileSystemFileSystemHandler PyFileSystem _copy_files_copy_files_selector)AzureFileSystemr)HadoopFileSystemr) GcsFileSystemr) AwsDefaultS3RetryStrategyAwsStandardS3RetryStrategy S3FileSystem S3LogLevelS3RetryStrategyensure_s3_initialized finalize_s3ensure_s3_finalized initialize_s3resolve_s3_regionNrcRU[;a[SUS35e[SUS35e)Nz8The pyarrow installation is not built with support for ''z&module 'pyarrow.fs' has no attribute ') _not_imported ImportErrorAttributeError)names ]C:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\pyarrow/fs.py __getattr__r$IsC } vQ    0a8 Fuse_mmapc [U[5(aU$[U[5(aU(a [S5e[R"U5up#UR U5nU(aqUR U/5SnUR[R:wa3[SURRSURSUS35e[XB5nU$SSK n[XR5(a6[U5RS:Xa [!US9$[#[%U55$[)S [U5S 35e![&a N$f=f) NzXSpecifying to use memory mapping not supported for filesystem specified as an URI stringrzWThe path component of the filesystem URI must point to a directory but it has a type: `z`. The path component is `z#` and the given filesystem URI is ``r r&zUnrecognized filesystem: zP. `filesystem` argument must be a FileSystem instance or a valid file system URI) isinstancerstr ValueErrorfrom_urinormalize_path get_file_infotyper Directoryr"pathr fsspecAbstractFileSystem__name__r r FSSpecHandlerr TypeError) filesystemr'fsr2prefix prefix_infor3s r#_ensure_filesystemr<Uso*j)) J $ $ 8 &&z2""4( **F84Q7K8#5#55 55@5E5E5J5J4KL%%0%5%5$67%,a) #6.B  ? *&?&?@@ #,,0AA*H==#M*$=>> A 'Z(8'9:B B     s#E EE) memory_mapc[U5(dUb [S5eX4$Ub^[XS9n[U[5(a [ U5nO [U[ 5(d [S5eURU5nX4$[ U5n[ US9nURU5nUR[R:gnU(d[R"U5upX4$URU5nX4$![a SnSnNGf=f![a#n[ U5nSU;dSU;aSnAO UeSnAff=fX4$)z Return filesystem/path from path which could be an URI or a plain filesystem path or a combination of fsspec protocol and URI. Nzg'filesystem' passed but the specified path is file-like, so there is nothing to open with 'filesystem'.r&zPExpected string path; path-like objects are only allowed with a local filesystemFz empty schemezCannot parse URI)rr,r<r*r rr+r7r.r/r0rNotFoundrr-)r2r8r= file_infoexists_locallyemsgs r#_resolve_filesystem_and_pathrDsv     !? ' H j/ 2 2"4(DD#&&* ((. 4 D !*5J?,,T2 $..H,=,==  )2248 J  ((.  /   a&C$(:c(A    s0C=D=D D D>D97D99D>iT) chunk_size use_threadsc[X5upg[X5upURU5n U R[R:Xa[ USS9n [ XkXXE5 g[XgXXE5 g)a Copy files between FileSystems. This functions allows you to recursively copy directories of files from one file system to another, such as from S3 to your local machine. Parameters ---------- source : string Source file path or URI to a single file or directory. If a directory, files will be copied recursively from this path. destination : string Destination file path or URI. If `source` is a file, `destination` is also interpreted as the destination file (not directory). Directories will be created as necessary. source_filesystem : FileSystem, optional Source filesystem, needs to be specified if `source` is not a URI, otherwise inferred. destination_filesystem : FileSystem, optional Destination filesystem, needs to be specified if `destination` is not a URI, otherwise inferred. chunk_size : int, default 1MB The maximum size of block to read before flushing to the destination file. A larger chunk_size will use more memory while copying but may help accommodate high latency FileSystems. use_threads : bool, default True Whether to use multiple threads to accelerate copying. Examples -------- Inspect an S3 bucket's files: >>> s3, path = fs.FileSystem.from_uri( ... "s3://registry.opendata.aws/roda/ndjson/") >>> selector = fs.FileSelector(path) >>> s3.get_file_info(selector) [>> fs.copy_files("s3://registry.opendata.aws/roda/ndjson/index.ndjson", ... f"file:///{local_path}/index_copy.ndjson") >>> fs.LocalFileSystem().get_file_info(str(local_path)+ ... '/index_copy.ndjson') Copy file using a FileSystem object: >>> fs.copy_files("registry.opendata.aws/roda/ndjson/index.ndjson", ... f"file:///{local_path}/index_copy.ndjson", ... source_filesystem=fs.S3FileSystem()) T recursiveN)rDr/r0rr1rrr) source destinationsource_filesystemdestination_filesystemrErF source_fs source_pathdestination_fsdestination_pathr@ source_sels r# copy_filesrSszp:I(D($N'' 4I~~+++!+> Y+' 6 I" -r%c\rSrSrSrSrSrSrSrSr \ S5r S r S r S rS rS rSrSrSrSrSrSrSrSrSrSrg)r6i z Handler for fsspec-based Python filesystems. https://filesystem-spec.readthedocs.io/en/latest/index.html Parameters ---------- fs : FSSpec-compliant filesystem instance Examples -------- >>> PyFileSystem(FSSpecHandler(fsspec_fs)) # doctest: +SKIP cXlgNr9)selfr9s r#__init__FSSpecHandler.__init__sr%cj[U[5(aURUR:H$[$rVr*r6r9NotImplementedrXothers r#__eq__FSSpecHandler.__eq__( e] + +77ehh& &r%cj[U[5(aURUR:g$[$rVr\r^s r#__ne__FSSpecHandler.__ne__ rbr%clURRn[U[5(aUSnSU3$)Nrzfsspec+)r9protocolr*list)rXrgs r# get_type_nameFSSpecHandler.get_type_name%s477## h % %{H ##r%cU$rVrXr2s r#r.FSSpecHandler.normalize_path+s r%c USnUSS:Xa[RnO,USS:Xa[RnSnO[Rn[ XX!R SS5S9$)Nsizer0file directorymtime)rprs)rFiler1Unknownrget)r2inforpftypes r#_create_file_infoFSSpecHandler._create_file_info.s_F| <6 !MME &\[ (&&ED$$E$hhw6MNNr%c/nUH?nURRU5nURURX455 MA U$![a- UR[ U[ R55 M{f=frV)r9rwappendryFileNotFoundErrorrrr?)rXpathsinfosr2rws r#r/FSSpecHandler.get_file_info;suD Aww||D) T33D?@  % @ XdH,=,=>? @sA  3BBc|URRUR5(dgURRUR5(a[ UR5eUR (a/$[ UR5eUR(aSnOSn/nURRURUSSS9nUR5HXupVURS5nURRS5nXx:wdM8URURXV55 MZ U$)NT)maxdepthwithdirsdetail/) r9isdirbase_direxistsNotADirectoryErrorallow_not_foundr}rIfinditemsstripr|ry) rXselectorrrselected_filesr2rw_pathrs r#get_file_info_selector$FSSpecHandler.get_file_info_selectorFsww}}X..//ww~~h//00():):;;++I+H,=,=>>   HH   4& )..0JDJJsOE((..s3H  T33D?@ 1 r%cXURRXS9 g![a gf=f)N)create_parents)r9mkdirFileExistsError)rXr2rIs r# create_dirFSSpecHandler.create_dircs+  GGMM$M 9   s  ))c8URRUSS9 gNTrH)r9rmrms r# delete_dirFSSpecHandler.delete_dirjs  44 (r%cnURRUSS9nUH|nURRU5(aURR USS9 M?URR U5(dMaURR U5 M~ g![a U(agef=f)NF)rTrH)r9listdirr}rrisfile)rXr2missing_dir_oksubpathssubpaths r#_delete_dir_contents"FSSpecHandler._delete_dir_contentsms wwtE:H  Gww}}W%% 7d 3(( 7#  !   sBB42B4cjURS5S:Xa [SUS5eURX5 g)Nrz$delete_dir_contents called on path 'r)rr,r)rXr2rs r#delete_dir_contents!FSSpecHandler.delete_dir_contentszs6 ::c?b 6cC C !!$7r%c&URS5 g)Nr)r)rXs r#delete_root_dir_contents&FSSpecHandler.delete_root_dir_contentss !!#&r%cURRU5(d [U5eURRU5 grV)r9rr}rrms r# delete_fileFSSpecHandler.delete_files2ww~~d###D) )  4r%c8URRXSS9 gr)r9mvrXsrcdests r#moveFSSpecHandler.moves  3 -r%c:URRX5 grV)r9copyrs r# copy_fileFSSpecHandler.copy_files  Sr%cSSKJn URRU5(d [ U5eU"URR USS9SS9$Nr PythonFilerbmoderpyarrowrr9rr}openrXr2rs r#open_input_streamFSSpecHandler.open_input_streamA&ww~~d###D) )$'',,t$,7cBBr%cSSKJn URRU5(d [ U5eU"URR USS9SS9$rrrs r#open_input_fileFSSpecHandler.open_input_filerr%cLSSKJn U"URRUSS9SS9$)Nrrwbrwrrr9rrXr2metadatars r#open_output_stream FSSpecHandler.open_output_stream#&$'',,t$,7cBBr%cLSSKJn U"URRUSS9SS9$)Nrrabrrrrs r#open_append_stream FSSpecHandler.open_append_streamrr%rWN)r5 __module__ __qualname____firstlineno____doc__rYr`rdrir. staticmethodryr/rrrrrrrrrrrrr__static_attributes__rlr%r#r6r6 s   $  O O :) $8 '. CCC Cr%r6rV)NN),r pyarrow.utilrr pyarrow._fsrrrrr r r r r rr FileStatsrpyarrow._azurefsrr r| pyarrow._hdfsrpyarrow._gcsfsr pyarrow._s3fsrrrrrrrrrratexitregisterr$r<rDrSr6rlr%r#rs2$8       ,0-.*, )LLL OO'( 05* Z9e9z?CH-&DH-VcC%cC{,*+, -+,- *)*)()sDBB4CC.B10B14C CC+*C+.DD