diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-09-25 14:42:44 -0400 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-09-25 14:42:44 -0400 |
| commit | cf5f3bbb0cb58430ed68ad3ebfcefc009e553d71 (patch) | |
| tree | 4c17bc3169ee195c236cea9c9efda0aef7488e3c /include/query/pointlookup.h | |
| parent | 826c1fff5accbaa6b415acc176a5acbeb5f691b6 (diff) | |
| download | dynamic-extension-cf5f3bbb0cb58430ed68ad3ebfcefc009e553d71.tar.gz | |
Code reformatting
Diffstat (limited to 'include/query/pointlookup.h')
| -rw-r--r-- | include/query/pointlookup.h | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/include/query/pointlookup.h b/include/query/pointlookup.h index b42ec85..ab3d93f 100644 --- a/include/query/pointlookup.h +++ b/include/query/pointlookup.h @@ -40,7 +40,7 @@ public: typedef std::vector<Wrapped<R>> LocalResultType; typedef std::vector<R> ResultType; - + constexpr static bool EARLY_ABORT = false; constexpr static bool SKIP_DELETE_FILTER = true; @@ -58,7 +58,7 @@ public: return query; } - + static void distribute_query(Parameters *parms, std::vector<LocalQuery *> const &local_queries, LocalQueryBuffer *buffer_query) { @@ -76,7 +76,7 @@ public: return result; } - + static LocalResultType local_query_buffer(LocalQueryBuffer *query) { LocalResultType result; @@ -91,11 +91,9 @@ public: return result; } - - static void - combine(std::vector<LocalResultType> const &local_results, - Parameters *parms, ResultType &output) { + static void combine(std::vector<LocalResultType> const &local_results, + Parameters *parms, ResultType &output) { for (auto r : local_results) { if (r.size() > 0) { if (r[0].is_deleted() || r[0].is_tombstone()) { @@ -107,7 +105,7 @@ public: } } } - + static bool repeat(Parameters *parms, ResultType &output, std::vector<LocalQuery *> const &local_queries, LocalQueryBuffer *buffer_query) { |