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