ClickHouse

registerAggregateFunctions.cpp
214 строк · 12.5 Кб
Перенос по словам
1
#include <AggregateFunctions/registerAggregateFunctions.h>
2

3
#include <AggregateFunctions/AggregateFunctionFactory.h>
4
#include <AggregateFunctions/Combinators/AggregateFunctionCombinatorFactory.h>
5

6

7
namespace DB
8
{
9
struct Settings;
10

11
class AggregateFunctionFactory;
12
void registerAggregateFunctionAvg(AggregateFunctionFactory &);
13
void registerAggregateFunctionAvgWeighted(AggregateFunctionFactory &);
14
void registerAggregateFunctionCount(AggregateFunctionFactory &);
15
void registerAggregateFunctionDeltaSum(AggregateFunctionFactory &);
16
void registerAggregateFunctionDeltaSumTimestamp(AggregateFunctionFactory &);
17
void registerAggregateFunctionGroupArray(AggregateFunctionFactory &);
18
void registerAggregateFunctionGroupArraySorted(AggregateFunctionFactory & factory);
19
void registerAggregateFunctionGroupUniqArray(AggregateFunctionFactory &);
20
void registerAggregateFunctionGroupArrayInsertAt(AggregateFunctionFactory &);
21
void registerAggregateFunctionGroupArrayIntersect(AggregateFunctionFactory &);
22
void registerAggregateFunctionsQuantile(AggregateFunctionFactory &);
23
void registerAggregateFunctionsQuantileDeterministic(AggregateFunctionFactory &);
24
void registerAggregateFunctionsQuantileExact(AggregateFunctionFactory &);
25
void registerAggregateFunctionsQuantileExactWeighted(AggregateFunctionFactory &);
26
void registerAggregateFunctionsQuantileInterpolatedWeighted(AggregateFunctionFactory &);
27
void registerAggregateFunctionsQuantileExactLow(AggregateFunctionFactory &);
28
void registerAggregateFunctionsQuantileExactHigh(AggregateFunctionFactory &);
29
void registerAggregateFunctionsQuantileExactInclusive(AggregateFunctionFactory &);
30
void registerAggregateFunctionsQuantileExactExclusive(AggregateFunctionFactory &);
31
void registerAggregateFunctionsQuantileTiming(AggregateFunctionFactory &);
32
void registerAggregateFunctionsQuantileTimingWeighted(AggregateFunctionFactory &);
33
void registerAggregateFunctionsQuantileTDigest(AggregateFunctionFactory &);
34
void registerAggregateFunctionsQuantileTDigestWeighted(AggregateFunctionFactory &);
35
void registerAggregateFunctionsQuantileBFloat16(AggregateFunctionFactory &);
36
void registerAggregateFunctionsQuantileDD(AggregateFunctionFactory &);
37
void registerAggregateFunctionsQuantileBFloat16Weighted(AggregateFunctionFactory &);
38
void registerAggregateFunctionsQuantileApprox(AggregateFunctionFactory &);
39
void registerAggregateFunctionsSequenceMatch(AggregateFunctionFactory &);
40
void registerAggregateFunctionWindowFunnel(AggregateFunctionFactory &);
41
void registerAggregateFunctionRate(AggregateFunctionFactory &);
42
void registerAggregateFunctionsMinMax(AggregateFunctionFactory &);
43
void registerAggregateFunctionsArgMinArgMax(AggregateFunctionFactory &);
44
void registerAggregateFunctionsAny(AggregateFunctionFactory &);
45
void registerAggregateFunctionAnyHeavy(AggregateFunctionFactory &);
46
void registerAggregateFunctionsAnyRespectNulls(AggregateFunctionFactory &);
47
void registerAggregateFunctionsStatisticsStable(AggregateFunctionFactory &);
48
void registerAggregateFunctionsStatisticsSecondMoment(AggregateFunctionFactory &);
49
void registerAggregateFunctionsStatisticsThirdMoment(AggregateFunctionFactory &);
50
void registerAggregateFunctionsStatisticsFourthMoment(AggregateFunctionFactory &);
51
void registerAggregateFunctionsStatisticsCovar(AggregateFunctionFactory &);
52
void registerAggregateFunctionsStatisticsCorr(AggregateFunctionFactory &);
53
void registerAggregateFunctionsVarianceMatrix(AggregateFunctionFactory &);
54
void registerAggregateFunctionSum(AggregateFunctionFactory &);
55
void registerAggregateFunctionSumCount(AggregateFunctionFactory &);
56
void registerAggregateFunctionSumMap(AggregateFunctionFactory &);
57
void registerAggregateFunctionsUniq(AggregateFunctionFactory &);
58
void registerAggregateFunctionUniqCombined(AggregateFunctionFactory &);
59
void registerAggregateFunctionUniqUpTo(AggregateFunctionFactory &);
60
void registerAggregateFunctionTopK(AggregateFunctionFactory &);
61
void registerAggregateFunctionsBitwise(AggregateFunctionFactory &);
62
void registerAggregateFunctionsBitmap(AggregateFunctionFactory &);
63
void registerAggregateFunctionsMaxIntersections(AggregateFunctionFactory &);
64
void registerAggregateFunctionHistogram(AggregateFunctionFactory &);
65
void registerAggregateFunctionRetention(AggregateFunctionFactory &);
66
void registerAggregateFunctionMLMethod(AggregateFunctionFactory &);
67
void registerAggregateFunctionEntropy(AggregateFunctionFactory &);
68
void registerAggregateFunctionSimpleLinearRegression(AggregateFunctionFactory &);
69
void registerAggregateFunctionMoving(AggregateFunctionFactory &);
70
void registerAggregateFunctionCategoricalIV(AggregateFunctionFactory &);
71
void registerAggregateFunctionAggThrow(AggregateFunctionFactory &);
72
void registerAggregateFunctionRankCorrelation(AggregateFunctionFactory &);
73
void registerAggregateFunctionMannWhitney(AggregateFunctionFactory &);
74
void registerAggregateFunctionWelchTTest(AggregateFunctionFactory &);
75
void registerAggregateFunctionStudentTTest(AggregateFunctionFactory &);
76
void registerAggregateFunctionMeanZTest(AggregateFunctionFactory &);
77
void registerAggregateFunctionCramersV(AggregateFunctionFactory &);
78
void registerAggregateFunctionTheilsU(AggregateFunctionFactory &);
79
void registerAggregateFunctionContingency(AggregateFunctionFactory &);
80
void registerAggregateFunctionCramersVBiasCorrected(AggregateFunctionFactory &);
81
void registerAggregateFunctionSingleValueOrNull(AggregateFunctionFactory &);
82
void registerAggregateFunctionSequenceNextNode(AggregateFunctionFactory &);
83
void registerAggregateFunctionNothing(AggregateFunctionFactory &);
84
void registerAggregateFunctionExponentialMovingAverage(AggregateFunctionFactory &);
85
void registerAggregateFunctionSparkbar(AggregateFunctionFactory &);
86
void registerAggregateFunctionIntervalLengthSum(AggregateFunctionFactory &);
87
void registerAggregateFunctionAnalysisOfVariance(AggregateFunctionFactory &);
88
void registerAggregateFunctionFlameGraph(AggregateFunctionFactory &);
89
void registerAggregateFunctionKolmogorovSmirnovTest(AggregateFunctionFactory & factory);
90
void registerAggregateFunctionLargestTriangleThreeBuckets(AggregateFunctionFactory & factory);
91

92
class AggregateFunctionCombinatorFactory;
93
void registerAggregateFunctionCombinatorIf(AggregateFunctionCombinatorFactory &);
94
void registerAggregateFunctionCombinatorArray(AggregateFunctionCombinatorFactory &);
95
void registerAggregateFunctionCombinatorForEach(AggregateFunctionCombinatorFactory &);
96
void registerAggregateFunctionCombinatorSimpleState(AggregateFunctionCombinatorFactory &);
97
void registerAggregateFunctionCombinatorState(AggregateFunctionCombinatorFactory &);
98
void registerAggregateFunctionCombinatorMerge(AggregateFunctionCombinatorFactory &);
99
void registerAggregateFunctionCombinatorNull(AggregateFunctionCombinatorFactory &);
100
void registerAggregateFunctionCombinatorOrFill(AggregateFunctionCombinatorFactory &);
101
void registerAggregateFunctionCombinatorResample(AggregateFunctionCombinatorFactory &);
102
void registerAggregateFunctionCombinatorDistinct(AggregateFunctionCombinatorFactory &);
103
void registerAggregateFunctionCombinatorMap(AggregateFunctionCombinatorFactory & factory);
104
void registerAggregateFunctionCombinatorsArgMinArgMax(AggregateFunctionCombinatorFactory & factory);
105

106
void registerWindowFunctions(AggregateFunctionFactory & factory);
107

108
void registerAggregateFunctions()
109
{
110
    {
111
        auto & factory = AggregateFunctionFactory::instance();
112

113
        registerAggregateFunctionAvg(factory);
114
        registerAggregateFunctionAvgWeighted(factory);
115
        registerAggregateFunctionCount(factory);
116
        registerAggregateFunctionDeltaSum(factory);
117
        registerAggregateFunctionDeltaSumTimestamp(factory);
118
        registerAggregateFunctionGroupArray(factory);
119
        registerAggregateFunctionGroupArraySorted(factory);
120
        registerAggregateFunctionGroupUniqArray(factory);
121
        registerAggregateFunctionGroupArrayInsertAt(factory);
122
        registerAggregateFunctionGroupArrayIntersect(factory);
123
        registerAggregateFunctionsQuantile(factory);
124
        registerAggregateFunctionsQuantileDeterministic(factory);
125
        registerAggregateFunctionsQuantileExact(factory);
126
        registerAggregateFunctionsQuantileExactWeighted(factory);
127
        registerAggregateFunctionsQuantileInterpolatedWeighted(factory);
128
        registerAggregateFunctionsQuantileExactLow(factory);
129
        registerAggregateFunctionsQuantileExactHigh(factory);
130
        registerAggregateFunctionsQuantileExactInclusive(factory);
131
        registerAggregateFunctionsQuantileExactExclusive(factory);
132
        registerAggregateFunctionsQuantileTiming(factory);
133
        registerAggregateFunctionsQuantileTimingWeighted(factory);
134
        registerAggregateFunctionsQuantileTDigest(factory);
135
        registerAggregateFunctionsQuantileTDigestWeighted(factory);
136
        registerAggregateFunctionsQuantileBFloat16(factory);
137
        registerAggregateFunctionsQuantileDD(factory);
138
        registerAggregateFunctionsQuantileBFloat16Weighted(factory);
139
        registerAggregateFunctionsQuantileApprox(factory);
140
        registerAggregateFunctionsSequenceMatch(factory);
141
        registerAggregateFunctionWindowFunnel(factory);
142
        registerAggregateFunctionRate(factory);
143
        registerAggregateFunctionsMinMax(factory);
144
        registerAggregateFunctionsArgMinArgMax(factory);
145
        registerAggregateFunctionsAny(factory);
146
        registerAggregateFunctionAnyHeavy(factory);
147
        registerAggregateFunctionsAnyRespectNulls(factory);
148
        registerAggregateFunctionsStatisticsStable(factory);
149
        registerAggregateFunctionsStatisticsSecondMoment(factory);
150
        registerAggregateFunctionsStatisticsThirdMoment(factory);
151
        registerAggregateFunctionsStatisticsFourthMoment(factory);
152
        registerAggregateFunctionsStatisticsCovar(factory);
153
        registerAggregateFunctionsStatisticsCorr(factory);
154
        registerAggregateFunctionsVarianceMatrix(factory);
155
        registerAggregateFunctionSum(factory);
156
        registerAggregateFunctionSumCount(factory);
157
        registerAggregateFunctionSumMap(factory);
158
        registerAggregateFunctionsUniq(factory);
159
        registerAggregateFunctionUniqCombined(factory);
160
        registerAggregateFunctionUniqUpTo(factory);
161
        registerAggregateFunctionTopK(factory);
162
        registerAggregateFunctionsBitwise(factory);
163
        registerAggregateFunctionCramersV(factory);
164
        registerAggregateFunctionTheilsU(factory);
165
        registerAggregateFunctionContingency(factory);
166
        registerAggregateFunctionCramersVBiasCorrected(factory);
167
        registerAggregateFunctionsBitmap(factory);
168
        registerAggregateFunctionsMaxIntersections(factory);
169
        registerAggregateFunctionHistogram(factory);
170
        registerAggregateFunctionRetention(factory);
171
        registerAggregateFunctionMLMethod(factory);
172
        registerAggregateFunctionEntropy(factory);
173
        registerAggregateFunctionSimpleLinearRegression(factory);
174
        registerAggregateFunctionMoving(factory);
175
        registerAggregateFunctionCategoricalIV(factory);
176
        registerAggregateFunctionAggThrow(factory);
177
        registerAggregateFunctionRankCorrelation(factory);
178
        registerAggregateFunctionMannWhitney(factory);
179
        registerAggregateFunctionSequenceNextNode(factory);
180
        registerAggregateFunctionWelchTTest(factory);
181
        registerAggregateFunctionStudentTTest(factory);
182
        registerAggregateFunctionMeanZTest(factory);
183
        registerAggregateFunctionNothing(factory);
184
        registerAggregateFunctionSingleValueOrNull(factory);
185
        registerAggregateFunctionIntervalLengthSum(factory);
186
        registerAggregateFunctionExponentialMovingAverage(factory);
187
        registerAggregateFunctionSparkbar(factory);
188
        registerAggregateFunctionAnalysisOfVariance(factory);
189
        registerAggregateFunctionFlameGraph(factory);
190
        registerAggregateFunctionKolmogorovSmirnovTest(factory);
191
        registerAggregateFunctionLargestTriangleThreeBuckets(factory);
192

193
        registerWindowFunctions(factory);
194
    }
195

196
    {
197
        auto & factory = AggregateFunctionCombinatorFactory::instance();
198

199
        registerAggregateFunctionCombinatorIf(factory);
200
        registerAggregateFunctionCombinatorArray(factory);
201
        registerAggregateFunctionCombinatorForEach(factory);
202
        registerAggregateFunctionCombinatorSimpleState(factory);
203
        registerAggregateFunctionCombinatorState(factory);
204
        registerAggregateFunctionCombinatorMerge(factory);
205
        registerAggregateFunctionCombinatorNull(factory);
206
        registerAggregateFunctionCombinatorOrFill(factory);
207
        registerAggregateFunctionCombinatorResample(factory);
208
        registerAggregateFunctionCombinatorDistinct(factory);
209
        registerAggregateFunctionCombinatorMap(factory);
210
        registerAggregateFunctionCombinatorsArgMinArgMax(factory);
211
    }
212
}
213

214
}
215
ClickHouse

Использование cookies
