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

#include "processor/operator/multiplicity_reducer.h"

namespace lbug {
namespace processor {

bool MultiplicityReducer::getNextTuplesInternal(ExecutionContext* context) {
    if (numRepeat == 0) {
        restoreMultiplicity();
        if (!children[0]->getNextTuple(context)) {
            return false;
        }
        saveMultiplicity();
        resultSet->multiplicity = 1;
    }
    numRepeat++;
    if (numRepeat == prevMultiplicity) {
        numRepeat = 0;
    }
    return true;
}

} // namespace processor
} // namespace lbug