Method getResultSet

src/processor/operator/sink.cpp:9–15

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);