U
|
¬ý°dq£ ã @ sà d Z ddlmZ ddlmZmZ ddlZddlmZ ddl Z ddl
|
Z
|
ddl Z ddl m Z mZmZmZmZmZ ddlZddlZddlmZ ddlZddlZddlmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z% dd l&m'Z'm(Z)m*Z*m+Z+m,Z, ddl-Z-ddl.Z.dd
|
l/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7 dd l8m9Z9 dd l:m;Z; dd l<m=Z> ddl?m@Z@ ddlAmBZB ddlCmDZDmEZEmFZFmGZG ddlHmIZI ddlJmKZK eLe,e* e+ ZMeM Nd¡ e Od¡ZPe#de0dZQe jRG dd dZSe jRG dd de e ZTdd d d d ZUe%d d d!d"d#ZVe%ddd!d$d#ZVd%d%d!d&d#ZVdd'd(d)d*ZWe%dd,d d d-d.d/ZXe%ddd dd-d0d/ZXdd2d d%d-d3d/ZXd4d5 ZYd6d d d7d8ZZe@eKd9 eKd: d; d<dd6d d?d d@ddAdBdCZ[d d dDdEdFZ\dGdGdGdGdHdIdJdKdLdM Z]eLe] ^¡ Z_d?dNdOdPdQZ`e@eKd: d; dRd6dSdSdTdUdVZadWd'dDdXdYZbe%d+d+d+d+d+dZd6d dSd?d d[dSd@d\d] d^d_Zce%d+d+d+d+d+d+d`d6d dSd?d dadSd@dbd] dcd_Zce%d+d+d+d+d+d+d`d6d dSd?d d dSd@ddd] ded_Zce@eKd: df dRddd1dgddd`d6d dSd?d d dSd@ddd] dhd_ZcG didj djeeZdG dkdl dledZeG dmdn dnedZfG dodp dpZgG dqdr drZhdsd dtdudvdwZid6d d!dxdyZjd6d d dzd{d|Zke
|
jld}d~ddZmdddd ddd
Zndd ddddZodS )zCommon IO api utilitiesé )Ú annotations)ÚABCÚabstractmethodN)Ú defaultdict)ÚBufferedIOBaseÚBytesIOÚ RawIOBaseÚStringIOÚ
|
TextIOBaseÚ TextIOWrapper)ÚPath) ÚIOÚAnyÚAnyStrÚ DefaultDictÚGenericÚHashableÚLiteralÚMappingÚSequenceÚTypeVarÚcastÚoverload)ÚurljoinÚurlparseÚ uses_netlocÚ uses_paramsÚ uses_relative)Ú
|
BaseBufferÚCompressionDictÚCompressionOptionsÚFilePathÚ
|
ReadBufferÚ ReadCsvBufferÚStorageOptionsÚ WriteBuffer)Ú get_lzma_file)Úimport_optional_dependency)ÚBZ2File)Údoc)Úfind_stack_level)Úis_boolÚ is_file_likeÚ
|
is_integerÚ is_list_like)Ú
|
MultiIndex)Ú _shared_docsÚ z ^[A-Za-z][A-Za-z0-9+\-+.]*://Ú BaseBufferT)Úboundc @ s> e Zd ZU dZded< ded< ded< ded< d Zd
|
ed < d S ) ÚIOArgsz?
|
Return value of io/common.py:_get_filepath_or_buffer.
|
ústr | BaseBufferÚfilepath_or_bufferÚstrÚencodingÚmoder Ú compressionFÚboolÚ should_closeN)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú__annotations__r< © rB rB úGd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\pandas/io/common.pyr4 S s
|
r4 c @ sn e Zd ZU dZded< ded< ejedZded< d Z d
|
ed < d d ddZ
|
dd ddZ dd dddZ dS )Ú IOHandlesau
|
Return value of io/common.py:get_handle
|
|
Can be used as a context manager.
|
|
This is used to easily close created buffers and to handle corner cases when
|
TextIOWrapper is inserted.
|
|
handle: The file handle to be used.
|
created_handles: All file handles that are created by get_handle
|
is_wrapped: Whether a TextIOWrapper needs to be detached.
|
z
|
IO[AnyStr]Úhandler r: )Údefault_factoryzlist[IO[bytes] | IO[str]]Úcreated_handlesFr; Ú
|
is_wrappedÚNone©Úreturnc C s\ | j r8t| jtst| j ¡ | j ¡ | j | j¡ | jD ] }| ¡ q>g | _d| _ dS )zµ
|
Close all created buffers.
|
|
Note: If a TextIOWrapper was inserted, it is flushed and detached to
|
avoid closing the potentially user-created buffer.
|
FN)
|
rH Ú
|
isinstancerE r ÚAssertionErrorÚflushÚdetachrG ÚremoveÚclose)ÚselfrE rB rB rC rQ u s
|
|
|
|
zIOHandles.closezIOHandles[AnyStr]c C s | S ©NrB ©rR rB rB rC Ú __enter__ s zIOHandles.__enter__r )ÚargsrK c G s | ¡ d S rS )rQ )rR rV rB rB rC Ú__exit__ s zIOHandles.__exit__N) r= r> r? r@ rA Ú dataclassesÚfieldÚlistrG rH rQ rU rW rB rB rB rC rD ` s
|
rD Úobjectr; )ÚurlrK c C s t | tsdS t| jtkS )zÚ
|
Check to see if a URL has a valid protocol.
|
|
Parameters
|
----------
|
url : str or unicode
|
|
Returns
|
-------
|
isurl : bool
|
If `url` has a valid protocol return True otherwise False.
|
F)rL r7 Ú parse_urlÚschemeÚ _VALID_URLS©r\ rB rB rC Úis_url s
|
ra r7 )r6 rK c C s d S rS rB ©r6 rB rB rC Ú _expand_user s rc c C s d S rS rB rb rB rB rC rc ¤ s zstr | BaseBufferTc C s t | trtj | ¡S | S )a]
|
Return the argument with an initial component of ~ or ~user
|
replaced by that user's home directory.
|
|
Parameters
|
----------
|
filepath_or_buffer : object to be converted if possible
|
|
Returns
|
-------
|
expanded_filepath_or_buffer : an expanded filepath or the
|
input if not expandable
|
)rL r7 ÚosÚpathÚ
|
expanduserrb rB rB rC rc © s
|
rI )ÚheaderrK c C s | d kr d S t | r2tt| } | dk r.tdd S t| ddr|tt| } ttt | s^tdtdd | D rxtdd S t | rt
|
d tdd S )
|
Nr zUPassing negative integer to header is invalid. For no header, use header=None insteadF)Z
|
allow_setsz*header must be integer or list of integersc s s | ]}|d k V qdS )r NrB )Ú.0ÚirB rB rC Ú <genexpr>Ì s z&validate_header_arg.<locals>.<genexpr>z8cannot specify multi-index header with negative integerszPassing a bool to header is invalid. Use header=None for no header or header=int or list-like of ints to specify the row(s) making up the column names) r- r ÚintÚ
|
ValueErrorr. r ÚallÚmapÚanyr+ Ú TypeError)rg rB rB rC Úvalidate_header_arg¼ s*
|
ÿ
|
ÿrq .r! )r6 Úconvert_file_likerK c C s d S rS rB ©r6 rr rB rB rC Ústringify_pathÙ s rt c C s d S rS rB rs rB rB rC rt Þ s FzFilePath | BaseBufferTc C s2 |st | rtt| S t| tjr*| ¡ } t| S )aó
|
Attempt to convert a path-like object to a string.
|
|
Parameters
|
----------
|
filepath_or_buffer : object to be converted
|
|
Returns
|
-------
|
str_filepath_or_buffer : maybe a string version of the object
|
|
Notes
|
-----
|
Objects supporting the fspath protocol (python 3.6+) are coerced
|
according to its __fspath__ method.
|
|
Any other object is passed through unchanged, which includes bytes,
|
strings, buffers, or anything else that's not even path-like.
|
)r, r r2 rL rd ÚPathLikeÚ
|
__fspath__rc rs rB rB rC rt å s
|
|
c O s ddl }|jj| |S )z`
|
Lazy-import wrapper for stdlib urlopen, as that imports a big chunk of
|
the stdlib.
|
r N)Úurllib.requestÚrequestÚurlopen)rV ÚkwargsÚurllibrB rB rC ry s ry zFilePath | BaseBufferc C s$ t | to"tt | ¡o"| d¡ S )zR
|
Returns true if the given URL looks like
|
something fsspec can handle
|
)zhttp://zhttps://)rL r7 r; Ú_RFC_3986_PATTERNÚmatchÚ
|
startswithr` rB rB rC Ú is_fsspec_url s
|
|
ÿ
|
ýr Ústorage_optionsÚcompression_optionsr6 )r r úutf-8Úrr r$ )r6 r8 r: r9 r rK c C sÐ t | } t|\}}t| |}|rJt| drJd|krJtjdtt d d}t||d}d|kr|dkr|d krtj| d
|
| t t d |}d |kr¦d|kr¦|d7 }t
|
| t r.t | r.|pÂi }d dl }|jj| |d }t|2} | j dd¡}
|
|
|
dkrddi}t| ¡ } W 5 Q R X t| ||d|dS t| rXt
|
| t sHt| d¡r`| dd¡} | d¡rx| dd¡} td} g } z&td d dlm }m } ||t g} W n t k
|
rÀ Y nX z$| j | fd|i|pÚi ¡ }W n^ t!| k
|
rD |dkrddi}nt|}d|d< | j | fd|i|p6i ¡ }Y nX t|||d|dS |rft"dt
|
| t t#t$j$frtt%| ||d |dS t| d s¾t| ds¾d t&| }t"|t| ||d |dS ) a%
|
If the filepath_or_buffer is a url, translate and return the buffer.
|
Otherwise passthrough.
|
|
Parameters
|
----------
|
filepath_or_buffer : a url, filepath (str, py.path.local or pathlib.Path),
|
or buffer
|
{compression_options}
|
|
.. versionchanged:: 1.4.0 Zstandard support.
|
|
encoding : the encoding to use to decode bytes, default is 'utf-8'
|
mode : str, optional
|
|
{storage_options}
|
|
.. versionadded:: 1.2.0
|
|
..versionchange:: 1.2.0
|
|
Returns the dataclass IOArgs.
|
ÚwriteÚbzDcompression has no effect when passing a non-binary object as input.)Ú
|
stacklevelN)ÚmethodÚw)Úbz2Úxz)zutf-16zutf-32z( will not write the byte order mark for Útr )ÚheaderszContent-EncodingÚgzipr T)r6 r8 r: r< r9 zs3a://zs3://zs3n://ÚfsspecZbotocore)Ú ClientErrorÚNoCredentialsErrorr9 Zanonz?storage_options passed with file object or non-fsspec file pathFÚreadz)Invalid file path or buffer object type: )'rt Úget_compression_methodÚinfer_compressionÚhasattrÚwarningsÚwarnÚRuntimeWarningr* ÚdictÚUnicodeWarningrL r7 ra rw rx ÚRequestry r Úgetr r r4 r rM r~ Úreplacer' Zbotocore.exceptionsr r ÚPermissionErrorÚ ImportErrorÚopenÚtuplerl ÚbytesÚmmaprc Útype)r6 r8 r: r9 r Úcompression_methodZ fsspec_moder{ Zreq_infoÚreqÚcontent_encodingÚreaderr Z err_types_to_retry_with_anonr r Zfile_objÚmsgrB rB rC Ú_get_filepath_or_buffer sâ "
|
ý ÿþý ý
|
|
û
|
ÿ
|
ýÿÿÿ
|
|
ÿÿÿûÿû ÿÿûr© )re rK c C s ddl m} td|| S )z©
|
converts an absolute native path to a FILE URL.
|
|
Parameters
|
----------
|
path : a path in native format
|
|
Returns
|
-------
|
a valid FILE URL
|
r )Ú pathname2urlzfile:)rw rª r )re rª rB rB rC Úfile_path_to_urlÓ s r« Útarr r Úzipr Úzstd) ú.tarú.tar.gzú.tar.bz2ú.tar.xzú.gzú.bz2ú.zipú.xzz.zstz"tuple[str | None, CompressionDict])r: rK c
|
C s` t | trPt| }z| d¡}W qX tk
|
rL } ztd|W 5 d}~X Y qXX ni }| }||fS )a
|
Simplifies a compression argument to a compression method string and
|
a mapping containing additional arguments.
|
|
Parameters
|
----------
|
compression : str or mapping
|
If string, specifies the compression method. If mapping, value at key
|
'method' specifies compression method.
|
|
Returns
|
-------
|
tuple of ({compression method}, Optional[str]
|
{compression arguments}, Dict[str, Any])
|
|
Raises
|
------
|
ValueError on mapping missing 'method' key
|
r z.If mapping, compression must have key 'method'N)rL r r ÚpopÚKeyErrorrl )r: Úcompression_argsr¤ ÚerrrB rB rC r ó s
|
r )r ú
|
str | None)r6 r: rK c C s |dkr dS |dkrZt | dd} t| ts.dS t ¡ D ] \}}| ¡ |¡r6| S q6dS |tkrf|S ddgtt }d| d| }t |dS )a/
|
Get the compression method for filepath_or_buffer. If compression='infer',
|
the inferred compression method is returned. Otherwise, the input
|
compression method is returned unchanged, unless it's invalid, in which
|
case an error is raised.
|
|
Parameters
|
----------
|
filepath_or_buffer : str or file handle
|
File path or object.
|
{compression_options}
|
|
.. versionchanged:: 1.4.0 Zstandard support.
|
|
Returns
|
-------
|
string or None
|
|
Raises
|
------
|
ValueError on invalid compression specified.
|
NZinferT)rr ú Unrecognized compression type: z
|
Valid compression types are )
|
rt rL r7 Úextension_to_compressionÚitemsÚlowerÚendswithÚ_supported_compressionsÚsortedrl )r6 r: Ú extensionZvalidr¨ rB rB rC r s
|
|
ÿr z
|
Path | strc C s& t | j}| ¡ s"td| ddS )z±
|
Check if parent directory of a file exists, raise OSError if it does not
|
|
Parameters
|
----------
|
path: Path or str
|
Path to check parent directory of
|
z1Cannot save file into a non-existent directory: 'ú'N)r ÚparentÚis_dirÚOSError)re rÅ rB rB rC Úcheck_parent_directoryM s
|
rÈ )r8 r: Ú
|
memory_mapÚerrorsr zLiteral[False]zIOHandles[bytes]) Ú path_or_bufr9 r8 r: rÉ Úis_textrÊ r rK c C s d S rS rB ©rË r9 r8 r: rÉ rÌ rÊ r rB rB rC Ú
|
get_handle[ s rÎ )r8 r: rÉ rÌ rÊ r z Literal[True]zIOHandles[str]c C s d S rS rB rÍ rB rB rC rÎ j s z!IOHandles[str] | IOHandles[bytes]c C s d S rS rB rÍ rB rB rC rÎ y s rË Tc C s¼ |pd}|pd}t | |r*d|kr*|d7 }t |¡ t|trHt |¡ t| ||||d}|j} t| |\} }}
|
t| t} t |j
|
} | d¡}d|kr¦| r¦t t| |rP|dkrÆ|j dd ¡|_ n |dkræd|j kræ| j d7 _ |d
|
kr2t| trtjf | |j d | } ntjf | |j d | } n|d krVt| fd|j i| } nÞ|dkrÚt| |j f| } | jj dkr4|
|
| ¡ | j ¡ } t| dkr²| j | ¡ ¡} n$| sÈtd| ntd| nZ|dkr®| d|j ¡ t| trtf d| i| } ntf d| i| } t| ts4td| jj kr4|
|
| ¡ | j ¡ }t|dkr| j |d ¡}|dk st|} n$|std| ntd| n|dkrÈt | |j } nl|dkr"t d}d|j krød |j f | i}nd |j!f | i}|j| fd|j i|} nd | }t|t| trDt|
|
| ¡ nNt| tr|j"rd|j krt| |j |j"|d d } n t| |j } |
|
| ¡ d }|sÐ|j d!krÐt| t#rÐt$| |j"d"} n~|rN|sð|sðt | |j rNt%| d#rt%| d$rt%| d%s t&| } t'| |j"|d d } |
|
| ¡ t|jtpJ|j( }d|j kr|t%| d&s|t)d't*|j d(|
|
+¡ |j(rªt|jtrt|
|
|j¡ t,| |
|
||j
|
d)S )*a
|
Get file handle for given path/buffer and mode.
|
|
Parameters
|
----------
|
path_or_buf : str or file handle
|
File path or object.
|
mode : str
|
Mode to open path_or_buf with.
|
encoding : str or None
|
Encoding to use.
|
{compression_options}
|
|
.. versionchanged:: 1.0.0
|
May now be a dict with key 'method' as compression mode
|
and other keys as compression options if compression
|
mode is 'zip'.
|
|
.. versionchanged:: 1.1.0
|
Passing compression options as keys in dict is now
|
supported for compression modes 'gzip', 'bz2', 'zstd' and 'zip'.
|
|
.. versionchanged:: 1.4.0 Zstandard support.
|
|
memory_map : bool, default False
|
See parsers._parser_params for more information. Only used by read_csv.
|
is_text : bool, default True
|
Whether the type of the content passed to the file/buffer is string or
|
bytes. This is not the same as `"b" not in mode`. If a string content is
|
passed to a binary file/buffer, a wrapper is inserted.
|
errors : str, default 'strict'
|
Specifies how encoding and decoding errors are to be handled.
|
See the errors argument for :func:`open` for a full list
|
of options.
|
storage_options: StorageOptions = None
|
Passed to _get_filepath_or_buffer
|
|
.. versionchanged:: 1.2.0
|
|
Returns the dataclass IOHandles
|
r Ústrictr
)r8 r: r9 r r r r® r r1 r )Úfilenamer9 )Úfileobjr9 r r9 r é z Zero files found in ZIP file z9Multiple files found in ZIP file. Only one file per ZIP: r¬ ÚnamerÑ r Nz Zero files found in TAR archive zDMultiple files found in TAR archive. Only one file per TAR archive: r Ú zstandardZdctxZcctxr¼ )r8 rÊ ÚnewlineFÚrb)r8 ÚreadableÚwritableÚseekabler z1Expected file path name or file-like object, got z type)rE rG rH r: )-Ú_is_binary_modeÚcodecsÚlookuprL r7 Ú lookup_errorr© r6 Ú_maybe_memory_mapr r: r· rÈ r9 r r ÚGzipFileÚ_BZ2FileÚ _BytesZipFileÚbufferÚappendÚnamelistÚlenr rl Ú
|
setdefaultÚ _BytesTarFilerM ÚgetnamesÚ extractfiler& r' ÚZstdDecompressorZZstdCompressorr8 r
|
Ú_BytesIOWrapperr Ú
|
_IOWrapperr r< rp r£ ÚreverserD )rË r9 r8 r: rÉ rÌ rÊ r ZioargsrE ÚhandlesZis_pathr¹ Z zip_namesÚfilesÚfiler® Z open_argsr¨ rH rB rB rC rÎ s> 6
|
|
|
û
|
|
|
|
þýüû
|
|
ÿþý
|
|
ÿÿ
|
|
ÿ
|
ÿÿ
|
|
ÿ
|
|
ÿþý
|
û
|
þÿÿ
|
ÿÿþýü
|
ÿÿ ÷c s8 e Zd ZdZeddddZdd fdd Z ZS )Ú_BufferedWriterz
|
Some objects do not support multiple .write() calls (TarFile and ZipFile).
|
This wrapper writes to the underlying buffer on close.
|
rI rJ c C s d S rS rB rT rB rB rC Úwrite_to_buffer¦ s z _BufferedWriter.write_to_bufferc sP | j r
|
d S | ¡ r8| d¡ | j | ¡ W 5 Q R X n
|
| j ¡ t ¡ d S )Nr )ÚclosedÚgetvalueÚseekrâ rò rQ ÚsuperrT ©Ú __class__rB rC rQ ª s
|
|
z_BufferedWriter.close)r= r> r? r@ r rò rQ Ú __classcell__rB rB r÷ rC rñ s rñ c sX e Zd Zddddddd fdd Zd
|
d
|
d d d ZddddZddddZ ZS )rç Nr r» z Literal[('r', 'a', 'w', 'x')]z-ReadBuffer[bytes] | WriteBuffer[bytes] | NonerI )rÓ r9 rÑ Ú archive_namerK c s< t ¡ || _|| _tjjf || |¡|d|| _d S )N)rÓ r9 rÑ ) rö Ú__init__rú rÓ ÚtarfileÚTarFiler Ú extend_moderâ )rR rÓ r9 rÑ rú rz r÷ rB rC rû » s
|
ýüz_BytesTarFile.__init__r7 )r9 rK c C sP | dd¡}|dkr|S | jd k rLt| jj}|dkrL| d|dd
}|S )Nr
r1 r )r³ r¶ r´ ú:rÒ )r rÓ r Úsuffix)rR r9 r rB rB rC rþ Ð s
|
z_BytesTarFile.extend_moderJ c C sP | j dkrdS t| j }|jdkr.| d¡j S |jdkrJ| d¡ d¡j S |j S )z¶
|
If an explicit archive_name is not given, we still want the file inside the zip
|
file not to be named something.tar, because that causes confusion (GH39465).
|
Nr¯ r1 )r° r± r² )rÓ r r Ú with_suffix©rR rÐ rB rB rC Úinfer_filenameÚ s
|
|
|
|
z _BytesTarFile.infer_filenamec C s> | j p| ¡ pd}tj|d}t| ¡ |_| j || ¡ d S )Nr¬ ©rÓ ) rú r rü ÚTarInforå rô Úsizerâ Úaddfile)rR rú ÚtarinforB rB rC rò é s z _BytesTarFile.write_to_buffer)Nr NN)r= r> r? rû rþ r rò rù rB rB r÷ rC rç º s û
|
rç c sF e Zd Zdddddd fdd Zdd d
|
d Zdd d d Z ZS )rá Nz1FilePath | ReadBuffer[bytes] | WriteBuffer[bytes]r7 r» rI )rð r9 rú rK c s@ t ¡ | dd¡}|| _| dtj¡ tj||f|| _d S )Nr
r1 r: ) rö rû r rú ræ ÚzipfileÚ ZIP_DEFLATEDÚZipFilerâ )rR rð r9 rú rz r÷ rB rC rû ò s
|
|
z_BytesZipFile.__init__rJ c C s@ t | jjtjtfr<t| jj}|jdkr6| d¡j S |j S dS )z¶
|
If an explicit archive_name is not given, we still want the file inside the zip
|
file not to be named something.zip, because that causes confusion (GH39465).
|
rµ r1 N)
|
rL râ rÐ rd ru r7 r r r rÓ r rB rB rC r s
|
z _BytesZipFile.infer_filenamec C s( | j p| ¡ pd}| j || ¡ ¡ d S )Nr )rú r râ Úwritestrrô )rR rú rB rB rC rò s z _BytesZipFile.write_to_buffer)N)r= r> r? rû r rò rù rB rB r÷ rC rá ñ s ü rá c @ sT e Zd ZdddddZdddd Zd
|
d d d Zd
|
d ddZd
|
d ddZdS )rì r rI )râ rK c C s
|
|| _ d S rS )râ )rR râ rB rB rC rû s z_IOWrapper.__init__r7 r c C s t | j|S rS ©Úgetattrrâ )rR rÓ rB rB rC Ú __getattr__ s z_IOWrapper.__getattr__r; rJ c C s t | jdr| j ¡ S dS )Nr× T)r râ r× rT rB rB rC r× " s
|
z_IOWrapper.readablec C s t | jdr| j ¡ S dS )NrÙ T)r râ rÙ rT rB rB rC rÙ ' s
|
z_IOWrapper.seekablec C s t | jdr| j ¡ S dS )NrØ T)r râ rØ rT rB rB rC rØ , s
|
z_IOWrapper.writableN)r= r> r? rû r r× rÙ rØ rB rB rB rC rì s
|
rì c @ s@ e Zd ZdddddddZddd d
|
Zdd d dddZdS )rë r zStringIO | TextIOBaser7 rI )râ r8 rK c C s || _ || _d| _d S )Nó )râ r8 Úoverflow)rR râ r8 rB rB rC rû 5 s z_BytesIOWrapper.__init__)Úattrc C s t | j|S rS r )rR r rB rB rC r > s z_BytesIOWrapper.__getattr__éÿÿÿÿz
|
int | Noner¡ )ÚnrK c C st | j d k st| j |¡ | j¡}| j| }|d ksH|dk sH|t|krRd| _|S |d |
}||d
| _|S d S )Nr r )râ rM r Úencoder8 r rå )rR r Z
|
bytestringZcombined_bytestringZ to_returnrB rB rC r A s
|
z_BytesIOWrapper.readN)r )r )r= r> r? rû r r rB rB rB rC rë 2 s rë r5 z/tuple[str | BaseBuffer, bool, list[BaseBuffer]])rE rÉ rK c C s g }|t | dpt| tM }|s*| ||fS tt| } t| trRt| d} | | ¡ z t t
|
j
|
| ¡ dt
|
j d}W 5 t|D ] } | ¡ qzX |||gfS )z Try to memory map file/buffer.ÚfilenorÖ r )Úaccess) r rL r7 r r# r rã ÚreversedrQ rì r¢ r Z ACCESS_READ)rE rÉ rî ÚwrappedrB rB rC rÞ O s&
|
|
|
|
|
ÿÿ rÞ c C sH d}t | } t| ts|S ztj | ¡}W n ttfk
|
rB Y nX |S )zTest whether file exists.F)rt rL r7 rd re Úexistsrp rl )r6 r rB rB rC Ú file_existsq s
|
r )rE r9 rK c C sV d|ksd|krd|kS t jt jt jf}tt| |r:dS t| t pTdt| d|kS )z+Whether the handle is opened in binary moder r
Fr9 ) rÛ Ú StreamWriterÚ StreamReaderÚStreamReaderWriterÚ
|
issubclassr£ rL Ú_get_binary_io_classesr )rE r9 Z text_classesrB rB rC rÚ s ü ÿrÚ ztuple[type, ...]rJ c C sH t tf} tddd}|dk rD| ¡ d¡}| t|f7 } W 5 Q R X | S )z!IO classes that that expect bytesrÔ Úignore)rÊ Nr )r r r' rê Z stream_readerr£ )Zbinary_classesr® r§ rB rB rC r s r z Sequence[Hashable] | MultiIndexzbool | Sequence[int] | None)ÚcolumnsÚ index_colrK c sD dkst trg tt| o@t | t o@t fdd| D S )a¥
|
Check whether or not the `columns` parameter
|
could be converted into a MultiIndex.
|
|
Parameters
|
----------
|
columns : array-like
|
Object which may or may not be convertible into a MultiIndex
|
index_col : None, bool or list, optional
|
Column or columns to use as the (possibly hierarchical) index
|
|
Returns
|
-------
|
bool : Whether or not columns could become a MultiIndex
|
Nc 3 s$ | ] }|t krt|tV qd S rS )rZ rL r )rh Úc©r# rB rC rj ¿ s z+is_potential_multi_index.<locals>.<genexpr>)rL r; rå r/ rm )r" r# rB r% rC Úis_potential_multi_index¦ s
|
ÿýr& zSequence[Hashable])ÚnamesÚis_potential_multiindexrK c C s¢ t | } tt}t| D ]\}}|| }|dkr|d ||< |rpt|tsNt|dd
|d d| f }n| d| }|| }q(|| |< |d ||< q| S )a:
|
Rename column names if duplicates exist.
|
|
Currently the renaming is done by appending a period and an autonumeric,
|
but a custom pattern may be supported in the future.
|
|
Examples
|
--------
|
>>> dedup_names(["x", "y", "x", "x"], is_potential_multiindex=False)
|
['x', 'y', 'x.1', 'x.2']
|
r rÒ Nr Ú.)rZ r rk Ú enumeraterL r rM )r' r( Úcountsri ÚcolZ cur_countrB rB rC Ú dedup_namesà s "
|
r- ).).)F)r Nr N)N)pr@ Ú
|
__future__r Úabcr r rÛ Ú collectionsr rX Ú functoolsr Úior r r r r
|
r r¢ rd Úpathlibr Úrerü Útypingr r r r r r r r r r r r Ú urllib.parser r r] r r r r r Zpandas._typingr r r r! r" r# r$ r% Z pandas.compatr& Zpandas.compat._optionalr' Zpandas.compat.compressorsr( rà Zpandas.util._decoratorsr) Zpandas.util._exceptionsr* Zpandas.core.dtypes.commonr+ r, r- r. Zpandas.core.indexes.apir/ Zpandas.core.shared_docsr0 Úsetr_ ÚdiscardÚcompiler| r2 Z dataclassr4 rD ra rc rq rt ry r r© r« r½ ÚvaluesrÁ r r rÈ rÎ rñ rç rá rì rë rÞ r rÚ Ú lru_cacher r& r- rB rB rB rC Ú<module> sô 8 (
|
|
|
, ÿ þ"
|
|
þ û 3÷ #6÷$÷$÷$÷$ 7$ " þ
|
