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

Method align

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

Source from the content-addressed store, hash-verified

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