summaryrefslogtreecommitdiffstats
path: root/include/framework/reconstruction/BSMPolicy.h
diff options
context:
space:
mode:
Diffstat (limited to 'include/framework/reconstruction/BSMPolicy.h')
-rw-r--r--include/framework/reconstruction/BSMPolicy.h14
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;