mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-29 02:52:13 +00:00
dbms: send requests to local clickhouse via network [#METR-13298]
This commit is contained in:
parent
f591ba73e1
commit
83f17692e1
@ -3,11 +3,10 @@
|
||||
#include <DB/Dictionaries/IDictionarySource.h>
|
||||
#include <DB/Client/ConnectionPool.h>
|
||||
#include <DB/DataStreams/RemoteBlockInputStream.h>
|
||||
#include <DB/Interpreters/InterpreterSelectQuery.h>
|
||||
#include <DB/Interpreters/executeQuery.h>
|
||||
#include <statdaemons/ext/range.hpp>
|
||||
#include <Poco/Util/AbstractConfiguration.h>
|
||||
#include <Poco/Net/NetworkInterface.h>
|
||||
#include <DB/DataStreams/NullBlockInputStream.h>
|
||||
|
||||
namespace DB
|
||||
{
|
||||
@ -50,7 +49,9 @@ public:
|
||||
BlockInputStreamPtr loadAll() override
|
||||
{
|
||||
if (is_local)
|
||||
return executeQuery(load_all_query, context).in;
|
||||
return new RemoteBlockInputStream{pool.get(), load_all_query, nullptr};
|
||||
/// should be processed locally but due to some coupling problems cannot be handled properly now
|
||||
/// return executeQuery(load_all_query, context).in;
|
||||
return new RemoteBlockInputStream{pool.get(), load_all_query, nullptr};
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user