Function optimize

dask/dataframe/dask_expr/_collection.py:4823–4824 · view source on GitHub ↗

(collection, fuse=True)

Source from the content-addressed store, hash-verified

4821
4822
4823	def optimize(collection, fuse=True):
4824	return new_collection(expr.optimize(collection.expr, fuse=fuse))
4825
4826
4827	def from_pandas(data, npartitions=None, sort=True, chunksize=None):

test_io_fusionFunction · 0.90

test_io_cullingFunction · 0.90

test_simpleFunction · 0.90

test_with_non_fusable_on_topFunction · 0.90

test_optimize_fusion_manyFunction · 0.90

test_optimize_fusion_repeatFunction · 0.90

test_optimize_fusion_broadcastFunction · 0.90

test_persist_with_fusionFunction · 0.90

test_nameFunction · 0.90

test_explode_simplifyFunction · 0.90

test_tail_downFunction · 0.90

test_partitionsFunction · 0.90

new_collectionFunction · 0.90

optimizeMethod · 0.45

test_io_fusionFunction · 0.72

test_io_cullingFunction · 0.72

test_simpleFunction · 0.72

test_with_non_fusable_on_topFunction · 0.72

test_optimize_fusion_manyFunction · 0.72

test_optimize_fusion_repeatFunction · 0.72

test_optimize_fusion_broadcastFunction · 0.72

test_persist_with_fusionFunction · 0.72

test_nameFunction · 0.72

test_explode_simplifyFunction · 0.72

test_tail_downFunction · 0.72

test_partitionsFunction · 0.72