MCPcopy Create free account
hub / github.com/dask/dask / combine

Method combine

dask/dataframe/dask_expr/_reductions.py:808–813  ·  view source on GitHub ↗
(cls, inputs: list, **kwargs)

Source from the content-addressed store, hash-verified

806
807 @classmethod
808 def combine(cls, inputs: list, **kwargs): # type: ignore
809 func = cls.reduction_combine or cls.reduction_aggregate or cls.reduction_chunk
810 df = _concat(inputs)
811 out = func(df, **kwargs) # type: ignore
812 # Return a dataframe so that the concatenated version is also a dataframe
813 return out.to_frame().T if is_series_like(out) else out
814
815 @classmethod
816 def aggregate(cls, inputs, **kwargs):

Callers

nothing calls this directly

Calls 4

_concatFunction · 0.90
is_series_likeFunction · 0.85
funcFunction · 0.50
to_frameMethod · 0.45

Tested by

no test coverage detected