aboutsummaryrefslogtreecommitdiffstats
path: root/searchlib/src/vespa/searchlib/tensor/serialized_fast_value_attribute.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'searchlib/src/vespa/searchlib/tensor/serialized_fast_value_attribute.cpp')
-rw-r--r--searchlib/src/vespa/searchlib/tensor/serialized_fast_value_attribute.cpp50
1 files changed, 0 insertions, 50 deletions
diff --git a/searchlib/src/vespa/searchlib/tensor/serialized_fast_value_attribute.cpp b/searchlib/src/vespa/searchlib/tensor/serialized_fast_value_attribute.cpp
index 94bf3f1a37b..a24059b3f7c 100644
--- a/searchlib/src/vespa/searchlib/tensor/serialized_fast_value_attribute.cpp
+++ b/searchlib/src/vespa/searchlib/tensor/serialized_fast_value_attribute.cpp
@@ -1,17 +1,13 @@
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "serialized_fast_value_attribute.h"
-#include "streamed_value_saver.h"
#include <vespa/eval/eval/value.h>
-#include <vespa/fastlib/io/bufferedfile.h>
#include <vespa/searchcommon/attribute/config.h>
#include <vespa/log/log.h>
LOG_SETUP(".searchlib.tensor.serialized_fast_value_attribute");
-#include "blob_sequence_reader.h"
-
using namespace vespalib;
using namespace vespalib::eval;
@@ -50,50 +46,4 @@ SerializedFastValueAttribute::getTensor(DocId docId) const
return _tensorBufferStore.get_tensor(ref);
}
-bool
-SerializedFastValueAttribute::onLoad(vespalib::Executor *)
-{
- BlobSequenceReader tensorReader(*this);
- if (!tensorReader.hasData()) {
- return false;
- }
- setCreateSerialNum(tensorReader.getCreateSerialNum());
- assert(tensorReader.getVersion() == getVersion());
- uint32_t numDocs(tensorReader.getDocIdLimit());
- _refVector.reset();
- _refVector.unsafe_reserve(numDocs);
- vespalib::Array<char> buffer(1024);
- for (uint32_t lid = 0; lid < numDocs; ++lid) {
- uint32_t tensorSize = tensorReader.getNextSize();
- if (tensorSize != 0) {
- if (tensorSize > buffer.size()) {
- buffer.resize(tensorSize + 1024);
- }
- tensorReader.readBlob(&buffer[0], tensorSize);
- vespalib::nbostream source(&buffer[0], tensorSize);
- EntryRef ref = _tensorBufferStore.store_encoded_tensor(source);
- _refVector.push_back(AtomicEntryRef(ref));
- } else {
- EntryRef invalid;
- _refVector.push_back(AtomicEntryRef(invalid));
- }
- }
- setNumDocs(numDocs);
- setCommittedDocIdLimit(numDocs);
- return true;
-}
-
-
-std::unique_ptr<AttributeSaver>
-SerializedFastValueAttribute::onInitSave(vespalib::stringref fileName)
-{
- vespalib::GenerationHandler::Guard guard(getGenerationHandler().
- takeGuard());
- return std::make_unique<StreamedValueSaver>
- (std::move(guard),
- this->createAttributeHeader(fileName),
- getRefCopy(),
- _tensorBufferStore);
-}
-
}