summaryrefslogtreecommitdiffstats
path: root/benchmarks/include/file_util.h
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2025-04-09 10:55:27 -0400
committerDouglas Rumbaugh <dbr4@psu.edu>2025-04-09 10:55:27 -0400
commit7440266737210c7979178d1747cc3d68594f364f (patch)
tree47e7b6db037438adc14e81a2f4acd383411895f3 /benchmarks/include/file_util.h
parent47c8864758399a83b5a80e2a8a31ea316b06505d (diff)
downloaddynamic-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.h26
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;