Method fuse

dask/dataframe/dask_expr/_expr.py:510–511 · view source on GitHub ↗

(self)

Source from the content-addressed store, hash-verified

508	return type(self)(self.frame[predicate], *self.operands[1:])
509
510	def fuse(self):
511	return optimize_blockwise_fusion(self)
512
513	def finalize_compute(self):
514	return FinalizeComputeDF(self)

_taskMethod · 0.45

test_fuse_tasks_keyFunction · 0.45

test_fuse_tasksFunction · 0.45

test_fuse_reject_multiple_outputsFunction · 0.45

test_fused_ensure_only_executed_onceFunction · 0.45

test_fused_dont_hold_in_memory_too_longFunction · 0.45

optimize_blockwise_fusionFunction · 0.85

test_fuse_tasks_keyFunction · 0.36

test_fuse_tasksFunction · 0.36

test_fuse_reject_multiple_outputsFunction · 0.36

test_fused_ensure_only_executed_onceFunction · 0.36

test_fused_dont_hold_in_memory_too_longFunction · 0.36