| 56 | } |
| 57 | |
| 58 | RemoteQueryExecutor::RemoteQueryExecutor( |
| 59 | Connection & connection, |
| 60 | const String & query_, const Block & header_, ContextPtr context_, |
| 61 | ThrottlerPtr throttler, const Scalars & scalars_, const Tables & external_tables_, |
| 62 | QueryProcessingStage::Enum stage_, std::shared_ptr<TaskIterator> task_iterator_) |
| 63 | : header(header_), query(query_), context(context_) |
| 64 | , scalars(scalars_), external_tables(external_tables_), stage(stage_), task_iterator(task_iterator_) |
| 65 | { |
| 66 | create_connections = [this, &connection, throttler]() |
| 67 | { |
| 68 | return std::make_unique<MultiplexedConnections>(connection, context, context->getSettingsRef(), throttler); |
| 69 | }; |
| 70 | } |
| 71 | |
| 72 | RemoteQueryExecutor::RemoteQueryExecutor( |
| 73 | std::vector<IConnectionPool::Entry> && connections_, |
nothing calls this directly
no test coverage detected