| 2549 | |
| 2550 | @derived_from(pd.Series) |
| 2551 | def dot(self, other, meta=no_default): |
| 2552 | if not isinstance(other, FrameBase): |
| 2553 | raise TypeError("The second operand must be a dask dataframe") |
| 2554 | |
| 2555 | if isinstance(other, DataFrame): |
| 2556 | s = self.map_partitions(M.dot, other, meta=meta) |
| 2557 | return s.groupby(by=s.index).apply( |
| 2558 | lambda x: x.sum(skipna=False), meta=s._meta_nonempty |
| 2559 | ) |
| 2560 | |
| 2561 | return self.map_partitions(_dot_series, other, meta=meta).sum(skipna=False) |
| 2562 | |
| 2563 | @derived_from(pd.DataFrame) |
| 2564 | def pipe(self, func, *args, **kwargs): |