Fix build and add comment.

This commit is contained in:
Nikolai Kochetov 2021-07-16 13:56:13 +03:00
parent f36d14f68f
commit d3099e0c89
2 changed files with 4 additions and 2 deletions

View File

@ -36,12 +36,12 @@ public:
ASTPtr query;
Block header;
size_t shard_num;
size_t shard_num = 0;
ConnectionPoolWithFailoverPtr pool;
/// If we connect to replicas lazily.
/// (When there is a local replica with big delay).
bool lazy;
bool lazy = false;
UInt32 local_delay = 0;
};

View File

@ -14,6 +14,8 @@ using ConnectionPoolWithFailoverPtr = std::shared_ptr<ConnectionPoolWithFailover
class Throttler;
using ThrottlerPtr = std::shared_ptr<Throttler>;
/// Reading step from remote servers.
/// Unite query results from several shards.
class ReadFromRemote final : public ISourceStep
{
public: