Dataset.take_all(limit: Optional[int] = None) List[ray.data.block.T][source]#

Return all of the records in the dataset.

This will move the entire dataset to the caller’s machine; if the dataset is very large, this can result in an OutOfMemory crash on the caller.


This operation will trigger execution of the lazy transformations performed on this dataset, and will block until execution completes.

Time complexity: O(dataset size)


limit – Raise an error if the size exceeds the specified limit.


A list of all the records in the dataset.