lbug 0.16.0

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
27
28
29
30
31
32
33
34
35
36
37
38
39

#pragma once

#include "common/data_chunk/data_chunk.h"
#include "processor/data_pos.h"

namespace lbug {
namespace processor {

struct AggregateInfo {
    DataPos aggVectorPos;
    std::vector<data_chunk_pos_t> multiplicityChunksPos;
    common::LogicalType distinctAggKeyType;

    AggregateInfo(const DataPos& aggVectorPos, std::vector<data_chunk_pos_t> multiplicityChunksPos,
        common::LogicalType distinctAggKeyType)
        : aggVectorPos{aggVectorPos}, multiplicityChunksPos{std::move(multiplicityChunksPos)},
          distinctAggKeyType{std::move(distinctAggKeyType)} {}
    EXPLICIT_COPY_DEFAULT_MOVE(AggregateInfo);

private:
    AggregateInfo(const AggregateInfo& other)
        : aggVectorPos{other.aggVectorPos}, multiplicityChunksPos{other.multiplicityChunksPos},
          distinctAggKeyType{other.distinctAggKeyType.copy()} {}
};

struct AggregateInput {
    common::ValueVector* aggregateVector;
    std::vector<common::DataChunk*> multiplicityChunks;

    AggregateInput() : aggregateVector{nullptr} {}
    EXPLICIT_COPY_DEFAULT_MOVE(AggregateInput);

private:
    AggregateInput(const AggregateInput& other)
        : aggregateVector{other.aggregateVector}, multiplicityChunks{other.multiplicityChunks} {}
};

} // namespace processor
} // namespace lbug