ClickHouse

1
#include <Processors/Sources/SourceFromChunks.h>
2

3
namespace DB
4
{
5

6
SourceFromChunks::SourceFromChunks(Block header, Chunks chunks_)
7
    : ISource(std::move(header))
8
    , chunks(std::move(chunks_))
9
    , it(chunks.begin())
10
{}
11

12
String SourceFromChunks::getName() const
13
{
14
    return "SourceFromChunks";
15
}
16

17
Chunk SourceFromChunks::generate()
18
{
19
    if (it != chunks.end())
20
    {
21
        Chunk && chunk = std::move(*it);
22
        it++;
23
        return chunk;
24
    }
25
    else
26
        return {};
27
}
28

29
}
30