MCPcopy Index your code
hub / github.com/dask/dask / _create_alignable_frame

Method _create_alignable_frame

dask/dataframe/dask_expr/_collection.py:2070–2081  ·  view source on GitHub ↗
(self, other, join="outer")

Source from the content-addressed store, hash-verified

2068 return new_collection(self.expr.rename_axis(mapper, index, columns, axis))
2069
2070 def _create_alignable_frame(self, other, join="outer"):
2071 if not is_dask_collection(other) and (
2072 is_series_like(other) or is_dataframe_like(other)
2073 ):
2074 if join in ("inner", "left"):
2075 npartitions = 1
2076 else:
2077 # We have to trigger alignment, otherwise pandas will add
2078 # the same values to every partition
2079 npartitions = 2
2080 other = from_pandas(other, npartitions=npartitions)
2081 return other
2082
2083 @derived_from(pd.DataFrame)
2084 def align(self, other, join="outer", axis=None, fill_value=None):

Callers 8

combine_firstMethod · 0.95
whereMethod · 0.95
maskMethod · 0.95
alignMethod · 0.95
_wrap_expr_opFunction · 0.80
methodFunction · 0.80
combineMethod · 0.80
combineMethod · 0.80

Calls 4

is_dask_collectionFunction · 0.90
is_series_likeFunction · 0.85
is_dataframe_likeFunction · 0.85
from_pandasFunction · 0.85

Tested by

no test coverage detected