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

Method align

dask/dataframe/dask_expr/_expr.py:411–421  ·  view source on GitHub ↗
(self, other, join="outer", axis=None, fill_value=None)

Source from the content-addressed store, hash-verified

409 return RenameAxis(self, mapper=mapper, index=index, columns=columns, axis=axis)
410
411 def align(self, other, join="outer", axis=None, fill_value=None):
412 from dask.dataframe.dask_expr._collection import new_collection
413
414 if not are_co_aligned(self, other):
415 aligned = AlignAlignPartitions(self, other, join, axis, fill_value)
416 else:
417 aligned = _Align(self, other, join, axis=axis, fill_value=fill_value)
418
419 return new_collection(AlignGetitem(aligned, position=0)), new_collection(
420 AlignGetitem(aligned, position=1)
421 )
422
423 def nunique_approx(self, split_every=None):
424 return NuniqueApprox(self, b=16, split_every=split_every)

Callers 7

test_alignFunction · 0.45
test_align_axisFunction · 0.45
test_alignFunction · 0.45
test_align_axisFunction · 0.45

Calls 5

new_collectionFunction · 0.90
are_co_alignedFunction · 0.85
_AlignClass · 0.85
AlignGetitemClass · 0.85

Tested by 7

test_alignFunction · 0.36
test_align_axisFunction · 0.36
test_alignFunction · 0.36
test_align_axisFunction · 0.36