Processors: development [#CLICKHOUSE-2948]

This commit is contained in:
Alexey Milovidov 2018-06-04 21:31:46 +03:00
parent 62296fc763
commit 1ff8be156c
3 changed files with 4 additions and 3 deletions

View File

@ -13,7 +13,7 @@ class ReadBuffer;
class IInputFormat : public ISource
{
private:
ReadBuffer & in;
ReadBuffer & in [[maybe_unused]];
public:
IInputFormat(Block header, ReadBuffer & in)

View File

@ -16,9 +16,10 @@ class IProcessor;
class Port
{
protected:
friend void connect(OutputPort &, InputPort &);
friend class IProcessor;
protected:
/// Shared state of two connected ports.
struct State
{

View File

@ -31,7 +31,7 @@ public:
Block res = std::move(blocks.front());
blocks.pop();
return std::move(res);
return res;
}
};