Function getNodeTableScanInfo

src/processor/map/map_extend.cpp:131–162

}

static ScanNodeTableInfo getNodeTableScanInfo(const LogicalScanNodeTable& scan,
    storage::NodeTable* table, const catalog::TableCatalogEntry* tableEntry,
    main::ClientContext* clientContext) {
    auto tableInfo = ScanNodeTableInfo(table, copyVector(scan.getPropertyPredicates()));
    auto binder = Binder(clientContext);
    auto expressionBinder = ExpressionBinder(&binder, clientContext);
    for (auto& expr : scan.getProperties()) {
        auto& property = expr->constCast<PropertyExpression>();
        if (property.hasProperty(tableEntry->getTableID())) {
            auto propertyName = property.getPropertyName();
            if (!tableEntry->containsProperty(propertyName) &&
                tableEntry->containsProperty("data")) {
                auto columnCaster = ColumnCaster(LogicalType::JSON());
                columnCaster.setJSONExtract(propertyName);
                tableInfo.addColumnInfo(tableEntry->getColumnID("data"), std::move(columnCaster));
                continue;
            }
            auto& columnType = tableEntry->getProperty(propertyName).getType();
            auto columnCaster = ColumnCaster(columnType.copy());
            if (property.getDataType() != columnType) {
                auto columnExpr = std::make_shared<PropertyExpression>(property);
                columnExpr->dataType = columnType.copy();
                columnCaster.setCastExpr(
                    expressionBinder.forceCast(columnExpr, property.getDataType()));
            }
            tableInfo.addColumnInfo(tableEntry->getColumnID(propertyName), std::move(columnCaster));
        } else {
            tableInfo.addColumnInfo(INVALID_COLUMN_ID, ColumnCaster(LogicalType::ANY()));
        }
    }
    return tableInfo;
}

std::unique_ptr<PhysicalOperator> PlanMapper::mapExtend(const LogicalOperator* logicalOperator) {
    auto extend = logicalOperator->constPtrCast<LogicalExtend>();