diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-01-17 17:28:50 -0500 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-01-17 17:28:50 -0500 |
| commit | 6c906c94e1eea6d4356b8c99b93da39029e8d95d (patch) | |
| tree | 8c5cd0d5bc5186cf6f19b29a94d424224a1cde8e /include/framework/reconstruction/FloodL0Policy.h | |
| parent | 77589d4cc82b766d2cf16294fab98a57f6579cb4 (diff) | |
| download | dynamic-extension-6c906c94e1eea6d4356b8c99b93da39029e8d95d.tar.gz | |
Progress
Diffstat (limited to 'include/framework/reconstruction/FloodL0Policy.h')
| -rw-r--r-- | include/framework/reconstruction/FloodL0Policy.h | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/include/framework/reconstruction/FloodL0Policy.h b/include/framework/reconstruction/FloodL0Policy.h index da4c297..8304d8a 100644 --- a/include/framework/reconstruction/FloodL0Policy.h +++ b/include/framework/reconstruction/FloodL0Policy.h @@ -24,7 +24,7 @@ public: FloodL0Policy(size_t buffer_size) : m_buffer_size(buffer_size) {} ReconstructionVector - get_reconstruction_tasks(const Epoch<ShardType, QueryType> *epoch, + get_reconstruction_tasks(const Version<ShardType, QueryType> *version, size_t incoming_reccnt) const override { ReconstructionVector reconstructions; @@ -32,10 +32,11 @@ public: } - ReconstructionTask - get_flush_task(const Epoch<ShardType, QueryType> *epoch) const override { - return ReconstructionTask{ - {{buffer_shid}}, 0, m_buffer_size, ReconstructionType::Append}; + 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}); } private: |