1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include "isummaryadapter.h"
#include "matchers.h"
#include "matchview.h"
#include "searchable_feed_view.h"
#include "searchview.h"
#include <vespa/searchcore/proton/attribute/i_attribute_writer.h>
#include <vespa/searchcore/proton/docsummary/summarymanager.h>
#include <vespa/searchcore/proton/index/i_index_writer.h>
#include <vespa/searchcore/proton/reprocessing/i_reprocessing_initializer.h>
#include <vespa/searchsummary/config/config-juniperrc.h>
#include <vespa/searchcommon/common/schema.h>
#include <vespa/config-attributes.h>
#include <vespa/config-indexschema.h>
#include <vespa/config-rank-profiles.h>
#include <vespa/config-summary.h>
#include <vespa/vespalib/util/varholder.h>
#include <vespa/searchcore/proton/reference/i_document_db_reference_resolver.h>
namespace proton::matching {
class RankingExpressions;
class OnnxModels;
}
namespace proton {
class DocumentSubDBReconfig;
struct IDocumentDBReferenceResolver;
class ReconfigParams;
/**
* Class used to reconfig the feed view and search view used in a searchable sub database.
*/
class SearchableDocSubDBConfigurer
{
private:
using SearchViewHolder = vespalib::VarHolder<SearchView::SP>;
using FeedViewHolder = vespalib::VarHolder<SearchableFeedView::SP>;
const ISummaryManager::SP &_summaryMgr;
SearchViewHolder &_searchView;
FeedViewHolder &_feedView;
matching::QueryLimiter &_queryLimiter;
const vespalib::eval::ConstantValueFactory& _constant_value_factory;
const vespalib::Clock &_clock;
vespalib::string _subDbName;
uint32_t _distributionKey;
void reconfigureFeedView(IAttributeWriter::SP attrWriter,
search::index::Schema::SP schema,
std::shared_ptr<const document::DocumentTypeRepo> repo);
void reconfigureMatchView(const searchcorespi::IndexSearchable::SP &indexSearchable);
void reconfigureMatchView(const Matchers::SP &matchers,
const searchcorespi::IndexSearchable::SP &indexSearchable,
const IAttributeManager::SP &attrMgr);
void reconfigureSearchView(MatchView::SP matchView);
void reconfigureSearchView(ISummaryManager::ISummarySetup::SP summarySetup, MatchView::SP matchView);
public:
SearchableDocSubDBConfigurer(const SearchableDocSubDBConfigurer &) = delete;
SearchableDocSubDBConfigurer & operator = (const SearchableDocSubDBConfigurer &) = delete;
SearchableDocSubDBConfigurer(const ISummaryManager::SP &summaryMgr,
SearchViewHolder &searchView,
FeedViewHolder &feedView,
matching::QueryLimiter &queryLimiter,
const vespalib::eval::ConstantValueFactory& constant_value_factory,
const vespalib::Clock &clock,
const vespalib::string &subDbName,
uint32_t distributionKey);
~SearchableDocSubDBConfigurer();
Matchers::SP createMatchers(const DocumentDBConfig& new_config_snapshot);
void reconfigureIndexSearchable();
std::unique_ptr<DocumentSubDBReconfig> prepare_reconfig(const DocumentDBConfig& new_config_snapshot, const DocumentDBConfig& old_config_snapshot, const ReconfigParams& reconfig_params, std::optional<search::SerialNum> serial_num);
void reconfigure(const DocumentDBConfig &newConfig,
const DocumentDBConfig &oldConfig,
const ReconfigParams ¶ms,
IDocumentDBReferenceResolver &resolver,
const DocumentSubDBReconfig& prepared_reconfig,
search::SerialNum serial_num);
IReprocessingInitializer::UP
reconfigure(const DocumentDBConfig &newConfig,
const DocumentDBConfig &oldConfig,
AttributeCollectionSpec && attrSpec,
const ReconfigParams ¶ms,
IDocumentDBReferenceResolver &resolver,
const DocumentSubDBReconfig& prepared_reconfig,
search::SerialNum serial_num);
};
} // namespace proton
|
