Method initLocalStateInternal

src/processor/operator/unwind_dedup.cpp:15–21

namespace processor {

void UnwindDedup::initLocalStateInternal(ResultSet* resultSet, ExecutionContext* /*context*/) {
    keyVectors.clear();
    keyVectors.reserve(keyDataPositions.size());
    for (auto& keyDataPos : keyDataPositions) {
        keyVectors.push_back(resultSet->getValueVector(keyDataPos).get());
    }
}

bool UnwindDedup::getNextTuplesInternal(ExecutionContext* context) {
    while (true) {