summaryrefslogtreecommitdiffstats
path: root/include/framework/reconstruction/FloodL0Policy.h
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2025-01-17 17:28:50 -0500
committerDouglas Rumbaugh <dbr4@psu.edu>2025-01-17 17:28:50 -0500
commit6c906c94e1eea6d4356b8c99b93da39029e8d95d (patch)
tree8c5cd0d5bc5186cf6f19b29a94d424224a1cde8e /include/framework/reconstruction/FloodL0Policy.h
parent77589d4cc82b766d2cf16294fab98a57f6579cb4 (diff)
downloaddynamic-extension-6c906c94e1eea6d4356b8c99b93da39029e8d95d.tar.gz
Progress
Diffstat (limited to 'include/framework/reconstruction/FloodL0Policy.h')
-rw-r--r--include/framework/reconstruction/FloodL0Policy.h11
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: