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
|
#pragma once
#include <Processors/Merges/IMergingTransform.h>
#include <Processors/Merges/Algorithms/FinishAggregatingInOrderAlgorithm.h>
namespace DB
{
class ColumnAggregateFunction;
/// Implementation of IMergingTransform via FinishAggregatingInOrderAlgorithm.
class FinishAggregatingInOrderTransform final : public IMergingTransform<FinishAggregatingInOrderAlgorithm>
{
public:
FinishAggregatingInOrderTransform(
const Block & header,
size_t num_inputs,
AggregatingTransformParamsPtr params,
SortDescription description,
size_t max_block_size_rows,
size_t max_block_size_bytes)
: IMergingTransform(
num_inputs, header, {}, /*have_all_inputs_=*/ true, /*limit_hint_=*/ 0, /*always_read_till_end_=*/ false,
header,
num_inputs,
params,
std::move(description),
max_block_size_rows,
max_block_size_bytes)
{
}
String getName() const override { return "FinishAggregatingInOrderTransform"; }
};
}
|
