lbug 0.16.1

An in-process property graph database management system built for query speed and scalability
Documentation 
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

#include "processor/operator/sink.h"

#include "main/query_result/materialized_query_result.h"
#include "processor/result/factorized_table_util.h"

namespace lbug {
namespace processor {

std::unique_ptr<ResultSet> Sink::getResultSet(storage::MemoryManager* memoryManager) {
    if (resultSetDescriptor == nullptr) {
        // Some pipeline does not need a resultSet, e.g. OrderByMerge
        return std::unique_ptr<ResultSet>();
    }
    return std::make_unique<ResultSet>(resultSetDescriptor.get(), memoryManager);
}

std::unique_ptr<main::QueryResult> SimpleSink::getQueryResult() const {
    return std::make_unique<main::MaterializedQueryResult>(messageTable);
}

void SimpleSink::appendMessage(const std::string& msg, storage::MemoryManager* memoryManager) {
    FactorizedTableUtils::appendStringToTable(messageTable.get(), msg, memoryManager);
}

} // namespace processor
} // namespace lbug