Skip to content

Commit 30d43b8

Browse files
fix rewriter bug
1 parent c0f4b6c commit 30d43b8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

bigframes/core/rewrite/sampling.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ def hash_based_sample(
9797
uniq_row_id = ops.RowHash().as_expr(
9898
ex.DerefOp(rowhash_col_id), ex.DerefOp(dupe_count_col_id), ex.const(seed)
9999
)
100-
result = nodes.ProjectionNode(root, ((uniq_row_id, unique_row_id_col_id),))
100+
result = nodes.ProjectionNode(result, ((uniq_row_id, unique_row_id_col_id),))
101101

102102
if fraction < 1:
103103
# The filtering is correlated with the ordering, but thats fine because the ordering is pseudo-random

0 commit comments

Comments
 (0)