daft.DataFrame.iter_partitions

daft.DataFrame.iter_partitions#

DataFrame.iter_partitions() Iterator[Union[MicroPartition, ray.ObjectRef[MicroPartition]]][source]#

Begin executing this dataframe and return an iterator over the partitions.

Each partition will be returned as a daft.Table object (if using Python runner backend) or a ray ObjectRef (if using Ray runner backend).

Warning

This method is experimental and may change in future versions.