iddlmZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z eje5ddlmZddderdd lmZddd  d d Zy#1swY!xYw) ) annotationsN)Path)IO TYPE_CHECKING)normalize_filepath)wrap_df)parse_columns_arg) PyDataFrame) DataFrame)columnsn_rowsct|ttfr t|}t |\}}t j ||||}t|S)a Read into a DataFrame from Apache Avro format. Parameters ---------- source Path to a file or a file-like object (by "file-like object" we refer to objects that have a `read()` method, such as a file handler like the builtin `open` function, or a `BytesIO` instance). For file-like objects, the stream position may not be updated accordingly after reading. columns Columns to select. Accepts a list of column indices (starting at zero) or a list of column names. n_rows Stop reading from Apache Avro file after reading `n_rows`. Returns ------- DataFrame ) isinstancestrrrr r read_avror)sourcer r projection column_namespydfs P/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/polars/io/avro.pyrrsK4&3+&#F+09J  z6 JD 4=)rzstr | Path | IO[bytes] | bytesr zlist[int] | list[str] | Noner z int | Nonereturnr ) __future__r contextlibpathlibrtypingrrpolars._utils.variousrpolars._utils.wraprpolars.io._utilsr suppress ImportError polars._plrr polarsr rrrr%s}"$4&.Z%('( -1  **    ((s A$$A-