Read/Scan¶

Read¶

paguro.read_parquet[M](source: FileSource, *, ...) → Dataset[M]

paguro.read_parquet(source: FileSource, *, ...) → Dataset[Any]

paguro.read_ipc[M](source, ...) → Dataset[M]

paguro.read_ipc(source, ...) → Dataset[Any]

paguro.read_avro[M](source, ...) → Dataset[M]

paguro.read_avro(source, ...) → Dataset[Any]

paguro.read_csv[M](source, ...) → Dataset[M]

paguro.read_csv(source, ...) → Dataset[Any]

paguro.read_database_uri[M](query: str, *, model, ...) → Dataset[M]

paguro.read_database_uri(query: str, *, model, ...) → Dataset[Any]

paguro.read_delta[M](source, ...) → Dataset[M]

paguro.read_delta(source, ...) → Dataset[Any]

paguro.read_json[M](source, ...) → Dataset[M]

paguro.read_json(source, ...) → Dataset[Any]

paguro.read_excel[M](source: FileSource, *, ...) → Dataset[M]

paguro.read_excel(source: FileSource, *, model, ...) → Dataset[Any]

paguro.read_ndjson[M](source, ...) → Dataset[M]

paguro.read_ndjson(source, ...) → Dataset[Any]

paguro.read_ods[M](source: FileSource, *, model, ...) → Dataset[M]

paguro.read_ods(source: FileSource, *, model, ...) → Dataset[Any]

Scan¶

paguro.scan_parquet[M](source: FileSource, *, ...) → LazyDataset[M]

paguro.scan_parquet(source: FileSource, *, ...) → LazyDataset[Any]

paguro.scan_ipc[M](source, ...) → LazyDataset[M]

paguro.scan_ipc(source, ...) → LazyDataset[Any]

paguro.scan_csv[M](source, ...) → LazyDataset[M]

paguro.scan_csv(source, ...) → LazyDataset[Any]

paguro.scan_delta[M](source, ...) → LazyDataset[M]

paguro.scan_delta(source, ...) → LazyDataset[Any]

paguro.scan_ndjson[M](source, ...) → LazyDataset[M]

paguro.scan_ndjson(source, ...) → LazyDataset[Any]

paguro.scan_iceberg[M](source: str | Table, ...) → LazyDataset[M]

paguro.scan_iceberg(source: str | Table, *, ...) → LazyDataset[Any]

paguro.scan_pyarrow_dataset[M](source, ...) → LazyDataset[M]

paguro.scan_pyarrow_dataset(source, ...) → LazyDataset[Any]

Metadata/Schema¶