Dataframe Methods

Dataframe Methods#

Catalog.map_rows(func[, columns, ...])

Takes a function and applies it to each top-level row of the Catalog.

Catalog.map_partitions(func, *args[, meta, ...])

Applies a function to each partition in the catalog and respective margin.

Catalog.write_catalog(base_catalog_path, *)

Save the catalog to disk in HATS format.

Catalog.compute()

Compute dask distributed dataframe to pandas dataframe

Catalog.to_delayed([optimize_graph])

Get a list of Dask Delayed objects for each partition in the dataset

Catalog.get_partition(order, pixel)

Get the dask partition for a given HEALPix pixel

Catalog.get_partition_index(order, pixel)

Get the dask partition for a given HEALPix pixel

Catalog.prune_empty_partitions([persist])

Prunes the catalog of its empty partitions

Catalog.to_dask_dataframe()

Convert the dataset to a Dask DataFrame.