Method executeImpl

src/TableFunctions/TableFunctionMergeTreeTextIndex.cpp:95–128

}

StoragePtr TableFunctionMergeTreeTextIndex::executeImpl(
    const ASTPtr & /*ast_function*/,
    ContextPtr context,
    const std::string & table_name,
    ColumnsDescription /*cached_columns*/,
    bool is_insert_query) const
{
    auto source_table_ptr = DatabaseCatalog::instance().getTable(StorageID{source_database, source_table}, context);
    auto metadata_snapshot = source_table_ptr->getInMemoryMetadataPtr(context, false);
    const auto & index_desc = metadata_snapshot->getSecondaryIndices().getByName(source_index_name);

    if (index_desc.type != "text")
        throw Exception(
            ErrorCodes::BAD_ARGUMENTS,
            "Got index '{}' of type '{}', expected 'text'",
            source_index_name, index_desc.type);

    const auto * merge_tree = dynamic_cast<const MergeTreeData *>(source_table_ptr.get());
    if (!merge_tree)
        throw Exception(ErrorCodes::BAD_ARGUMENTS, "Storage MergeTreeTextIndex expected MergeTree table, got: {}", source_table_ptr->getName());

    auto text_index = MergeTreeIndexFactory::instance().get(metadata_snapshot, index_desc, *merge_tree->getSettings());
    auto columns = getActualTableStructure(context, is_insert_query);
    StorageID storage_id(getDatabaseName(), table_name);

    auto res = std::make_shared<StorageMergeTreeTextIndex>(
        std::move(storage_id),
        std::move(source_table_ptr),
        std::move(text_index),
        std::move(columns));

    res->startup();
    return res;
}

void registerTableFunctionMergeTreeTextIndex(TableFunctionFactory & factory);
void registerTableFunctionMergeTreeTextIndex(TableFunctionFactory & factory)