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(...)

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([progress_bar, tqdm_kwargs])

Compute dask distributed dataframe to pandas dataframe.

Catalog.to_delayed()

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

Catalog.get_partition(order, pixel)

Get the partition for a given HEALPix pixel

Catalog.prune_empty_partitions()

Prunes the catalog of its empty partitions

Catalog.to_dask_dataframe([divisions])

Converts to a Dask DataFrame