Skip to content

Commit 109e564

Browse files
committed
review fixes
1 parent 069fded commit 109e564

File tree

3 files changed

+5
-7
lines changed

3 files changed

+5
-7
lines changed

ydb/core/protos/statistics.proto

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -201,6 +201,5 @@ message TEvAggregateStatisticsResponse {
201201

202202
message TSimpleColumnStatistics {
203203
optional uint64 Count = 1;
204-
optional uint64 CountNonNull = 2;
205-
optional uint64 CountDistinct = 3;
204+
optional uint64 CountDistinct = 2;
206205
};

ydb/core/statistics/aggregator/select_builder.cpp

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,10 +16,9 @@ ui32 TSelectBuilder::AddBuiltinAggregation(std::optional<TString> columnName, TS
1616
return Columns.back().Seq;
1717
}
1818

19-
ui32 TSelectBuilder::AddFactory(const TStringBuf& udafName) {
20-
// TODO: check UDAF existence, determine paramcount
19+
ui32 TSelectBuilder::AddFactory(const TStringBuf& udafName, size_t paramCount) {
20+
// TODO: check UDAF existence, validate paramcount
2121
ui32 curId = Udaf2Factory.size();
22-
size_t paramCount = 2;
2322
auto [it, emplaced] = Udaf2Factory.try_emplace(udafName, curId, udafName, paramCount);
2423
return it->second.Id;
2524
}

ydb/core/statistics/aggregator/select_builder.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ class TSelectBuilder {
2121
}
2222

2323
private:
24-
ui32 AddFactory(const TStringBuf& udafName);
24+
ui32 AddFactory(const TStringBuf& udafName, size_t paramCount);
2525

2626
private:
2727
struct TFactory {
@@ -49,7 +49,7 @@ class TSelectBuilder {
4949

5050
template<typename... TArgs>
5151
ui32 TSelectBuilder::AddUDAFAggregation(TString columnName, const TStringBuf& udafName, TArgs&&... params) {
52-
auto factory = AddFactory(udafName);
52+
auto factory = AddFactory(udafName, sizeof...(params));
5353

5454
// TODO: parameters escaping/binding
5555
TString paramsStr = Join(',', params...);

0 commit comments

Comments
 (0)