Method IStorageCnchFile

src/Storages/RemoteFile/IStorageCnchFile.cpp:71–107

}

IStorageCnchFile::IStorageCnchFile(
    ContextPtr context_,
    const StorageID & table_id_,
    const ColumnsDescription & required_columns_,
    const ConstraintsDescription & constraints_,
    const ASTPtr & setting_changes_,
    const CnchFileArguments & arguments_,
    const CnchFileSettings & settings_)
    : IStorage(table_id_)
    , WithMutableContext(context_->getGlobalContext())
    , CnchStorageCommonHelper(table_id_, table_id_.getDatabaseName(), table_id_.getTableName())
    , arguments(std::move(arguments_))
    , settings(std::move(settings_))
{
    context_->getRemoteHostFilter().checkURL(Poco::URI(arguments.url));

    if (arguments.format_name.empty())
        arguments.format_name = "auto";
    if (arguments.compression_method.empty())
        arguments.compression_method = "auto";

    StorageInMemoryMetadata metadata;
    metadata.setSettingsChanges(setting_changes_);
    metadata.setColumns(required_columns_);
    metadata.setConstraints(constraints_);
    setInMemoryMetadata(metadata);

    String path = arguments.url.substr(arguments.url.find('/', arguments.url.find("//") + 2));
    arguments.is_glob_path = path.find_first_of("*?{") != std::string::npos;

    file_list.emplace_back(arguments.url);

    auto default_virtuals = NamesAndTypesList{{"_path", std::make_shared<DataTypeString>()}, {"_file", std::make_shared<DataTypeString>()}};
    virtual_columns = getVirtualsForStorage(metadata.getSampleBlock().getNamesAndTypesList(), default_virtuals);
    for (const auto & column : virtual_columns)
        virtual_header.insert({column.type->createColumn(), column.type, column.name});
}

Pipe IStorageCnchFile::read(
    const Names & column_names,