q-PhddlmZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z eje5ddlmZdddn #1swxYwYerdd lmZddd ddZdS)) annotationsN)Path)IO TYPE_CHECKING)normalize_filepath)wrap_df)parse_columns_arg) PyDataFrame) DataFrame)columnsn_rowssourcestr | Path | IO[bytes] | bytesr list[int] | list[str] | Noner int | Nonereturnr ct|ttfrt|}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)rr r projection column_namespydfs N/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/polars/io/avro.pyrrs[4&3+&&,#F++099J  z6 J JD 4==)rrr rr rrr ) __future__r contextlibpathlibrtypingrrpolars._utils.variousrpolars._utils.wraprpolars.io._utilsr suppress ImportError polars.polarsr polarsr rrrr(sI""""""$$$$$$$$444444&&&&&&......Z%%**))))))***************!      -1 sAAA