MCPcopy Index your code
hub / github.com/dask/dask / MemoryUsageFrame

Class MemoryUsageFrame

dask/dataframe/dask_expr/_reductions.py:1494–1510  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1492
1493
1494class MemoryUsageFrame(MemoryUsage):
1495 _parameters = ["frame", "deep", "_index"]
1496 _defaults = {"deep": False, "_index": True}
1497
1498 @property
1499 def chunk_kwargs(self):
1500 return {"deep": self.deep, "index": self._index}
1501
1502 @property
1503 def combine_kwargs(self):
1504 return {"is_dataframe": is_dataframe_like(self.frame._meta)}
1505
1506 @staticmethod
1507 def reduction_combine(x, is_dataframe):
1508 if is_dataframe:
1509 return x.groupby(x.index).sum()
1510 return x.sum()
1511
1512
1513class TotalMemoryUsageFrame(MemoryUsageFrame):

Callers 2

memory_usageMethod · 0.90
memory_usageMethod · 0.90

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…