FM / __pycache_

/usr/local/lib/python3.6/site-packages/fsspec/__pycache__/

/usr/local/lib/python3.6/site-packages/fsspec/__pycache__

Name	Size	Mode	Actions
archive.cpython-36.pyc	2679	0644	edit dl rm
asyn.cpython-36.pyc	23250	0644	edit dl rm
caching.cpython-36.pyc	13325	0644	edit dl rm
callbacks.cpython-36.pyc	5927	0644	edit dl rm
compression.cpython-36.pyc	4645	0644	edit dl rm
config.cpython-36.pyc	2740	0644	edit dl rm
conftest.cpython-36.pyc	1361	0644	edit dl rm
core.cpython-36.pyc	20234	0644	edit dl rm
dircache.cpython-36.pyc	3292	0644	edit dl rm
exceptions.cpython-36.pyc	733	0644	edit dl rm
fuse.cpython-36.pyc	10110	0644	edit dl rm
gui.cpython-36.pyc	14214	0644	edit dl rm
mapping.cpython-36.pyc	8208	0644	edit dl rm
parquet.cpython-36.pyc	11181	0644	edit dl rm
registry.cpython-36.pyc	7621	0644	edit dl rm
spec.cpython-36.pyc	52248	0644	edit dl rm
transaction.cpython-36.pyc	3178	0644	edit dl rm
utils.cpython-36.pyc	14403	0644	edit dl rm
_version.cpython-36.pyc	464	0644	edit dl rm
__init__.cpython-36.pyc	1394	0644	edit dl rm

Edit: /usr/local/lib/python3.6/site-packages/fsspec/__pycache__/compression.cpython-36.pyc (4645B)

3 8%Eg�3@sdZddlmZddlmZddlZddlmZdd�Z de iZ d#d d �Zd$dd �Zeded�eded�yddl mZedejd�Wn0ek r�ddlmZeddd�d�YnXy,ddlmZeded�ededdd�Wnek �r�YnXy0ddlZedejddd�edejddd�Wnek �rFYnXGdd�de�ZyddlZejedeg�Wneefk �r�YnXyddlZedejjd�Wnek �r�YnXy"ddlZd%dd �Z ed!e d"�Wnek �r�YnXdS)&z9Helper functions for a standard streaming compression API�)�BZ2File)�ZipFileN)�AbstractBufferedFilecKs|S)N�)�file�mode�kwargsrr� file-like. Accepts an input file-like object, the target mode and kwargs. Returns a wrapped file-like object. extensions: (str, Iterable[str]) A file extension, or list of file extensions for which to infer this compression scheme. Eg. "gz". force: (bool) Force re-registration of compression type or extensions. Raises: ValueError: If name or extensions already registered, and not force. z&Duplicate compression registration: %sz-Duplicate compression file extension: %s (%s)N)� isinstance�str�compr� ValueError�fsspec�utils�compressions)�name�callback� extensions�force�extrrr �register_compressions r�rbcs|d|krJ|pd}t|fddi|��j|dd�}|jf�fdd� |_|St|��|dkrf�j�d}�j|fddi|��S) N�rrr�w)rcs|�p�j�S)N)�close)�closer)�zrr �>szunzip..r)r�openr�namelist)�infiler�filenamer�for)rr �unzip9sr$�zip�bz2)�igzip�gzip�gz)�GzipFilecKstfd|i|��S)N�fileobj)r*)�frrrr rVsr)�LZMAFile�lzma�xzT)rcs@eZdZ�fdd�Zd dd�Zddd�Zd d �Zdd�Z�ZS)� SnappyFilecsVddl}t�jfdd|jd�ddd�|��||_d|krH|j�|_n |j�|_dS)Nr�snappy�bi�ɚ;)�fs�pathr�sizer)r1�super�__init__�stripr!ZStreamDecompressor�codecZStreamCompressor)�selfr!rrr1)� __class__rr r7kszSnappyFile.__init__FcCs.|jjd�|jj|jj��}|jj|�dS)NrT)�buffer�seekr9Z add_chunk�readr!�write)r:�final�outrrr � _upload_chunkwszSnappyFile._upload_chunkrcCstd��dS)NzSnappyFile is not seekable)�NotImplementedError)r:�loc�whencerrr r=}szSnappyFile.seekcCsdS)NFr)r:rrr �seekable�szSnappyFile.seekablecCs|jj||�}|jj|�S)z*Get the specified set of bytes from remote)r!r>r9� decompress)r:�start�end�datarrr �_fetch_range�szSnappyFile._fetch_range)F)r) �__name__� __module__�__qualname__r7rBr=rFrK� __classcell__rr)r;r r0js r0r1�lz4cCs4d|krtj�}|j|�Stjdd�}|j|�SdS)Nr� )�level)�zstdZZstdDecompressor� stream_readerZZstdCompressorZ stream_writer)r!rZcctxrrr �zstandard_file�s rUrSZzst)F)rN)r)!�__doc__r&r�zipfilerZfsspec.utilsrZfsspec.specrr r rr$Zisalr'Z IGzipFile�ImportErrorr(r*r.r-Zlzmaffir0r1�compress� NameErrorZ lz4.framerP�framerZ zstandardrSrUrrrr �s^ '