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

Method _recursive_join

dask/dataframe/dask_expr/_merge.py:936–956  ·  view source on GitHub ↗
(self, frames)

Source from the content-addressed store, hash-verified

934 return self._recursive_join(self.frames)
935
936 def _recursive_join(self, frames):
937 if len(frames) == 1:
938 return frames[0]
939
940 if len(frames) == 2:
941 return Merge(
942 frames[0],
943 frames[1],
944 how="outer",
945 left_index=True,
946 right_index=True,
947 )
948
949 midx = len(frames) // 2
950
951 return self._recursive_join(
952 [
953 self._recursive_join(frames[:midx]),
954 self._recursive_join(frames[midx:]),
955 ],
956 )

Callers 1

_lowerMethod · 0.95

Calls 1

MergeClass · 0.85

Tested by

no test coverage detected