Skip to content

Commit

Permalink
Add more pairs to test
Browse files Browse the repository at this point in the history
  • Loading branch information
Dtenwolde committed Nov 14, 2024
1 parent 6e8e4d6 commit 48a5217
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
1 change: 0 additions & 1 deletion src/core/operator/physical_path_finding_operator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,6 @@ GlobalBFSState::GlobalBFSState(shared_ptr<DataChunk> pairs_, CSR* csr_, int64_t
src = FlatVector::GetData<int64_t>(src_data);
dst = FlatVector::GetData<int64_t>(dst_data);
result.SetCapacity(pairs->size());
std::cout << pairs->size() << std::endl;

CreateTasks();
size_t number_of_threads_to_schedule = std::min(num_threads, (idx_t)global_task_queue.size());
Expand Down
7 changes: 6 additions & 1 deletion test/sql/path_finding/path_finding_snb.test
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,11 @@ create or replace table snb_many_pairs as (
from (select a.rowid as src from person a),
(select b.rowid as dst from person b)
using sample reservoir(2500 rows) repeatable (300)
UNION ALL
select src, dst
from (select a.rowid as src from person a),
(select b.rowid as dst from person b)
using sample reservoir(2500 rows) repeatable (300)
);

query I
Expand Down Expand Up @@ -57,4 +62,4 @@ SELECT cast(min(create_csr_edge(
JOIN person c on c.id = k.person2id)
Select count(*) from (SELECT src, dst, shortestpathoperator(src, dst, csr_id) FROM snb_many_pairs, csr_cte);
----
7500
10000

0 comments on commit 48a5217

Please sign in to comment.