1 files changed, 54 insertions, 0 deletions
diff --git a/streamingvisitors/src/vespa/vsm/searcher/utf8suffixstringfieldsearcher.cpp b/streamingvisitors/src/vespa/vsm/searcher/utf8suffixstringfieldsearcher.cpp
new file mode 100644
index 00000000000..3495d46b85b
--- /dev/null
+++ b/streamingvisitors/src/vespa/vsm/searcher/utf8suffixstringfieldsearcher.cpp
@@ -0,0 +1,54 @@
+// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+#include "utf8suffixstringfieldsearcher.h"
+
+using search::byte;
+using search::streaming::QueryTerm;
+using search::streaming::QueryTermList;
+
+namespace vsm {
+
+std::unique_ptr<FieldSearcher>
+UTF8SuffixStringFieldSearcher::duplicate() const
+{
+    return std::make_unique<UTF8SuffixStringFieldSearcher>(*this);
+}
+
+size_t
+UTF8SuffixStringFieldSearcher::matchTerms(const FieldRef & f, const size_t mintsz)
+{
+    (void) mintsz;
+    termcount_t words = 0;
+    const byte * srcbuf = reinterpret_cast<const byte *> (f.data());
+    const byte * srcend = srcbuf + f.size();
+    if (f.size() >= _buf->size()) {
+        _buf->reserve(f.size() + 1);
+    }
+    cmptype_t * dstbuf = &(*_buf.get())[0];
+    size_t tokenlen = 0;
+
+    for( ; srcbuf < srcend; ) {
+        if (*srcbuf == 0) {
+            ++_zeroCount;
+            ++srcbuf;
+        }
+        srcbuf = tokenize(srcbuf, _buf->capacity(), dstbuf, tokenlen);
+        for (QueryTermList::iterator it = _qtl.begin(), mt = _qtl.end(); it != mt; ++it) {
+            QueryTerm & qt = **it;
+            const cmptype_t * term;
+            termsize_t tsz = qt.term(term);
+            if (matchTermSuffix(term, tsz, dstbuf, tokenlen)) {
+                addHit(qt, words);
+            }
+        }
+        words++;
+    }
+    return words;
+}
+
+size_t
+UTF8SuffixStringFieldSearcher::matchTerm(const FieldRef & f, QueryTerm & qt)
+{
+    return matchTermSuffix(f, qt);
+}
+
+}