From d36dd0c78e5f7c7795e17fec1beab46d64b5c835 Mon Sep 17 00:00:00 2001 From: Jay Chia Date: Mon, 28 Oct 2024 16:37:42 -0700 Subject: [PATCH] Rename to fanout_by_hash --- daft/execution/rust_physical_plan_shim.py | 2 +- src/daft-scheduler/src/scheduler.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/daft/execution/rust_physical_plan_shim.py b/daft/execution/rust_physical_plan_shim.py index 0abd8451bb..225fd13185 100644 --- a/daft/execution/rust_physical_plan_shim.py +++ b/daft/execution/rust_physical_plan_shim.py @@ -214,7 +214,7 @@ def sort( ) -def split_by_hash( +def fanout_by_hash( input: physical_plan.InProgressPhysicalPlan[PartitionT], num_partitions: int, partition_by: list[PyExpr], diff --git a/src/daft-scheduler/src/scheduler.rs b/src/daft-scheduler/src/scheduler.rs index 809eeb2cf7..9d0894d1d8 100644 --- a/src/daft-scheduler/src/scheduler.rs +++ b/src/daft-scheduler/src/scheduler.rs @@ -500,7 +500,7 @@ fn physical_plan_to_partition_tasks( py, "daft.execution.rust_physical_plan_shim" ))? - .getattr(pyo3::intern!(py, "split_by_hash"))? + .getattr(pyo3::intern!(py, "fanout_by_hash"))? .call1(( upstream_iter, hash_clustering_config.num_partitions,