diff --git a/sstables/sstable_set.cc b/sstables/sstable_set.cc index 3b5ddc7d8a..3727337a8a 100644 --- a/sstables/sstable_set.cc +++ b/sstables/sstable_set.cc @@ -25,6 +25,7 @@ #include "compatible_ring_position.hh" #include "compaction_strategy_impl.hh" #include "leveled_compaction_strategy.hh" +#include "time_window_compaction_strategy.hh" #include "sstable_set_impl.hh" @@ -530,6 +531,10 @@ std::unique_ptr leveled_compaction_strategy::make_sstable_set( return std::make_unique(std::move(schema)); } +std::unique_ptr time_window_compaction_strategy::make_sstable_set(schema_ptr schema) const { + return std::make_unique(std::move(schema)); +} + sstable_set make_partitioned_sstable_set(schema_ptr schema, lw_shared_ptr all, bool use_level_metadata) { return sstable_set(std::make_unique(schema, use_level_metadata), schema, std::move(all)); } diff --git a/sstables/time_window_compaction_strategy.hh b/sstables/time_window_compaction_strategy.hh index acf06d821a..3b50990b22 100644 --- a/sstables/time_window_compaction_strategy.hh +++ b/sstables/time_window_compaction_strategy.hh @@ -184,6 +184,8 @@ public: return compaction_strategy_type::time_window; } + virtual std::unique_ptr make_sstable_set(schema_ptr schema) const override; + virtual compaction_backlog_tracker& get_backlog_tracker() override { return _backlog_tracker; }