B ÛT•\Öã@s^ddlmZmZmZddlmZddlZddlmZddlm Z Gdd „d e ƒZeejd <dS)é)Úprint_functionÚdivisionÚabsolute_import)ÚglobNé)Úcoreé)Útokenizec@sXeZdZdZejZdd„Zdd„Zdd„Zdd „Z ddd„Z d d„Zdd„Zdd„Z dS)ÚLocalFileSystemz«API spec for the methods a filesystem A filesystem must provide these methods, if it is to be registered as a backend for dask. Implementation for local disccKst ¡|_dS)z¢ Parameters ---------- storage_options: key-value May be credentials, or other configuration specific to the backend. N)ÚosÚgetcwdÚcwd)ÚselfZstorage_options©rú/lib/python3.7/site-packages/dask/bytes/local.pyÚ__init__szLocalFileSystem.__init__cCs(tj |¡stj |j|¡Stj |¡S)z(Ensure paths are absolute and normalized)rÚpathÚisabsÚjoinr Únormpath)rrrrrÚ_normalize_pathszLocalFileSystem._normalize_pathcCstt| |¡ƒƒS)z*For a template path, return matching files)Úsortedrr)rrrrrr"szLocalFileSystem.globcCsB| |¡}yt |¡Wn$tk r<tj |¡s8t‚YnXdS)z7Make any intermediate directories to make path writableN)rrÚmakedirsÚOSErrorrÚisdirÚAssertionError)rrrrrÚmkdirs&s zLocalFileSystem.mkdirsÚrbcKst| |¡|dS)agMake a file-like object Parameters ---------- mode: string normally "rb", "wb" or "ab" or other. kwargs: key-value Any other parameters, such as buffer size. May be better to set these on the filesystem instance, to apply to all files created by it. Not used for local. )Úmode)Úopenr)rrrÚkwargsrrrr.szLocalFileSystem.opencCs| |¡}t|t |¡jƒS)z3Unique identifier, so we can tell if a file changed)rr rÚstatÚst_mtime)rrrrrÚukey<s zLocalFileSystem.ukeycCst | |¡¡jS)z!Size in bytes of the file at path)rr!rÚst_size)rrrrrÚsizeAszLocalFileSystem.sizecCsddl}|jj ¡S)z$Get an equivalent pyarrow filesystemrN)ZpyarrowZ filesystemr Zget_instance)rZparrrÚ_get_pyarrow_filesystemEsz'LocalFileSystem._get_pyarrow_filesystemN)r)Ú__name__Ú __module__Ú__qualname__Ú__doc__rÚseprrrrrr#r%r&rrrrr s r Úfile) Z __future__rrrrrÚrÚbaser Úobjectr Z_filesystemsrrrrÚsA