diff options
Diffstat (limited to 'include/framework/reconstruction/BSMPolicy.h')
| -rw-r--r-- | include/framework/reconstruction/BSMPolicy.h | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/include/framework/reconstruction/BSMPolicy.h b/include/framework/reconstruction/BSMPolicy.h index c42b928..eaa374a 100644 --- a/include/framework/reconstruction/BSMPolicy.h +++ b/include/framework/reconstruction/BSMPolicy.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 { @@ -28,6 +28,12 @@ public: 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 reconstructions; auto levels = version->get_structure()->get_level_vector(); level_index target_level = find_reconstruction_target(levels); @@ -53,12 +59,6 @@ public: 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::Merge}); - } - private: level_index find_reconstruction_target(LevelVector &levels) const { level_index target_level = invalid_level_idx; |