ง q-Phิ ใ๓‚—ddlmZddlmZddlmZddlmZer ddlm Z ddl m Z eฆซddd œdd„ฆซZ dS)้)ฺ annotations)ฺ TYPE_CHECKING)ฺunstableฉฺ_scan_pyarrow_dataset)ฺ LazyFrame)ฺpyarrowTNฉฺallow_pyarrow_filterฺ batch_sizeฺsource๚pa.dataset.Datasetr ฺboolr ๚ int | Noneฺreturnrc๓&—t|||ฌฆซS)us Scan a pyarrow dataset. .. warning:: This functionality is considered **unstable**. It may be changed at any point without it being considered a breaking change. This can be useful to connect to cloud or partitioned datasets. Parameters ---------- source Pyarrow dataset to scan. allow_pyarrow_filter Allow predicates to be pushed down to pyarrow. This can lead to different results if comparisons are done with null values as pyarrow handles this different than polars does. batch_size The maximum row count for scanned pyarrow record batches. Warnings -------- This method can only can push down predicates that are allowed by PyArrow (e.g. not the full Polars API). If :func:`scan_parquet` works for your source, you should use that instead. Notes ----- When using partitioning, the appropriate `partitioning` option must be set on `pyarrow.dataset.dataset` before passing to Polars or the partitioned-on column(s) may not get passed to Polars. Examples -------- >>> import pyarrow.dataset as ds >>> dset = ds.dataset("s3://my-partitioned-folder/", format="ipc") # doctest: +SKIP >>> ( ... pl.scan_pyarrow_dataset(dset) ... .filter("bools") ... .select("bools", "floats", "date") ... .collect() ... ) # doctest: +SKIP shape: (1, 3) โ”Œโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ฌโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ฌโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ” โ”‚ bools โ”† floats โ”† date โ”‚ โ”‚ --- โ”† --- โ”† --- โ”‚ โ”‚ bool โ”† f64 โ”† date โ”‚ โ•žโ•โ•โ•โ•โ•โ•โ•โ•ชโ•โ•โ•โ•โ•โ•โ•โ•โ•ชโ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•ก โ”‚ true โ”† 2.0 โ”† 1970-05-04 โ”‚ โ””โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ดโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ดโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”˜ r r)r r r s ๚c/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/polars/io/pyarrow_dataset/functions.pyฺscan_pyarrow_datasetr s%€๕v !ุุ1ุ๐ ๑ ๔ ๐๓)r rr rr rrr)ฺ __future__rฺtypingrฺpolars._utils.unstablerฺ(polars.io.pyarrow_dataset.anonymous_scanrฺpolarsrฺpolars.dependenciesr ฺparฉrr๚rsป๐ุ"ะ"ะ"ะ"ะ"ะ"เ ะ ะ ะ ะ ะ เ+ะ+ะ+ะ+ะ+ะ+ุJะJะJะJะJะJเ๐2ุ ะ ะ ะ ะ ะ ุ1ะ1ะ1ะ1ะ1ะ1๐ €„๐"&ุ!๐ >๐>๐>๐>๐>๑ „๐>๐>๐>r