blob: 4f6b10dd068acd3311ac6999b802664a441d5139 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
#include <Processors/Formats/LazyOutputFormat.h>
#include <Processors/Transforms/AggregatingTransform.h>
namespace DB
{
WriteBufferFromPointer LazyOutputFormat::out(nullptr, 0);
Chunk LazyOutputFormat::getChunk(UInt64 milliseconds)
{
if (isFinished())
return {};
Chunk chunk;
if (milliseconds)
{
if (!queue.tryPop(chunk, milliseconds))
return {};
}
else
{
if (!queue.pop(chunk))
return {};
}
if (chunk)
info.update(chunk.getNumRows(), chunk.allocatedBytes());
return chunk;
}
Chunk LazyOutputFormat::getTotals()
{
return std::move(totals);
}
Chunk LazyOutputFormat::getExtremes()
{
return std::move(extremes);
}
void LazyOutputFormat::setRowsBeforeLimit(size_t rows_before_limit)
{
info.setRowsBeforeLimit(rows_before_limit);
}
}
|
