ClickHouse

1
#include "AggregateFunctionState.h"
2
#include "AggregateFunctionMerge.h"
3
#include "AggregateFunctionCombinatorFactory.h"
4

5
#include <DataTypes/DataTypeAggregateFunction.h>
6

7

8
namespace DB
9
{
10

11
namespace
12
{
13

14
class AggregateFunctionCombinatorState final : public IAggregateFunctionCombinator
15
{
16
public:
17
    String getName() const override { return "State"; }
18

19
    DataTypes transformArguments(const DataTypes & arguments) const override
20
    {
21
        return arguments;
22
    }
23

24
    AggregateFunctionPtr transformAggregateFunction(
25
        const AggregateFunctionPtr & nested_function,
26
        const AggregateFunctionProperties &,
27
        const DataTypes & arguments,
28
        const Array & params) const override
29
    {
30
        return std::make_shared<AggregateFunctionState>(nested_function, arguments, params);
31
    }
32
};
33

34
}
35

36
void registerAggregateFunctionCombinatorState(AggregateFunctionCombinatorFactory & factory)
37
{
38
    factory.registerCombinator(std::make_shared<AggregateFunctionCombinatorState>());
39
}
40

41
}
42