Method relation_set_new_node

cpp/deeplake_pg/table_am.cpp:1135–1203

}

void deeplake_table_am_routine::relation_set_new_node(
    Relation rel, const RelFileLocator* newrnode, char persistence, TransactionId* freezeXid, MultiXactId* minmulti)
{
    // Get the schema-qualified table name
    const std::string table_name = get_qualified_table_name(rel);

    // Block temp table creation from VACUUM FULL
    // VACUUM FULL tries to create a temp table (pg_temp_*) to rebuild the original table
    // This is not supported for columnar storage
    if (table_name.find("pg_temp_") != std::string::npos) {
        ereport(
            ERROR,
            (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
             errmsg("VACUUM FULL is not supported for deeplake tables"),
             errhint(
                 "Deeplake uses columnar storage which is already compact. Use VACUUM or VACUUM ANALYZE instead.")));
    }

    *freezeXid = RecentXmin;
    *minmulti = GetOldestMultiXactId();

    // Create physical storage for the relation.
    // Even though DeepLake uses columnar storage (S3/cloud), PostgreSQL's ANALYZE
    // requires a physical storage file for block sampling. The read_stream API
    // expects to read physical blocks from the relation's storage file.
    // Without this, ANALYZE fails with "could not open file" errors.
    SMgrRelation srel = RelationCreateStorage(*newrnode, persistence, true);

    // Extend the storage to have at least one block.
    // This is needed because ANALYZE's BlockSampler will try to read blocks,
    // and if the file is empty, read_stream_next_buffer will fail.
    // We create a minimal block so that ANALYZE can proceed.
    // The actual data comes from our columnar storage via scan_analyze_next_tuple.
    smgrzeroextend(srel, MAIN_FORKNUM, 0, 1, true);

    if (persistence == RELPERSISTENCE_UNLOGGED) {
        smgrcreate(srel, INIT_FORKNUM, false);
        log_smgrcreate(&srel->smgr_rlocator.locator, INIT_FORKNUM);
        smgrimmedsync(srel, INIT_FORKNUM);
    }

    smgrclose(srel);

    // Get the tuple descriptor
    TupleDesc tupdesc = RelationGetDescr(rel);
    if (tupdesc == nullptr) {
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_TABLE),
                 errmsg("could not get tuple descriptor for relation \"%s\"", RelationGetRelationName(rel))));
    }

    convert_schema(tupdesc);

    // Set DDL context to prevent auto-creation of tables from catalog during
    // concurrent table creation (which causes race conditions).
    table_storage::ddl_context_guard ddl_guard;

    try {