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

Style [#CLICKHOUSE-2]

Browse Source
This commit is contained in:
Alexey Milovidov 2018-01-22 07:04:57 +03:00
parent 08a76cbdcc
commit 98c52ede21
2 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dbms/src/Interpreters/ClusterProxy/DescribeStreamFactory.h
View File

@ -11,13 +11,11 @@ namespace ClusterProxy
class DescribeStreamFactory final : public IStreamFactory class DescribeStreamFactory final : public IStreamFactory
{ {
public: public:
DescribeStreamFactory() = default; void createForShard(
const Cluster::ShardInfo & shard_info,
virtual void createForShard( const String & query, const ASTPtr & query_ast,
const Cluster::ShardInfo & shard_info, const Context & context, const ThrottlerPtr & throttler,
const String & query, const ASTPtr & query_ast, BlockInputStreams & res) override;
const Context & context, const ThrottlerPtr & throttler,
BlockInputStreams & res) override;
}; };
} }

16
dbms/src/Interpreters/ClusterProxy/SelectStreamFactory.h
View File

@ -14,15 +14,15 @@ class SelectStreamFactory final : public IStreamFactory
{ {
public: public:
SelectStreamFactory( SelectStreamFactory(
QueryProcessingStage::Enum processed_stage, QueryProcessingStage::Enum processed_stage,
QualifiedTableName main_table, QualifiedTableName main_table,
const Tables & external_tables); const Tables & external_tables);
virtual void createForShard( void createForShard(
const Cluster::ShardInfo & shard_info, const Cluster::ShardInfo & shard_info,
const String & query, const ASTPtr & query_ast, const String & query, const ASTPtr & query_ast,
const Context & context, const ThrottlerPtr & throttler, const Context & context, const ThrottlerPtr & throttler,
BlockInputStreams & res) override; BlockInputStreams & res) override;
private: private:
QueryProcessingStage::Enum processed_stage; QueryProcessingStage::Enum processed_stage;