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

Method _lower

dask/dataframe/dask_expr/_expr.py:1013–1030  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

1011 return after
1012
1013 def _lower(self):
1014 overlapped = CreateOverlappingPartitions(self.frame, self.before, self.after)
1015
1016 return MapPartitions(
1017 overlapped,
1018 _overlap_chunk,
1019 self._meta,
1020 self.enforce_metadata,
1021 self.transform_divisions,
1022 self.clear_divisions,
1023 self.align_dataframes,
1024 None,
1025 None,
1026 self.token,
1027 self._kwargs,
1028 len(self.args[1:]),
1029 *self.args[1:],
1030 )
1031
1032
1033class CreateOverlappingPartitions(Expr):

Callers

nothing calls this directly

Calls 2

MapPartitionsClass · 0.85

Tested by

no test coverage detected