Method StorageExecutable

src/Storages/StorageExecutable.cpp:99–137

}

StorageExecutable::StorageExecutable(
    const StorageID & table_id_,
    const String & format,
    const ExecutableSettings & settings_,
    const VectorWithMemoryTracking<ASTPtr> & input_queries_,
    const ColumnsDescription & columns,
    const ConstraintsDescription & constraints,
    const String & comment)
    : StorageWithCommonVirtualColumns(table_id_)
    , settings(std::make_unique<ExecutableSettings>(settings_))
    , input_queries(input_queries_)
    , log(settings->is_executable_pool ? getLogger("StorageExecutablePool") : getLogger("StorageExecutable"))
{
    StorageInMemoryMetadata storage_metadata;
    storage_metadata.setColumns(columns);
    storage_metadata.setConstraints(constraints);
    storage_metadata.setComment(comment);
    storage_metadata.setVirtuals(createVirtuals());
    setInMemoryMetadata(storage_metadata);

    ShellCommandSourceCoordinator::Configuration configuration
    {
        .format = format,
        .command_termination_timeout_seconds = (*settings)[ExecutableSetting::command_termination_timeout],
        .command_read_timeout_milliseconds = (*settings)[ExecutableSetting::command_read_timeout],
        .command_write_timeout_milliseconds = (*settings)[ExecutableSetting::command_write_timeout],
        .stderr_reaction = (*settings)[ExecutableSetting::stderr_reaction],
        .check_exit_code = (*settings)[ExecutableSetting::check_exit_code],

        .pool_size = (*settings)[ExecutableSetting::pool_size],
        .max_command_execution_time_seconds = (*settings)[ExecutableSetting::max_command_execution_time],

        .is_executable_pool = settings->is_executable_pool,
        .send_chunk_header = (*settings)[ExecutableSetting::send_chunk_header],
        .execute_direct = true
    };

    coordinator = std::make_unique<ShellCommandSourceCoordinator>(std::move(configuration));
}

VirtualColumnsDescription StorageExecutable::createVirtuals()
{