diff options
Diffstat (limited to 'include/framework/reconstruction/TieringPolicy.h')
| -rw-r--r-- | include/framework/reconstruction/TieringPolicy.h | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/include/framework/reconstruction/TieringPolicy.h b/include/framework/reconstruction/TieringPolicy.h index 63be5fe..dce5c3c 100644 --- a/include/framework/reconstruction/TieringPolicy.h +++ b/include/framework/reconstruction/TieringPolicy.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,6 +26,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); @@ -49,15 +55,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::Append}); - return v; - } - private: level_index find_reconstruction_target(LevelVector &levels) const { level_index target_level = invalid_level_idx; |