| 1310 | |
| 1311 | |
| 1312 | class MemoryUsagePerPartition(Blockwise): |
| 1313 | _parameters = ["frame", "index", "deep"] |
| 1314 | _defaults = {"index": True, "deep": False} |
| 1315 | |
| 1316 | @staticmethod |
| 1317 | def operation(*args, **kwargs): |
| 1318 | if is_series_like(args[0]): |
| 1319 | return args[0]._constructor([total_mem_usage(*args, **kwargs)]) |
| 1320 | return args[0]._constructor_sliced([total_mem_usage(*args, **kwargs)]) |
| 1321 | |
| 1322 | def _divisions(self): |
| 1323 | return (None,) * (self.frame.npartitions + 1) |
| 1324 | |
| 1325 | |
| 1326 | class DropDuplicatesBlockwise(Blockwise): |
no outgoing calls
no test coverage detected