ray.data.DatasetPipeline.sum#

DatasetPipeline.sum() → int[source]#

Sum the records in the dataset pipeline.

This blocks until the entire pipeline is fully executed.

Time complexity: O(dataset size / parallelism)

Returns

The sum of the records in the dataset pipeline.