thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-24 18:50:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Processors support for StorageXDBC reading.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-02-17 18:32:27 +03:00
parent 728ece09f1
commit dda0bcb9ba
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dbms/src/Storages/StorageXDBC.cpp
View File

@ -82,7 +82,7 @@ std::function<void(std::ostream &)> StorageXDBC::getReadPOSTDataCallback(const N
return [query](std::ostream & os) { os << "query=" << query; };
}
BlockInputStreams StorageXDBC::read(const Names & column_names,
Pipes StorageXDBC::readWithProcessors(const Names & column_names,
const SelectQueryInfo & query_info,
const Context & context,
QueryProcessingStage::Enum processed_stage,
@ -92,7 +92,7 @@ BlockInputStreams StorageXDBC::read(const Names & column_names,
check(column_names);
bridge_helper->startBridgeSync();
return IStorageURLBase::read(column_names, query_info, context, processed_stage, max_block_size, num_streams);
return IStorageURLBase::readWithProcessors(column_names, query_info, context, processed_stage, max_block_size, num_streams);
}

3
dbms/src/Storages/StorageXDBC.h
View File

@ -16,13 +16,14 @@ class StorageXDBC : public IStorageURLBase
{
public:
BlockInputStreams read(const Names & column_names,
Pipes readWithProcessors(const Names & column_names,
const SelectQueryInfo & query_info,
const Context & context,
QueryProcessingStage::Enum processed_stage,
size_t max_block_size,
unsigned num_streams) override;
bool supportProcessorsPipeline() const override { return true; }
StorageXDBC(const StorageID & table_id_,
const std::string & remote_database_name,