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

Method _lower

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

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 2

MapPartitionsClass · 0.85

Tested by

no test coverage detected