Function initMask

src/processor/map/map_semi_masker.cpp:20–28

masksPerTable is collected from semiMasker. maskPerTable is collected from target operator, i.e. GDS, scan, ... Normally the two maps should have the same tableIDs. An exception is in GDS with filtered projected graph, multiple semiMasker will work on the same target GDS operator so masksPerTable may have fewer tableIDs.

// An exception is in GDS with filtered projected graph, multiple semiMasker will work on
// the same target GDS operator so masksPerTable may have fewer tableIDs.
static void initMask(table_id_map_t<std::vector<SemiMask*>>& masksPerTable,
    const table_id_map_t<SemiMask*>& maskPerTable) {
    for (auto& [tableID, masks] : masksPerTable) {
        DASSERT(maskPerTable.contains(tableID));
        auto mask = maskPerTable.at(tableID);
        mask->enable();
        masks.emplace_back(mask);
    }
}

std::unique_ptr<PhysicalOperator> PlanMapper::mapSemiMasker(
    const LogicalOperator* logicalOperator) {