diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-01-27 18:17:21 -0500 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-01-27 18:17:21 -0500 |
| commit | 30da48151f58803968ca3ef5d42e66a9223d80a4 (patch) | |
| tree | 23cad3718bca116016caf5aba375a3eb3a490328 /include/framework/reconstruction/FloodL0Policy.h | |
| parent | f149a2459cfc2007f755d792b3c4e567d30c132f (diff) | |
| download | dynamic-extension-30da48151f58803968ca3ef5d42e66a9223d80a4.tar.gz | |
progress
Diffstat (limited to 'include/framework/reconstruction/FloodL0Policy.h')
| -rw-r--r-- | include/framework/reconstruction/FloodL0Policy.h | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/include/framework/reconstruction/FloodL0Policy.h b/include/framework/reconstruction/FloodL0Policy.h index 8304d8a..94bed70 100644 --- a/include/framework/reconstruction/FloodL0Policy.h +++ b/include/framework/reconstruction/FloodL0Policy.h @@ -11,7 +11,7 @@ #include <cmath> #include "framework/reconstruction/ReconstructionPolicy.h" -#include "framework/scheduling/Epoch.h" +#include "framework/scheduling/Version.h" #include "util/types.h" namespace de { @@ -26,17 +26,14 @@ public: ReconstructionVector get_reconstruction_tasks(const Version<ShardType, QueryType> *version, size_t incoming_reccnt) const override { - ReconstructionVector reconstructions; return reconstructions; - } ReconstructionVector get_flush_tasks(const Version<ShardType, QueryType> *version) const override { - ReconstructionVector v; - v.add_reconstruction(ReconstructionTask{ - {{buffer_shid}}, 0, m_buffer_size, ReconstructionType::Append}); + ReconstructionVector reconstructions; + return reconstructions; } private: |