diff --git a/db/view/view_builder.hh b/db/view/view_builder.hh index f032099028..cd7c0e422a 100644 --- a/db/view/view_builder.hh +++ b/db/view/view_builder.hh @@ -189,6 +189,8 @@ public: static constexpr size_t batch_size = 128; static constexpr size_t batch_memory_max = 1024*1024; + replica::database& get_db() noexcept { return _db; } + public: view_builder(replica::database&, db::system_keyspace&, db::system_distributed_keyspace&, service::migration_notifier&, view_update_generator& vug); view_builder(view_builder&&) = delete; diff --git a/db/view/view_update_generator.hh b/db/view/view_update_generator.hh index 6b9c0cf5e7..dbc8fd9b7f 100644 --- a/db/view/view_update_generator.hh +++ b/db/view/view_update_generator.hh @@ -72,6 +72,8 @@ public: future<> stop(); future<> register_staging_sstable(sstables::shared_sstable sst, lw_shared_ptr table); + replica::database& get_db() noexcept { return _db; } + future<> mutate_MV( dht::token base_token, utils::chunked_vector view_updates,