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
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "fast_access_doc_subdb_configurer.h"
#include "fast_access_feed_view.h"
#include "document_subdb_reconfig.h"
#include "documentdbconfig.h"
#include "reconfig_params.h"
#include <vespa/searchcore/proton/attribute/attributemanager.h>
#include <vespa/searchcore/proton/attribute/attribute_collection_spec_factory.h>
#include <vespa/searchcore/proton/attribute/attribute_manager_reconfig.h>
#include <vespa/searchcore/proton/attribute/attribute_writer.h>
#include <vespa/searchcore/proton/common/document_type_inspector.h>
#include <vespa/searchcore/proton/common/indexschema_inspector.h>
#include <vespa/searchcore/proton/reprocessing/attribute_reprocessing_initializer.h>
using document::DocumentTypeRepo;
using search::index::Schema;
namespace proton {
using ARIConfig = AttributeReprocessingInitializer::Config;
void
FastAccessDocSubDBConfigurer::reconfigureFeedView(FastAccessFeedView & curr,
std::shared_ptr<Schema> schema,
std::shared_ptr<const DocumentTypeRepo> repo,
std::shared_ptr<IAttributeWriter> writer)
{
_feedView.set(std::make_shared<FastAccessFeedView>(
StoreOnlyFeedView::Context(curr.getSummaryAdapter(),
std::move(schema),
curr.getDocumentMetaStore(),
std::move(repo),
curr.getUncommittedLidTracker(),
curr.getGidToLidChangeHandler(),
curr.getWriteService()),
curr.getPersistentParams(),
FastAccessFeedView::Context(std::move(writer),curr.getDocIdLimit())));
}
FastAccessDocSubDBConfigurer::FastAccessDocSubDBConfigurer(FeedViewVarHolder &feedView,
const vespalib::string &subDbName)
: _feedView(feedView),
_subDbName(subDbName)
{
}
FastAccessDocSubDBConfigurer::~FastAccessDocSubDBConfigurer() = default;
std::unique_ptr<DocumentSubDBReconfig>
FastAccessDocSubDBConfigurer::prepare_reconfig(const DocumentDBConfig& new_config_snapshot,
const DocumentDBConfig& old_config_snapshot,
const AttributeCollectionSpecFactory& attr_spec_factory,
const ReconfigParams& reconfig_params,
uint32_t docid_limit,
std::optional<search::SerialNum> serial_num)
{
(void) new_config_snapshot;
(void) old_config_snapshot;
(void) serial_num;
auto old_attribute_writer = _feedView.get()->getAttributeWriter();
auto old_attribute_manager = old_attribute_writer->getAttributeManager();
auto reconfig = std::make_unique<DocumentSubDBReconfig>(std::shared_ptr<Matchers>(), old_attribute_manager);
if (reconfig_params.shouldAttributeManagerChange()) {
auto attr_spec = attr_spec_factory.create(new_config_snapshot.getAttributesConfig(), docid_limit, serial_num);
reconfig->set_attribute_manager_reconfig(old_attribute_manager->prepare_create(std::move(*attr_spec)));
}
return reconfig;
}
IReprocessingInitializer::UP
FastAccessDocSubDBConfigurer::reconfigure(const DocumentDBConfig &newConfig,
const DocumentDBConfig &oldConfig,
const DocumentSubDBReconfig& prepared_reconfig,
search::SerialNum serial_num)
{
std::shared_ptr<FastAccessFeedView> oldView = _feedView.get();
auto writer = std::make_shared<AttributeWriter>(prepared_reconfig.attribute_manager());
reconfigureFeedView(*oldView, newConfig.getSchemaSP(), newConfig.getDocumentTypeRepoSP(), writer);
const document::DocumentType *newDocType = newConfig.getDocumentType();
const document::DocumentType *oldDocType = oldConfig.getDocumentType();
assert(newDocType != nullptr);
assert(oldDocType != nullptr);
DocumentTypeInspector inspector(*oldDocType, *newDocType);
IndexschemaInspector oldIndexschemaInspector(oldConfig.getIndexschemaConfig());
return std::make_unique<AttributeReprocessingInitializer>
(ARIConfig(writer->getAttributeManager(), *newConfig.getSchemaSP()),
ARIConfig(oldView->getAttributeWriter()->getAttributeManager(), *oldConfig.getSchemaSP()),
inspector, oldIndexschemaInspector, _subDbName, serial_num);
}
} // namespace proton
|
