| 1252 | |
| 1253 | |
| 1254 | class Count(Reduction): |
| 1255 | _parameters = ["frame", "numeric_only", "split_every"] |
| 1256 | _defaults = {"split_every": False, "numeric_only": False} |
| 1257 | reduction_chunk = M.count |
| 1258 | |
| 1259 | @classmethod |
| 1260 | def reduction_aggregate(cls, df): |
| 1261 | return df.sum().astype("int64") |
| 1262 | |
| 1263 | @property |
| 1264 | def chunk_kwargs(self): |
| 1265 | if self.frame._meta.ndim < 2: |
| 1266 | return dict() |
| 1267 | else: |
| 1268 | return dict(numeric_only=self.numeric_only) |
| 1269 | |
| 1270 | |
| 1271 | class IndexCount(Reduction): |