File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -904,23 +904,13 @@ impl<'a> Pregel<'a> {
904904 // do so by performing an inner join between the `current_vertices` DataFrame and the
905905 // `vertex_columns` DataFrame. The join is performed on the `id` column of the
906906 // `current_vertices` DataFrame and the `id` column of the `vertex_columns` DataFrame.
907- let current_vertices_lf = vertices. to_owned ( ) . inner_join (
908- vertex_columns,
909- col ( Column :: Id . as_ref ( ) ) ,
910- col ( Column :: Id . as_ref ( ) ) ,
911- ) ;
912-
913- println ! (
914- "{}" ,
915- current_vertices_lf
916- . clone( )
917- . with_common_subplan_elimination( false )
918- . with_streaming( true )
919- . describe_optimized_plan( )
920- . unwrap( )
921- ) ;
922-
923- current_vertices = current_vertices_lf
907+ current_vertices = vertices
908+ . to_owned ( )
909+ . inner_join (
910+ vertex_columns,
911+ col ( Column :: Id . as_ref ( ) ) ,
912+ col ( Column :: Id . as_ref ( ) ) ,
913+ )
924914 . with_common_subplan_elimination ( false )
925915 . with_streaming ( true )
926916 . collect ( ) ?;
You can’t perform that action at this time.
0 commit comments