Skip to content

Commit

Permalink
removing a print
Browse files Browse the repository at this point in the history
  • Loading branch information
angelip2303 committed May 26, 2023
1 parent 699ddd9 commit fa66b4e
Showing 1 changed file with 7 additions and 17 deletions.
24 changes: 7 additions & 17 deletions src/pregel.rs
Original file line number Diff line number Diff line change
Expand Up @@ -904,23 +904,13 @@ impl<'a> Pregel<'a> {
// do so by performing an inner join between the `current_vertices` DataFrame and the
// `vertex_columns` DataFrame. The join is performed on the `id` column of the
// `current_vertices` DataFrame and the `id` column of the `vertex_columns` DataFrame.
let current_vertices_lf = vertices.to_owned().inner_join(
vertex_columns,
col(Column::Id.as_ref()),
col(Column::Id.as_ref()),
);

println!(
"{}",
current_vertices_lf
.clone()
.with_common_subplan_elimination(false)
.with_streaming(true)
.describe_optimized_plan()
.unwrap()
);

current_vertices = current_vertices_lf
current_vertices = vertices
.to_owned()
.inner_join(
vertex_columns,
col(Column::Id.as_ref()),
col(Column::Id.as_ref()),
)
.with_common_subplan_elimination(false)
.with_streaming(true)
.collect()?;
Expand Down

0 comments on commit fa66b4e

Please sign in to comment.