Processors for IStorageSystemOneBlock.

This commit is contained in:
Nikolai Kochetov 2020-01-24 18:42:31 +03:00
parent 61154da744
commit dc49635ed4

View File

@ -42,7 +42,10 @@ public:
UInt64 num_rows = res_columns.at(0)->size();
Chunk chunk(std::move(res_columns), num_rows);
return { Pipe(std::make_shared<SourceFromSingleChunk>(sample_block, std::move(chunk))) };
Pipes pipes;
pipes.emplace_back(std::make_shared<SourceFromSingleChunk>(sample_block, std::move(chunk)));
return pipes;
}
};