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
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "struct_fields_resolver.h"
#include <vespa/searchcommon/attribute/iattributecontext.h>
#include <vespa/searchlib/common/matching_elements_fields.h>
#include <vespa/vespalib/util/issue.h>
#include <algorithm>
#include <vespa/log/log.h>
LOG_SETUP(".searchsummary.docsummary.struct_fields_resolver");
using search::attribute::CollectionType;
using search::attribute::IAttributeContext;
using vespalib::Issue;
namespace search::docsummary {
StructFieldsResolver::StructFieldsResolver(const vespalib::string& field_name, const IAttributeContext& attr_ctx,
bool require_all_struct_fields_as_attribute)
: _field_name(field_name),
_map_key_attribute(),
_map_value_fields(),
_map_value_attributes(),
_array_fields(),
_array_attributes(),
_has_map_key(false),
_has_map_value(false),
_error(false)
{
std::vector<const search::attribute::IAttributeVector *> attrs;
attr_ctx.getAttributeList(attrs);
vespalib::string prefix = field_name + ".";
_map_key_attribute = prefix + "key";
vespalib::string map_value_attribute_name = prefix + "value";
vespalib::string value_prefix = prefix + "value.";
for (const auto attr : attrs) {
vespalib::string name = attr->getName();
if (name.substr(0, prefix.size()) != prefix) {
continue;
}
if (attr->getCollectionType() != CollectionType::Type::ARRAY) {
Issue::report("StructFieldsResolver: Attribute '%s' is not an array attribute", name.c_str());
_error = true;
break;
}
if (name.substr(0, value_prefix.size()) == value_prefix) {
_map_value_fields.emplace_back(name.substr(value_prefix.size()));
} else {
_array_fields.emplace_back(name.substr(prefix.size()));
if (name == _map_key_attribute) {
_has_map_key = true;
} else if (name == map_value_attribute_name) {
_has_map_value = true;
}
}
}
if (!_error) {
std::sort(_map_value_fields.begin(), _map_value_fields.end());
for (const auto& field : _map_value_fields) {
_map_value_attributes.emplace_back(value_prefix + field);
}
std::sort(_array_fields.begin(), _array_fields.end());
for (const auto& field : _array_fields) {
_array_attributes.emplace_back(prefix + field);
}
if (require_all_struct_fields_as_attribute && !_map_value_fields.empty()) {
if (!_has_map_key) {
Issue::report("StructFieldsResolver: Missing key attribute '%s', have value attributes for map", _map_key_attribute.c_str());
_error = true;
} else if (_array_fields.size() != 1u) {
Issue::report("StructFieldsResolver: Could not determine if field '%s' is array or map of struct", field_name.c_str());
_error = true;
}
}
}
}
StructFieldsResolver::~StructFieldsResolver() = default;
void
StructFieldsResolver::apply_to(MatchingElementsFields& fields) const
{
if (is_map_of_struct()) {
if (_has_map_key) {
fields.add_mapping(_field_name, _map_key_attribute);
}
for (const auto& sub_field : _map_value_attributes) {
fields.add_mapping(_field_name, sub_field);
}
} else {
for (const auto& sub_field : _array_attributes) {
fields.add_mapping(_field_name, sub_field);
}
}
}
}
|
