diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-04-09 10:55:27 -0400 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-04-09 10:55:27 -0400 |
| commit | 7440266737210c7979178d1747cc3d68594f364f (patch) | |
| tree | 47e7b6db037438adc14e81a2f4acd383411895f3 /benchmarks/include/file_util.h | |
| parent | 47c8864758399a83b5a80e2a8a31ea316b06505d (diff) | |
| download | dynamic-extension-7440266737210c7979178d1747cc3d68594f364f.tar.gz | |
Disabled early abort for point lookups
I'm having some trouble getting "bad" query performance,
so I'm going to try using PLs w/o early abort as a
worst-case scenario. This should get the best per-shard
performance scaling
Diffstat (limited to 'benchmarks/include/file_util.h')
| -rw-r--r-- | benchmarks/include/file_util.h | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/benchmarks/include/file_util.h b/benchmarks/include/file_util.h index df8d999..a159dbe 100644 --- a/benchmarks/include/file_util.h +++ b/benchmarks/include/file_util.h @@ -10,6 +10,7 @@ #include <memory> #include <sstream> #include <string> +#include <type_traits> #include <vector> #include "psu-util/progress.h" @@ -73,6 +74,7 @@ static std::vector<QP> read_range_queries(std::string &fname, while (fscanf(qf, "%zu%zu%lf\n", &start, &stop, &sel) != EOF) { if (start < stop && std::abs(sel - selectivity) < 0.00001) { QP q; + q.lower_bound = start; q.upper_bound = stop; @@ -85,6 +87,30 @@ static std::vector<QP> read_range_queries(std::string &fname, } template <typename QP> +static std::vector<QP> read_sosd_point_lookups(std::string &fname, size_t n) { + std::vector<QP> queries; + + FILE *qf = fopen(fname.c_str(), "r"); + + if (!qf) { + fprintf(stderr, "ERROR: Failed to open file %s\n", fname.c_str()); + exit(EXIT_FAILURE); + } + + size_t start, stop; + double sel; + while (fscanf(qf, "%zu%zu%lf\n", &start, &stop, &sel) != EOF && queries.size() < n) { + QP q; + + q.search_key= start; + queries.push_back(q); + } + fclose(qf); + + return queries; +} + +template <typename QP> static std::vector<QP> read_binary_knn_queries(std::string fname, size_t k, size_t n) { std::vector<QP> queries; |