summaryrefslogtreecommitdiffstats
path: root/include/framework/reconstruction
diff options
context:
space:
mode:
Diffstat (limited to 'include/framework/reconstruction')
-rw-r--r--include/framework/reconstruction/BSMPolicy.h22
-rw-r--r--include/framework/reconstruction/LevelingPolicy.h22
-rw-r--r--include/framework/reconstruction/ReconstructionPolicy.h6
-rw-r--r--include/framework/reconstruction/TieringPolicy.h18
4 files changed, 34 insertions, 34 deletions
diff --git a/include/framework/reconstruction/BSMPolicy.h b/include/framework/reconstruction/BSMPolicy.h
index 9138bd1..4ceca9a 100644
--- a/include/framework/reconstruction/BSMPolicy.h
+++ b/include/framework/reconstruction/BSMPolicy.h
@@ -16,17 +16,17 @@
namespace de {
template <ShardInterface ShardType, QueryInterface<ShardType> QueryType>
-class BSMPolicy : ReconstructionPolicy<ShardType, QueryType> {
+class BSMPolicy : public ReconstructionPolicy<ShardType, QueryType> {
typedef std::vector<std::shared_ptr<InternalLevel<ShardType, QueryType>>>
LevelVector;
public:
- BSMPolicy(size_t scale_factor, size_t buffer_size)
- : m_scale_factor(scale_factor), m_buffer_size(buffer_size) {}
+ BSMPolicy(size_t buffer_size)
+ : m_scale_factor(2), m_buffer_size(buffer_size) {}
ReconstructionVector
- get_reconstruction_tasks(Epoch<ShardType, QueryType> *epoch,
- size_t incoming_reccnt) override {
+ get_reconstruction_tasks(const Epoch<ShardType, QueryType> *epoch,
+ size_t incoming_reccnt) const override {
ReconstructionVector reconstructions;
auto levels = epoch->get_structure()->get_level_vector();
@@ -44,7 +44,7 @@ public:
task.type = ReconstructionType::Merge;
for (level_index i = target_level; i > source_level; i--) {
- if (i < levels.size()) {
+ if (i < (level_index)levels.size()) {
task.add_shard({i, all_shards_idx}, levels[i]->get_record_count());
}
}
@@ -54,17 +54,17 @@ public:
}
ReconstructionTask
- get_flush_task(Epoch<ShardType, QueryType> *epoch) override {
+ get_flush_task(const Epoch<ShardType, QueryType> *epoch) const override {
return ReconstructionTask{
{{buffer_shid}}, 0, m_buffer_size, ReconstructionType::Flush};
}
private:
- level_index find_reconstruction_target(LevelVector &levels) {
+ level_index find_reconstruction_target(LevelVector &levels) const {
level_index target_level = 0;
- for (size_t i = 0; i < (level_index)levels.size(); i++) {
- if (levels[i].get_record_count() + 1 <= capacity(i)) {
+ for (level_index i = 0; i < (level_index)levels.size(); i++) {
+ if (levels[i]->get_record_count() + 1 <= capacity(i)) {
target_level = i;
break;
}
@@ -73,7 +73,7 @@ private:
return target_level;
}
- inline size_t capacity(level_index level) {
+ inline size_t capacity(level_index level) const {
return m_buffer_size * pow(m_scale_factor, level + 1);
}
diff --git a/include/framework/reconstruction/LevelingPolicy.h b/include/framework/reconstruction/LevelingPolicy.h
index 00f2cff..8bf5645 100644
--- a/include/framework/reconstruction/LevelingPolicy.h
+++ b/include/framework/reconstruction/LevelingPolicy.h
@@ -16,7 +16,7 @@
namespace de {
template <ShardInterface ShardType, QueryInterface<ShardType> QueryType>
-class LevelingPolicy : ReconstructionPolicy<ShardType, QueryType> {
+class LevelingPolicy : public ReconstructionPolicy<ShardType, QueryType> {
typedef std::vector<std::shared_ptr<InternalLevel<ShardType, QueryType>>>
LevelVector;
@@ -25,8 +25,8 @@ public:
: m_scale_factor(scale_factor), m_buffer_size(buffer_size) {}
ReconstructionVector
- get_reconstruction_tasks(Epoch<ShardType, QueryType> *epoch,
- size_t incoming_reccnt) override {
+ get_reconstruction_tasks(const Epoch<ShardType, QueryType> *epoch,
+ size_t incoming_reccnt) const override {
ReconstructionVector reconstructions;
auto levels = epoch->get_structure()->get_level_vector();
@@ -41,7 +41,7 @@ public:
for (level_index i = target_level; i > source_level; i--) {
size_t target_reccnt =
- (i < levels.size()) ? levels[i]->get_record_count() : 0;
+ (i < (level_index)levels.size()) ? levels[i]->get_record_count() : 0;
size_t total_reccnt = levels[i - 1]->get_record_count() + target_reccnt;
reconstructions.add_reconstruction(i - 1, i, total_reccnt,
@@ -52,29 +52,29 @@ public:
}
ReconstructionTask
- get_flush_task(Epoch<ShardType, QueryType> *epoch) override {
+ get_flush_task(const Epoch<ShardType, QueryType> *epoch) const override {
return ReconstructionTask{
- {{buffer_shid}}, 0, m_buffer_size, ReconstructionType::Flush};
+ {{buffer_shid}}, 0, m_buffer_size, ReconstructionType::Merge};
}
private:
- level_index find_reconstruction_target(LevelVector &levels) {
+ level_index find_reconstruction_target(LevelVector &levels) const {
level_index target_level = 0;
size_t incoming_records = m_buffer_size;
- for (size_t i = 0; i < (level_index)levels.size(); i++) {
- if (levels[i].get_record_count() + incoming_records < capacity(i)) {
+ for (level_index i = 0; i < (level_index)levels.size(); i++) {
+ if (levels[i]->get_record_count() + incoming_records < capacity(i)) {
target_level = i;
break;
}
- incoming_records = levels[i].get_record_count();
+ incoming_records = levels[i]->get_record_count();
}
return target_level;
}
- inline size_t capacity(level_index level) {
+ inline size_t capacity(level_index level) const {
return m_buffer_size * pow(m_scale_factor, level + 1);
}
diff --git a/include/framework/reconstruction/ReconstructionPolicy.h b/include/framework/reconstruction/ReconstructionPolicy.h
index 976091e..aa213df 100644
--- a/include/framework/reconstruction/ReconstructionPolicy.h
+++ b/include/framework/reconstruction/ReconstructionPolicy.h
@@ -23,8 +23,8 @@ class ReconstructionPolicy {
public:
ReconstructionPolicy() {}
- virtual ReconstructionVector get_reconstruction_tasks(Epoch<ShardType, QueryType> *epoch,
- size_t incoming_reccnt) = 0;
- virtual ReconstructionTask get_flush_task(Epoch<ShardType, QueryType> *epoch) = 0;
+ virtual ReconstructionVector get_reconstruction_tasks(const Epoch<ShardType, QueryType> *epoch,
+ size_t incoming_reccnt) const = 0;
+ virtual ReconstructionTask get_flush_task(const Epoch<ShardType, QueryType> *epoch) const = 0;
};
}
diff --git a/include/framework/reconstruction/TieringPolicy.h b/include/framework/reconstruction/TieringPolicy.h
index 120bcb5..71fe9ec 100644
--- a/include/framework/reconstruction/TieringPolicy.h
+++ b/include/framework/reconstruction/TieringPolicy.h
@@ -16,15 +16,15 @@
namespace de {
template <ShardInterface ShardType, QueryInterface<ShardType> QueryType>
-class TieringPolicy : ReconstructionPolicy<ShardType, QueryType> {
+class TieringPolicy : public ReconstructionPolicy<ShardType, QueryType> {
typedef std::vector<std::shared_ptr<InternalLevel<ShardType, QueryType>>> LevelVector;
public:
TieringPolicy(size_t scale_factor, size_t buffer_size)
: m_scale_factor(scale_factor), m_buffer_size(buffer_size) {}
ReconstructionVector
- get_reconstruction_tasks(Epoch<ShardType, QueryType> *epoch,
- size_t incoming_reccnt) override {
+ get_reconstruction_tasks(const Epoch<ShardType, QueryType> *epoch,
+ size_t incoming_reccnt) const override {
ReconstructionVector reconstructions;
auto levels = epoch->get_structure()->get_level_vector();
@@ -39,7 +39,7 @@ public:
for (level_index i = target_level; i > source_level; i--) {
size_t target_reccnt =
- (i < levels.size()) ? levels[i]->get_record_count() : 0;
+ (i < (level_index)levels.size()) ? levels[i]->get_record_count() : 0;
size_t total_reccnt = levels[i - 1]->get_record_count() + target_reccnt;
reconstructions.add_reconstruction(i - 1, i, total_reccnt,
@@ -50,17 +50,17 @@ public:
}
ReconstructionTask
- get_flush_task(Epoch<ShardType, QueryType> *epoch) override {
+ get_flush_task(const Epoch<ShardType, QueryType> *epoch) const override {
return ReconstructionTask{
{{buffer_shid}}, 0, m_buffer_size, ReconstructionType::Flush};
}
private:
- level_index find_reconstruction_target(LevelVector &levels) {
+ level_index find_reconstruction_target(LevelVector &levels) const {
level_index target_level = 0;
- for (size_t i = 0; i < (level_index) levels.size(); i++) {
- if (levels[i].get_shard_count() + 1 <= capacity()) {
+ for (level_index i = 0; i < (level_index) levels.size(); i++) {
+ if (levels[i]->get_shard_count() + 1 <= capacity()) {
target_level = i;
break;
}
@@ -69,7 +69,7 @@ private:
return target_level;
}
- inline size_t capacity() {
+ inline size_t capacity() const {
return m_scale_factor;
}